芹菜池运行协同任务
celery-pool-asyncio的Python项目详细描述
芹菜池异步
- 免费软件：apache软件许可证2.0
功能
import asyncio
from celery import Celery
app = Celery()
@app.task(
bind=True,
soft_time_limit=None, # temporary unimplemented. You can help me
time_limit=300, # raises futures.TimeoutError on timeout
)
async def my_task(self, *args, **kwargs):
await asyncio.sleep(5)
@app.task
async def my_simple_task(*args, **kwargs):
await asyncio.sleep(5)
然后运行芹菜：
$ celery worker -A hello_async_celery.app -P celery_pool_asyncio:TaskPool
更改日志
[0.1.4]
- 修复猴子：必须修补另一个功能
[0.1.3]
- 添加更改日志
- 附加文档
[0.1.2]
- 添加monkey patcher使brocker io操作不阻塞
[0.1.1]
- 重构代码
- 修复发现的错误
[0.1.0]
- 初始提交
欢迎加入QQ群-->： 979659372
