PyQS is a simple task-queue for SQS.
email/tasks.py
@task()
def send_email(subject):
pass
Then later run
send_email.delay(subject='Hi there')
This task will get enqueued to a new 'emailer.tasks.send_email' queue.
If you wanted to put it on a particular queue, say 'email', you can do
email/tasks.py
@task(queue='email')
def send_email(subject):
pass
Run the worker:
$ pyqs email.tasks.send_email
Or to run all tasks
$ pyqs email.*
This is based on Python's fnmatch.
- 'failure' queue?
- special logger?
- sentry integration?