python - 如何检查 ec2 中的 SNS？

Question

据我了解，SNS 可以向订阅者推送消息。我有一个简单的脚本，可以将消息推送到 SQS。但我想做的基本上是:我有一个SNS主题，有一个EC2实例，有一个SQS。 SQS 订阅了 SNS 主题。

我想要执行以下操作，当我在 SNS 中创建新消息时，我希望 EC2 收到此通知以检查 SQS。我可以完成最后一部分(去检查 SQS)，但不明白如何接收消息??????

例如，

发布:

context = zmq.Context()
socket = context.socket(zmq.PUB)
socket.bind("tcp://*:%s" % '5556')
socket.send("HI")  

子

socket.recv()

从上面的例子来看，PUB 应该是我的 SNS，SUB 是我的 EC2，对吧？那么如何监听新的SNS消息呢？

Answer 1

如果您想要一种简单的方法来设置监听器，其中包括在处理完成后自动删除消息以及将异常自动推送到指定队列，则可以使用 pySqsListener包裹。

您可以像这样设置监听器:

from sqs_listener import SqsListener

class MyListener(SqsListener):
    def handle_message(self, body, attributes, messages_attributes):
        run_my_function(body['param1'], body['param2']

listener = MyListener('my-message-queue', 'my-error-queue')
listener.listen()

有一个标志可以从短轮询切换到长轮询 - 所有这些都记录在 README 文件中。