各位大大好
小弟最近刚接触 celery 目前用 Django 结合 celery 处理 long process
可是遇到问题就是 celery worker 是否有什么处理 task 的限制
我丢入的 task 到一定数量后 就会开始 loop
worker 会不理我后面丢入的 task
我的 Django 架构大致如下
proj 根目录
└ app
├─ myapp.py # 跑分析的 code
├─ tasks.py
└─ views.py
程式码如下
https://gist.github.com/anonymous/1ba5217364d481f61007df4ed1d43a50
原本还以为是我分析的 code 有问题
结果改成单纯的 print 值也有问题
我从 0 开始开始 +1 +1 print 过去
到第8个他就不理我 进入 loop 了
结果如下
http://imgur.com/vZJpjZ1
希望熟悉 celery 的大大可以帮助我一下