Connectez-vous à Elastic MQ avec boto

Une alternative locale à Amazon SQS.

La méthode utilisant connect_to_region de boto arrive souvent, S'il s'agit d'un ElasticMQ local, vous devez vous connecter avec regioninfo.SQSRegionInfo, alors notez-le.

Il semble que si ʻis_secure est défini sur True, il devient https`.

Préparation

ElasticMQ est abandonné et démarré. Par défaut, le port est «9324».

$ java -jar ~/opt/elasticmq-server-0.8.8.jar

Celui à envoyer

#!/usr/bin/env python
# -*- coding: utf-8 -*-

import sys
from boto.sqs import regioninfo
from boto.sqs.message import Message

AWS_ACCESS_KEY = 'TEST'   #Tout EMQ est bien
AWS_SECRET_KEY = 'TEST'   #Tout EMQ est bien

SQS_REGION     = "emq"         #Tout EMQ est bien
SQS_ENDPOINT   = "localhost"

#Pour AWS
# SQS_REGION = "ap-northeast-1"
# SQS_ENDPOINT = "sqs.ap-northeast-1.amazonaws.com"

SQS_QUEUE_NAME = 'dev_messages'
PORT = 9324     #80 pour AWS/Ou ne spécifiez pas

region = regioninfo.SQSRegionInfo(name=SQS_REGION, endpoint=SQS_ENDPOINT)
conn = region.connect(
        aws_access_key_id=AWS_ACCESS_KEY,
        aws_secret_access_key=AWS_SECRET_KEY,
        port=PORT,
        is_secure=False
    );

queue = conn.create_queue(SQS_QUEUE_NAME)
msg = Message(
    body='QUEUE TEST',
)
msg.message_attributes = {
        "name1": {
            "data_type": "String",
            "string_value": "I am a string"
        },
    }
queue.write(msg)

Celui qui reçoit

#!/usr/bin/env python
# -*- coding: utf-8 -*-

import sys
from boto.sqs import regioninfo
from boto.sqs.message import Message

AWS_ACCESS_KEY = 'TEST'   #Tout EMQ est bien
AWS_SECRET_KEY = 'TEST'   #Tout EMQ est bien

SQS_REGION     = "emq"         #Tout EMQ est bien
SQS_ENDPOINT   = "localhost"

#Pour AWS
# SQS_REGION = "ap-northeast-1"
# SQS_ENDPOINT = "sqs.ap-northeast-1.amazonaws.com"

SQS_QUEUE_NAME = 'dev_messages'
PORT = 9324     #80 pour AWS/Ou ne spécifiez pas

region = regioninfo.SQSRegionInfo(name=SQS_REGION, endpoint=SQS_ENDPOINT)
conn = region.connect(
        aws_access_key_id=AWS_ACCESS_KEY,
        aws_secret_access_key=AWS_SECRET_KEY,
        port=PORT,
        is_secure=False
    );

queue = conn.get_queue(SQS_QUEUE_NAME)
queue.set_attribute('ReceiveMessageWaitTimeSeconds', 20)

import json

msgs = queue.get_messages(10)
for msg in msgs:
    print json.dumps(msg.__dict__, default=str)
    queue.delete_message(msg)