QueueFetcher makes dealing with SQS queues in Django easier
Project description
QueueFetcher allows you to deal with Amazon SQS queues in an easier manner in Django.
It provides:
run_queue management task to start the task from cli
QueueFetcher class to do the heavy lifting with the pieces seperated out and testable
Getting started
Install queue-fetcher from pip
Add queue_fetcher to INSTALLED_APPLICATIONS
Add to your settings.py:
TEST_SQS = False
QUEUES = {
'Internal Name': 'Name On Amazon'
}
Now build your tasks in your tasks package:
from queue_fetcher.tasks import QueueFetcher class SampleQueueTask(QueueFetcher): queue = 'test' def process_sample(self, msg): raise NotImplementedError('This does nothing.. yet')
QueueFetcher expects messages from SQS to contain a list of events, with each event containg a message_type attribute of something like update_transaction.
This is then dispatched to a function prefixed with process_.
Project details
NoneRelease 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
Hashes for queue_fetcher-1.6.2-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | a7ec992fd76e07b31dfdd3a24bd8e9405df825e61fc320d98d1cafd59ef22bd4 |
|
MD5 | 27b634ccc2f0d7fa7114c367ad062794 |
|
BLAKE2b-256 | 27d1d222f2a86c84b556dffa7fd6cc1d1182d6cecd27c56dfa88abdfc9c4d1d3 |