当芹菜以工作者模式启动时运行代码

Question

我希望在启动芹菜工作程序时运行一些代码。当我们假设一个任务被导入以从客户端类型的应用程序中使用时，就不是这样了。

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))

Answer 1

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