This is documentation for the next version of K6. For the latest stable release, go to the latest version.
sendMessage
SQSClient.sendMessageBatch(queueUrl, entries)
delivers up to ten messages to the specified Amazon Simple Queue
Service (SQS) queue.
Parameters
SendMessageBatchEntry
Returns
MessageBatchResponse
Example
import exec from 'k6/execution';
import {
AWSConfig,
SQSClient,
} from 'https://jslib.k6.io/aws/0.12.3/sqs.js';
const awsConfig = new AWSConfig({
region: __ENV.AWS_REGION,
accessKeyId: __ENV.AWS_ACCESS_KEY_ID,
secretAccessKey: __ENV.AWS_SECRET_ACCESS_KEY,
sessionToken: __ENV.AWS_SESSION_TOKEN,
});
const sqs = new SQSClient(awsConfig);
const testQueue = 'https://sqs.us-east-1.amazonaws.com/000000000/test-queue';
export default async function () {
// If our test queue does not exist, abort the execution.
const queuesResponse = await sqs.listQueues();
if (queuesResponse.queueUrls.filter((q) => q === testQueue).length == 0) {
exec.test.abort();
}
// Prepare a bunch of batch messages to add to the queue
const messageBatch = [
{ messageId: '0', messageBody: 'test0' },
{ messageId: '1', messageBody: 'test1' },
];
// Send the batch of messages to the queue
await sqs.sendMessageBatch(testQueue, messageBatch);
}