步骤函数 - 从 SQS 读取?

Step functions - read from SQS?

SQS 中将有数千条消息。

是否可以在 Step 函数中等到 OrderId:123 (json) 在 SQS 中,然后在收到特定订单 ID 时执行 Lambda 函数?

编辑: Step Functions 定期调用 Lambda 函数,直到它设法检索具有特定属性的消息。 OrderId 属性将在消息正文中。例如:

{
  "OrderId": 1235,
  "Items": [{"Id":1, "Name": "Item 1"}]
}

不,无法从 Amazon SQS 中有选择地检索消息。

您的应用程序可以请求从 SQS 接收 1-10 条消息,但不能请求特定的消息。

参见:Finding certain messages in SQS

您可以改为将消息发送到 Amazon SNS,然后 Filter Messages with Amazon SNS 使用属性,还可以将 SQS 队列订阅到 SNS 主题以将消息的副本发送到 SQS,但这开始太复杂了。

您或许应该重新设计解决方案,让收到的订单触发下一个 activity,而不是搜索给定的订单响应。