从twisted作为调用任务运行内联回调
txinvoke的Python项目详细描述
从Twisted作为Invoke任务运行内联回调。
安装
pip install txinvoke
示例
# -*- coding: utf-8 -*-# tasks.pyimporttimeimporttxmongofromtxinvokeimporttask_on_callbacks@task_on_callbacks(name='test_task')defexample(verbose=False):connection=yieldtxmongo.MongoConnection()test_collection=connection.db.testforxinrange(10000):data=x*time.time()doc={'something':data}yieldtest_collection.insert(doc,safe=True)ifverbose:print("Test data '{data}' was inserted".format(data=data))
注意事项
很抱歉,链接的任务当前无法工作。