celery 官方要 5.0 才支持 asyncio
我的是这么实现在 celery 中跑 async def 的
```
import asyncio
def run_async(coro):
return
asyncio.run(coro)
@
app.task
def celery_task(*args, **kwargs):
return run_async(async_func(*args, **kwargs))
async def async_func(*args, **kwargs):
rv = await sub_func()
# do sth
return rv
async def sub_func():
return 1
# Usage:
def view(request):
task = celery_task.delay(request)
return Response({'task_id':
task.id})
```