Our internal queue wrapper.
Project description
pillar-queue-wrapper
Pillar's wrapper around AWS SQS
There are 2 options for authentication through this wrapper
- Explicit: Where the 'aws_access_key' and 'aws_access_secret' are explicitly passed into the queue function
- Implicit: Where 'None' is passed into the queue function and it trys to get the credetials from the AWS cli Install the aws cli and add the 'aws_access_key' and 'aws_access_secret' to it.
Quickstart/Basic Usage
q = Queue(
name="queuename",
aws_access_key="aws_access_key here",
aws_access_secret="aws_access_secret here",
aws_default_region='us-east-1',
)
#Note if a queue name ends with .fifo, it is a fifo queue
q.send_message(message="A test message", message_attributes={}, message_group_id=None, deduplication_id=None)
#blocking function that will wait for a message to appear
message = q.wait_for_message(delete_message=True)
print(message.body)
Testing
-
Install AWS CLI with
pip install awscli
, insert your AWS iam Access key ID and Secret access key found in the AWS IAM console -
Make two queues in the SQS Tab called
testqueue
andtestqueue.fifo
. The queuetestqueue.fifo
should be of the FIFO type detailed here. These queues will be used to run the tests. -
Run 'pytest'
Future Features:
- Queue creation/destruction
- Message pooling
- get,set, and delete functionality to use queues like arrays pythonically
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Close
Hashes for pillar-queue-wrapper-0.0.1.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | 271752422aa286a7fb56d2a601e5d4b7200eb8c2035196cfea3ae8fc2887d77c |
|
MD5 | a92a4cc720b26b263d682a8989a6054e |
|
BLAKE2b-256 | 44ace204464cdc920fb0bf4a0a7272bc23264a29939d294e9a362ff5b29196f8 |
Close
Hashes for pillar_queue_wrapper-0.0.1-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | b13e48374240c9842c6f465a361bf2d6b98c2f64f522a4385bf40d2b6fb542e4 |
|
MD5 | 06c03fb939227961dcc749376549d3ee |
|
BLAKE2b-256 | 2091d9a81f38d7157834c0c08cf5a5e1dd9144d6d1b451c4f73434fb41832789 |