西芹殺死進程

Question

我用芹菜3.1.23。

任務的代碼非常簡單：

@app.task(bind=True, max_retries=None, default_retry_delay=settings.CELERY_RECONNECT_TIME) 
def analize_text(self, **kwargs): 
    print 'test' 
    return 1 

我啓動芹菜此命令：

芹菜-A任務工人--loglevel =信息--concurrency = 4 -n analize_text -Q analize.analize_text -Ofair

所以，我使用4個CPU。 問題是，芹菜定期殺死工人，並開始新的代替。新員工在日誌和新PID中都有新號碼。 這是我的日誌https://dpaste.de/N1Vk

它爲什麼這樣做？這個錯誤？

Answer 1

它取決於CELERY_MAX_TASKS_PER_CHILD，即工人在回收之前應完成的任務數量，默認爲無限制。

http://docs.celeryproject.org/en/latest/configuration.html#std:setting-CELERYD_MAX_TASKS_PER_CHILD

所以，你的芹菜配置可能有此限制設置爲一些低數量，因此你的員工越來越回收。 您可以在芹菜stats中查看更多信息。