步骤函数 - 从 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,而不是搜索给定的订单响应。
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,而不是搜索给定的订单响应。