python - 向现有的 celery 工作进程动态添加功能？

Question

我开始使用 celery，我想知道是否可以将模块添加到已经启动的 celeryd 进程中。换句话说，而不是像通过 celeryconfig.py 添加模块

CELERY_IMPORTS = ("tasks", "additional_module" )

在启动工作人员之前，我想在工作进程启动后以某种方式使附加模块可用。

提前致谢。

Answer 1

您可以通过使用扩展的导入列表启动一个新的celeryd 并最终优雅地关闭您的旧工人（在它完成当前工作之后）来实现您的目标。

由于将工作推送给您并且仅在 celery 完成工作后才将它们标记为完成的异步性质，因此您实际上不会错过以这种方式进行的任何工作。您应该能够在同一台机器上运行 celery 工作程序 - 它们只会显示为到 RabbitMQ（或您使用的任何队列后端）的新连接。