python - 当出现问题时停止 celery worker

Question

当出现问题时，如何从代码中停止 celery？例如redis或者数据库宕机了。

例如，如果 init 函数出现异常，我可以停止连接

@stop_if_error
@signals.worker_process_init.connect
def init_method(*_, **_):
    #some init code

但是如果 worker 工作正在进行并且出现异常，如何停止呢？

Answer 1

您可以将 Celery 配置为仅在代理(Redis，如果我理解得很好)关闭时重试 N 次。关于你提到的数据库 - 我想你指的是结果后端？如果您这样做，那么这取决于您的用例。如果结果后端不起作用并不重要。

我们不做任何检查，而是确保代理和结果后端高度可用(例如 Redis 集群)。