当新消息添加到队列时如何从 AWS SQS 接收通知

Question

我正在尝试从 AWS 设置 SQS 队列，我的目标是

1. 收到来自 sns 主题的通知，该主题基本上来自亚马逊市场。
2. 当收到新消息时，我需要通知我的应用程序收到一条新消息以及该消息，或者至少通知有一条新消息。

有办法实现这一点吗？从文档中我可以看到我们可以使用 sdk 接收消息，并且我正在使用 Node js、Express、链接到 amazon sdk-javaScript for sqs。我应该以一定的时间间隔继续检查 sqs 吗？我相信应该有更好的方法。

Answer 1

一种选择是设置一个连接到该 SQS 队列的 Elastic Beanstalk 工作类型环境。当您创建一个工作者类型的 beanstalk env（您可以在其中选择 Node）时，您可以指定它使用哪个队列以及 SQS 将向其发布新消息的 HTTP 路径（expressjs POST 处理程序或其他）。它使消耗队列变得更容易，您可以返回 200 来销毁消息，或者从该 POST 中抛出以将其放回队列中以重试或将其置为死信。