1

私が理解している限りでは、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 メッセージをリッスンするにはどうすればよいでしょうか。

4

1 に答える 1