Simple Queue Jobs TF Fork
Project description
Origin
This is a fork of the original [sqjobs](https://github.com/igalarzab/sqjobs/)
Installation
Simply use pip to install the last version of sqjobs
pip install --upgrade sqjobs
Getting started
First you have to create jobs. A job is simply a class that inherits from Job.
from sqjobs import Job
class Adder(Job):
default_queue_name = 'queue_name'
def run(self, num1, num2):
return num1 + num2
Then, you can launch the job creating a new broker.
from sqjobs import create_sqs_broker
broker = create_sqs_broker(access_key='ak', secret_key='sk')
broker.add_job(AdderJob, 1, 2, queue_name='other_queue_name')
Documentation
Check out sqjobs’s documentation for further information.
Project details
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
sqjobstf-0.8.tar.gz
(17.5 kB
view hashes)
Built Distributions
sqjobstf-0.8-py2.7.egg
(25.2 kB
view hashes)
sqjobstf-0.8-py2-none-any.whl
(28.1 kB
view hashes)