运行 celery 以 worker 模式启动时的代码

running code when celery starts in worker mode

当 celery worker 启动时,我正在寻找 运行 一些代码。不是当我们说要从客户端类型应用程序导入任务时。

celery_app = Celery(__name__)
# I want to only create the egine if this file is used by a worker
engine = create_engine(str(POSTGRES_URL))

您正在寻找工作信号(https://docs.celeryproject.org/en/latest/userguide/signals.html?highlight=worker_ready#worker-signals)。那里都有很好的解释。我猜 worker_ready 是您首先应该看的那个。