Celery 中的 [每个子进程的最大任务设置] 到底意味着什么?

yad*_*ick 8 celery python-3.x

该文档是:

\n\n
\n

使用此选项,您可以配置工作进程在被新进程替换\xe2\x80\x99s 之前可以执行的最大任务数。

\n
\n\n

在什么情况下工人会被新流程取代?此设置是否会使工作人员即使具有多个进程,一次也只能处理一项任务?

\n

kig*_*was 11

这意味着当celery执行的任务超过一个worker的限制(如果使用默认进程池,“worker”是一个进程),它会自动重新启动worker。

假设您使用 celery 进行数据库操作并且忘记关闭数据库连接,自动重启机制将帮助您关闭所有挂起的连接。

  • @lollerskates“假设您使用 celery 进行数据库操作并且忘记关闭数据库连接,自动重启机制将帮助您关闭所有挂起的连接。” (3认同)