在 AWS 中将 SNS 订阅到 SQS?
Subscribing SNS to SQS in AWS?
查看这张图片:
这些消息非常重要,因此我在中间使用了一个队列。
但是现在 - 在右侧 SNS 上,我需要有多个订阅者 (Lambdas)。
但是现在,如何将右侧的SNS订阅到中心的SQS?
问题:
是否可以将 SNS 订阅到 SQS? (意思是 - 将消息从 SQS 传递到 SNS)
SNS 是一个主题,它不订阅任何东西。无法接收数据,需要发布到。
但是,您可以从应用程序代码向其发布。为此,您可以在中间将消费者附加到您的 SQS。这可以是 Java 应用程序或简单的 lambda 代码。
这里有一些使用各种语言的参考资料。
首先创建一个新的 Lambda 函数来向 SNS 主题发送消息。
参考这个 - https://github.com/aws-samples/serverless-app-examples/tree/master/python/step-functions-send-to-sns
然后您可以配置您的队列以在接收到有效负载时触发 Lambda 函数。
查看这张图片:
这些消息非常重要,因此我在中间使用了一个队列。 但是现在 - 在右侧 SNS 上,我需要有多个订阅者 (Lambdas)。
但是现在,如何将右侧的SNS订阅到中心的SQS?
问题:
是否可以将 SNS 订阅到 SQS? (意思是 - 将消息从 SQS 传递到 SNS)
SNS 是一个主题,它不订阅任何东西。无法接收数据,需要发布到。
但是,您可以从应用程序代码向其发布。为此,您可以在中间将消费者附加到您的 SQS。这可以是 Java 应用程序或简单的 lambda 代码。
这里有一些使用各种语言的参考资料。
首先创建一个新的 Lambda 函数来向 SNS 主题发送消息。 参考这个 - https://github.com/aws-samples/serverless-app-examples/tree/master/python/step-functions-send-to-sns
然后您可以配置您的队列以在接收到有效负载时触发 Lambda 函数。