SQS消息

Question

我需要安裝一個客戶端將發送SQS到服務器：

客戶端：

...
SQS = AWS :: SQS.new
q = sqs.queues.create（ 「q_name」）
M = q.send_message（ 「元」）
...

但如何服務器可以讀取客戶端的消息？
預先感謝您。

Answer 1

首先你需要讓你的服務器連接到SQS，然後你可以得到你的隊列。 在您的隊列上執行get_messages。請轉至boto docs以獲取有關屬性的更多信息。這將根據您的參數爲您提供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 

希望這會有所幫助。