使用Python连接到Amazon Web Services SQS(简单的队列服务)

Question

我想知道这里的人是否知道如何使用Python连接到AWS SQS？我需要一个公共网址吗？

有人可以提供一个简单的代码示例吗？

谢谢。

Answer 1

以下是一些用于将消息推入SQS的示例代码(对不起，使用Boto而不是推荐的Boto3(：

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读取：

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)

Answer 2

正如我在评论中所说的，使用 boto：

import boto3
# Create SQS client
sqs = boto3.client('sqs')
# List SQS queues
response = sqs.list_queues()
print(response['QueueUrls'])

文档此处