芹菜工人onStart事件？

Question

我一直在查看Celery 4.3.0文档，但我找不到任何类型的工作者生命周期事件。大多数worker管理都是基于命令行的，但我需要一种在代码中挂接worker start事件的方法，这样我就可以执行一些自定义的队列使用者分配。

芹菜有这样的活动吗？

Answer 1

芹菜在不同的事件中发出信号。有两个与worker init相关的信号

before the worker is started发送的worker_init信号。

在所有池child processes when they start中调度的worker_process_init信号。

以下是监听信号的代码示例。

from celery.signals import worker_init, worker_process_init


@worker_init.connect()
def worker_init_handler(*args, **kwargs):
    print(args, kwargs)
    print('worker_init')


@worker_process_init.connect()
def worker_process_init_handler(*args, **kwargs):
    print(args, kwargs)
    print('worker_process_init')