Pythonを使用してAWS SQSに接続する方法を知っている人がいますか?パブリックURLが必要ですか?Amazon Webサービスに接続Pythonを使用してSQS(Simple Queueサービス)?
誰かがこれを行う方法の簡単なコード例を提供できますか?
ありがとうございます。
Pythonを使用してAWS SQSに接続する方法を知っている人がいますか?パブリックURLが必要ですか?Amazon Webサービスに接続Pythonを使用してSQS(Simple Queueサービス)?
誰かがこれを行う方法の簡単なコード例を提供できますか?
ありがとうございます。
はここで(申し訳ありませんが、むしろ推奨boto3よりのbotoを使用して)SQSにメッセージをプッシュするためのいくつかのサンプルコードです:
import boto, boto.sqs
from boto.sqs.message import Message
from optparse import OptionParser
# Parse command line
parser = OptionParser()
(options, args) = parser.parse_args()
# Send to SQS
q_conn = boto.sqs.connect_to_region("ap-southeast-2")
q = q_conn.get_queue('cheese-queue')
if q==None:
print "No queue!"
else:
m = Message()
m.set_body(args[0])
q.write(m)
print args[0] + ' pushed to Queue'
SQSから読み取るためOMEサンプルコード:
import boto, boto.sqs
from boto.sqs.message import Message
# Connect to Queue
q_conn = boto.sqs.connect_to_region("ap-southeast-2")
q = q_conn.get_queue('cheese-queue')
# Get a message
m = q.read(visibility_timeout=15)
if m == None:
print "No message!"
else:
print m.get_body()
q.delete_message(m)
私はboto
を使用し、コメントで言ったように:
import boto3 # Create SQS client sqs = boto3.client('sqs') # List SQS queues response = sqs.list_queues() print(response['QueueUrls'])
ドキュメントhere
使用[ 'boto'(http://boto3.readthedocs.io/en/latest/guide/sqs-example-using-queues.html)モジュール –