各位大大好
小弟最近剛接觸 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 的大大可以幫助我一下