/PyQS

Python task-queues for Amazon SQS

Primary LanguagePython

PyQS - Python task-queues for Amazon SQS

Build Status

WARNING: This library is still under active development and should not be used in production.

In a nutshell

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.

Exception Handling

  • 'failure' queue?
  • special logger?
  • sentry integration?