2017-06-07 10 views

答えて

1

はここで(申し訳ありませんが、むしろ推奨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) 
+0

コードありがとう!例えばpycharmでこれを書いたり、pythonシェルを使う必要がありますか? – raxor

+0

解決済み! Pycharmを使ってもうまくいきました! – raxor

0

私はbotoを使用し、コメントで言ったように:

import boto3 

# Create SQS client 
sqs = boto3.client('sqs') 

# List SQS queues 
response = sqs.list_queues() 

print(response['QueueUrls']) 

ドキュメントhere

+0

感謝あなたはそんなに!私はこのフォーラムに新しいので、もし私が何か間違っている私は申し訳ありません:) – raxor

+0

まだSQSからメッセージを取得している問題を..すべてのガイドは、boto3、aws cliなどをインストールしています..私はpycharm内でコーディングしていますエラーが発生します。:/ – raxor

関連する問題