4. awssqstools

AwsSQSTools

class awssqstools.AwsSQSTools(aws_access_key_id, aws_secret_access_key, region, queue_name)

Bases: boto.sqs.connection.SQSConnection

AwsSQSTools

Parameters:

• aws_access_key_id (str) – aws_access_key_id
• aws_secret_access_key (str) – aws_secret_access_key
• region (str) – region.
• queue_name (str) – AWS SQS queue name.

get_all_queues(*args, **kwargs)

Get all queue

Return type:list Returns:A list of boto.sqs.queue.Queue instances.

get_messages(num_messages=10, *args, **kwargs)

Get messages from queue

Parameters:num_messages (int) – get message in one time. Return type:list Returns:A list of boto.sqs.message.Message instances

Todo

• Need to increase get_messages concurrency.
• Maybe auto convert json object.

write(body)

Write a message into queue

Parameters:body (str) – message body Return type:boto.sqs.message.Message Returns:boto.sqs.message.Message

write_batch(body_list)

Write huge messages will be split 10 messages in each single request.

Parameters:body_list (list) – a list of message raw data. Return type:list Returns:boto.sqs.batchresults.BatchResults in list

Todo

default args.