0

我需要设置一个将 sqs 发送到服务器的客户端:

客户端:

...
sqs = AWS::SQS.new
q = sqs.queues.create("q_name")
m = q.send_message("meta")
...

但是服务器如何读取客户端的消息?
先感谢您。

4

1 回答 1

0

首先你需要让你的服务器连接到 SQS 然后你可以得到你的队列。在您的队列上执行 get_messages。转到boto 文档以获取有关属性的更多信息。这将根据您的参数为您提供 1 到 10 个消息对象。然后在每个对象上执行 get_body() 然后您将获得消息的字符串。

这是python中的一个简单示例。抱歉不知道红宝石。

sqsConn = connect_to_region("us-west-1", # this is the region you created the queue in
                        aws_access_key_id=AWS_ACCESS_KEY_ID,
                        aws_secret_access_key=AWS_SECRET_ACCESS_KEY)

QUEUE = sqsConn.get_queue("my-queue") # the name of your queue

msgs = QUEUE.get_messages(num_messages=10, # try and get 10 messages
                          wait_time_seconds=1, # wait 1 second for these messages
                          visibility_timeout=10) # keep them visible for 10 seconds

body = msgs[0].get_body() # get the string from the first object

希望这可以帮助。

于 2013-04-09T23:03:35.507 回答