Connexion aux services Web Amazon SQS (service Simple Queue) à l'aide de Python?

Question

Je me demandais si quelqu'un ici sait comment je peux me connecter à AWS SQS en utilisant Python? Ai-je besoin d'une URL publique?

Quelqu'un pourrait-il fournir un exemple de code simple sur la façon de faire cela?

Merci.

Answer 1

Voici quelques exemples de code pour pousser des messages dans SQS (désolé, en utilisant Boto plutôt que le boto3 recommandé) :

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' 

Voici s ome exemple de code à lire à partir de 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

Comme je l'ai dit dans les commentaires, utilisez boto:

import boto3 

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

# List SQS queues 
response = sqs.list_queues() 

print(response['QueueUrls']) 

Documentation here