SQSClient

SQSClient 用于与 AWS Simple Queue Service (SQS) 交互。

借助它，用户可以向指定队列发送消息，并列出当前区域中可用的队列。

SQSClient 包含在专用的 sqs.js jslib bundle 和包含所有服务客户端的 aws.js bundle 中。

方法

函数	描述
`sendMessage`	向指定队列发送消息。
`listQueues`	返回当前区域中的队列列表。

抛出错误

SQSClient 方法在失败时抛出错误。

Error	条件
`InvalidSignatureError`	使用无效凭据时
`SQSServiceError`	当 AWS 回应请求的操作时发生错误

示例

import exec from 'k6/execution';

import {
  AWSConfig,
  SQSClient,
} from 'https://jslib.k6.io/aws/0.13.0/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.urls.filter((q) => q === testQueue).length == 0) {
    exec.test.abort();
  }

  // Send message to test queue
  await sqs.sendMessage(testQueue, JSON.stringify({ value: '123' }));
}