sqjobs 0.7.1

安装

只需使用pip安装最新版本的sqjobs

pip install --upgrade sqjobs

开始

首先你必须创造就业机会。作业只是一个继承 来自Job。

fromsqjobsimportJobclassAdder(Job):default_queue_name='queue_name'defrun(self,num1,num2):returnnum1+num2

然后，您可以启动创建新代理的作业。

fromsqjobsimportcreate_sqs_brokerbroker=create_sqs_broker(access_key='ak',secret_key='sk')broker.add_job(AdderJob,1,2,queue_name='other_queue_name')

文档

查看sqjobs’s documentation了解更多信息。