diff --git a/tests/stress_test.sh b/tests/stress_test.sh index 57c37ed..b248102 100755 --- a/tests/stress_test.sh +++ b/tests/stress_test.sh @@ -33,7 +33,7 @@ POD_LABEL="app.kubernetes.io/name=shared-sqs" # Параметры нагрузки — ЖЁСТКИЕ CONCURRENT_WORKERS=20 # параллельных воркеров -MESSAGES_PER_WORKER=15 # сообщений на воркер (итого 1000) +MESSAGES_PER_WORKER=10 # сообщений на воркер (итого 1000) BURST_SIZE=80 # размер burst-пакета TENANT_COUNT=5 # тенантов для multi-tenant теста QUEUE_FLOOD_COUNT=25 # очередей на тенанта @@ -353,7 +353,7 @@ echo "" # ═══════════════════════════════════════════════════════════ # 4. MULTI-TENANT ИЗОЛЯЦИЯ — 5 тенантов × 50 msg одновременно # ═══════════════════════════════════════════════════════════ -MSGS_PER_TENANT=50 +MSGS_PER_TENANT=30 echo "═══ 4. Multi-tenant изоляция: ${TENANT_COUNT} тенантов × ${MSGS_PER_TENANT} msg ═══" SEC4_START=$(date +%s) @@ -470,7 +470,7 @@ LONGPOLL_QURL=$(qurl "$T1_ID" "$LONGPOLL_Q") # Consumer: читает с long-poll, считает сколько получит за 30s ( - end=$((SECONDS + 30)) + end=$((SECONDS + 20)) total_recv=0 while [[ $SECONDS -lt $end ]]; do R=$(sqs "$T1_AK" "$T1_SK" receive-message --queue-url "$LONGPOLL_QURL" \ @@ -497,7 +497,7 @@ for p in $(seq 1 5); do printf "[LP-prod${p}:${ok}] " >&2 ) & done -echo " ⏳ Long-poll: consumer ждёт, producers отправляют (30s)..." +echo " ⏳ Long-poll: consumer ждёт, producers отправляют (20s)..." wait echo "" @@ -793,16 +793,16 @@ R=$(sqs "$T1_AK" "$T1_SK" create-queue --queue-name "$MIXED_Q") MIXED_QURL=$(qurl "$T1_ID" "$MIXED_Q") # Предзагрузка 100 msg -for m in $(seq 1 100); do +for m in $(seq 1 30); do sqs "$T1_AK" "$T1_SK" send-message --queue-url "$MIXED_QURL" \ --message-body "mixed-init-${m}" >/dev/null 2>&1 if (( m % 20 == 0 )); then printf "[init:${m}] " >&2; fi done echo "" -echo " Начальная загрузка: 100 msg" +echo " Начальная загрузка: 30 msg" # 10 Отправителей -for w in $(seq 1 10); do +for w in $(seq 1 5); do ( end=$((SECONDS + MIXED_DURATION)); ok=0 while [[ $SECONDS -lt $end ]]; do @@ -815,7 +815,7 @@ for w in $(seq 1 10); do done # 10 Читателей-удалителей -for w in $(seq 1 10); do +for w in $(seq 1 5); do ( end=$((SECONDS + MIXED_DURATION)); recv=0 while [[ $SECONDS -lt $end ]]; do @@ -834,7 +834,7 @@ for w in $(seq 1 10); do done # 3 GetQueueAttributes -for w in $(seq 1 3); do +for w in $(seq 1 2); do ( end=$((SECONDS + MIXED_DURATION)); ok=0; fail=0 while [[ $SECONDS -lt $end ]]; do @@ -863,11 +863,11 @@ wait echo "" MIXED_SENT=0; MIXED_RECV=0; ATTR_OK=0; ATTR_FAIL=0 -for w in $(seq 1 10); do +for w in $(seq 1 5); do [[ -f "${TMPDIR_STRESS}/mixed_send_${w}.result" ]] && MIXED_SENT=$((MIXED_SENT + $(cat "${TMPDIR_STRESS}/mixed_send_${w}.result"))) [[ -f "${TMPDIR_STRESS}/mixed_recv_${w}.result" ]] && MIXED_RECV=$((MIXED_RECV + $(cat "${TMPDIR_STRESS}/mixed_recv_${w}.result"))) done -for w in $(seq 1 3); do +for w in $(seq 1 2); do if [[ -f "${TMPDIR_STRESS}/mixed_attr_${w}.result" ]]; then IFS=':' read -r ok fail < "${TMPDIR_STRESS}/mixed_attr_${w}.result" ATTR_OK=$((ATTR_OK + ok)); ATTR_FAIL=$((ATTR_FAIL + fail))