使用相同的 SQS 到多个 Lambda

AWS Lambda 是一项强大的服务，它允许您以一种完全托管的方式运行代码，而无需考虑基础设施方面的任何事情。一般来说，Lambda 函数是独立的，直接处理一些输入，并返回一些输出。但是，有时您可能需要将同一个输入发送到多个 Lambda 函数。在这种情况下，您可以使用 Amazon Simple Queue Service（SQS）作为中间队列来协调 Lambda 函数。

步骤

以下是将相同的 SQS 消息发送到多个 Lambda 函数的步骤：

1. 创建一个新的 SQS 队列，并向它添加所需数量的订阅。
2. 创建 Lambda 函数，并将其设置为作为一个 SQS 队列的相关订阅者。
3. 创建额外的 Lambda 函数，并将每个 Lambda 函数都将其设置为相同的 SQS 队列的订阅者。

在上述步骤中，您可以使用 AWS Lambda 控制台或者 AWS CLI 来完成得到的结果相同。

控制台方式

1. 打开 AWS 控制台，并前往 Amazon SQS 服务页面。
2. 创建新的 SQS 队列，并记录其 ARN。
3. 在 Lambda 控制台创建一个新的函数，并将其代码上传到 Lambda。
4. 将新的 Lambda 函数与创建的 SQS 队列相关联。
5. 使用 Lambda 控制台中的“Add Trigger”功能，向该函数添加 SQS 触发器，并将其与上述创建的新队列相关联。
6. 完成并创建该 Lambda 函数。
7. 在 Lambda 控制台中，重复第 3-6 步，以创建任意数量的 Lambda 函数，并将这些函数都与相同的创建的队列相关联。

注意要为每个相同的 SQS 队列创建新的消费者，否则消息将无法正确被处理。

AWS CLI 方式

使用 AWS CLI 时，您需要遵循以下步骤：

1. 创建具有所需权限的 AWS 资源访问 IAM 角色，并为您的 AWS CLI 配置它们。
2. 使用 AWS CLI 工具创建新的 SQS 队列，记录其 ARN。
3. 使用 AWS CLI 创建新的 Lambda 函数，并将其与创建的队列相关联。请确保在此步骤中将您的 AWS 资源访问 IAM 角色与 Lambda 函数相关联。
4. 使用 AWS CLI 工具将新创建的 Lambda 函数与 SQS 队列相关联。
5. 在 AWS CLI 中使用“lambda-add-permission”命令，为您的每个 Lambda 函数授权运行所需操作。
6. 使用如下命令为您的 Lambda 函数添加 SQS 触发器：``` $ aws lambda create-event-source-mapping --function-name my-function --batch-size 1 --event-source-arn arn:aws:sqs:us-west-2:account-id:my-queue --region us-west-2

简要解释：

- `–function-name`：您要附加触发器的函数。
- `–batch-size`：每个 Lambda 调用的并行处理记录数。
- `–event-source-arn`：与此触发器关联的事件源 ARN。
- `–region`：您使用的区域。

7. 重复第 3-6 步，以创建任意数量的 Lambda 函数，并将这些函数都与相同的创建的队列相关联。

## 处理多个消费者

由于每个消息将发送到您使用的所有订阅者，因此您需要考虑每个消费者处理的消息数量。这可以通过调整“Batch Size”参数来处理，从而设置每个批次的记录数，然后将每个消费者分配给特定的消息批次。

## 结论

将相同的 SQS 消息发送到多个 Lambda 函数可以确保您的应用程序的可伸缩性和可用性。本文介绍了如何使用 AWS 控制台和 AWS CLI 完成这个过程。要提高消息处理效率，请使用“Batch Size”参数来处理多个消费者。