Skip to content

Commit 4d5b174

Browse files
authored
feat: set number of SQS consumers dynamically (#3472)
1 parent b9f8a44 commit 4d5b174

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

packages/artillery/lib/platform/aws-ecs/legacy/sqs-reporter.js

+5-1
Original file line numberDiff line numberDiff line change
@@ -36,6 +36,10 @@ class SqsReporter extends EventEmitter {
3636
// Debug info:
3737
this.messagesProcessed = {};
3838
this.metricsMessagesFromWorkers = {};
39+
40+
this.poolSize = typeof process.env.SQS_CONSUMER_POOL_SIZE !== 'undefined'
41+
? parseInt(process.env.SQS_CONSUMER_POOL_SIZE, 10)
42+
: Math.max(Math.ceil(this.count / 10), 75);
3943
}
4044

4145
_allWorkersDone() {
@@ -326,7 +330,7 @@ class SqsReporter extends EventEmitter {
326330
};
327331

328332
this.sqsConsumers = [];
329-
for (let i = 0; i < 30; i++) {
333+
for (let i = 0; i < this.poolSize; i++) {
330334
const sqsConsumer = createConsumer(i);
331335

332336
sqsConsumer.on('error', (err) => {

0 commit comments

Comments
 (0)