存储它
worker的Python项目详细描述
简单工人
注意：此包仍在alpha中。小心使用！
快速启动
安装工作程序：
pip install worker
使用工作线程：
data=[{'hello':'world'},]*40info={'worker':'xxx.yyy.worker_do_sth'}worker=Worker(mode='thread')resp=worker.work(data,info)print(resp)
defworker_do_sth(data,info):print(data)returndatadefcallback(results):print('final')print(results)deftest_celery():data=['u11','u22','u33','u44','u21','u22','u23','u24','u31','u32','u33','u34','u41','u42','u43','u44','u51','u52','u53','u54',]*8info={'celery_worker':'test.functional.test_celery.simple','worker':'test.functional.test_celery.worker_do_sth','celery_max_workers':4,'celery_chunk_size':80,'chunk_size':20,'final_callback':'test.functional.test_celery.callback','queue':'123'}worker=Worker(mode='celery')resp=worker.work(data,info)returnresp
欢迎加入QQ群-->： 979659372
