py-queue-factory is a python library that takes care of creating required queue instances so that you only have to worry about actually using the queue
pip install git+https://github.com/practo/py-queue-factory.git@<version>
or
pip install git+https://github.com/practo/py-queue-factory.git@<commit hash>Params required queue_uri, host_url and subdomain
queue_uri is used to decide what type of queue to create (SQS, SQS Local, Beanstalk)
host_url and subdomain is used to decide the actual queue name (staging name/latest is suffixed to queue name)
If queue prefix is prod-subscriptions-
queue name is random-queue
and host url is https://subscriptions-stag.practodev.com
actual queue name would be prod-subscriptions-random-queue-stag
- Send Message
- Receive Message
- Delete Message
- Create queue if not exists
- Configurable visibility timeout
- Configurable encoding (json/base64)
- SQS Spooling
- Send Message
- Receive Message
- Delete Message
- Create queue if not exists
- Configurable visibility timeout
- Configurable encoding (json/base64)
- SQS Spooling (Don't know if spool-consumer supports aws local)
- Send Message
- Receive Message
- Delete Message
- Create queue if not exists
# Format for AWS SQS queue
QUEUE_URI = 'https://<aws_access_key>:<aws_secret_key>@sqs.<region>.amazonaws.com/<account_id>/<queue_prefix>'
# Format for AWSLocal/localstack SQS queue
QUEUE_URI = 'https://anything:anything@sqs.<region>.awslocal:<sqs_port>/<account_id>/<queue_prefix>'
#Example AWS local SQS queue uri
QUEUE_URI = 'https://anything:[email protected]:4576/1/prod-subscriptions-'
#Example AWS SQS queue uri
QUEUE_URI = 'https://AKIAJHY5ABCPXF4YXXYZ:kdsjhfkjsdksdfkdsjnckjsdnkfjdsdkfjndskjf@sqs.ap-south-1.amazonaws.com/961234512345/prod-subscriptions-'For debugging you can clone this repo locally and install it from that location
pip install -e <location of py_queue_factory>Note: Remove any previously installed version of this library