使用 Python 连接到 Amazon Web 服务 SQS（简单队列服务）？

Question

我想知道这里是否有人知道如何使用 Python 连接到 AWS SQS？我需要 public Url 吗？

有人可以提供有关如何执行此操作的简单代码示例吗？

谢谢。

Answer 1

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

import boto3

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

# List SQS queues
response = sqs.list_queues()

print(response['QueueUrls'])

文档here

Answer 2

下面是一些将消息推送到 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)

使用 Python 连接到 Amazon Web 服务 SQS（简单队列服务）？

Connect to Amazon web services SQS (Simple Queue service) using Python?

python

amazon-sqs

amazon-web-services