API网关SQS集成与SendMessageBatch

首先，需要在 API 网关中创建一个资源和相应的方法来处理发送多条消息到 SQS 队列的请求。以下是一个使用 AWS API Gateway 和 AWS Lambda 的 Node.js 示例代码：

exports.handler = async (event) => {
  const AWS = require('aws-sdk');

  const sqs = new AWS.SQS({
    region: process.env.AWS_REGION,
  });

  const params = {
    Entries: [], // 将要发送到 SQS 的消息集合
    QueueUrl: process.env.SQS_QUEUE_URL, // SQS 队列的 URL
  };

  // 处理从 API Gateway 接收到的每个请求中的消息
  for (const record of event.Records) {
    const entry = {
      Id: record.messageId,
      MessageBody: record.body,
    };
    
    params.Entries.push(entry);
  }

  // 向 SQS 发送多条消息
  const result = await sqs.sendMessageBatch(params).promise();

  return result;
};

然后，需要配置 API Gateway 接收来自客户端的请求并将其代理到 Lambda 函数。转到 API 网关控制台并按照以下步骤操作：

1. 创建一个新的 API。
2. 创建一个新的资源并分配相应的路径。例如，'/send-messages”。
3. 为'/send-messages”资源创建一个 POST 方法，并选择 Lambda 作为集成类型。
4. 选择您的 Lambda 函数，并确保在集成请求中启用代理。这将确保 API Gateway 将请求正文发送给 Lambda 函数。
5. 配置 API Gateway 来将任何必需的标头传递给 Lambda 函数，例如将消息体设置为特定的格式。

最后，您需要为 Lambda 函数授予权限以调用 SQS。您可以为执行 Lambda 函数的 IAM 角色授予 SQS 发送消息的权限，也可以使用以下策略为 Lambda 函数授予权限：

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Action": [
                "sqs:SendMessageBatch"
            ],
            "Resource": [
                "arn:aws:sqs:region:account-id:queue-name"
            ]
        }
    ]
}

别忘了替换资源 ARN：'region”和'account-id”替换为这些值的实