我有一个Celery worker配置为连接到redis，如下所示：

celery_app_site24x7 = Celery('monitoringExterne.celerys.site24x7',
                             broker=settings.REDIS['broker'], backend=settings.REDIS['backend'])

celery_app_site24x7.conf.broker_transport_options = {
    'visibility_timeout': 36000
}

celery_app_site24x7.conf.socket_timeout = 300
celery_app_site24x7.conf.broker_connection_max_retries = None
celery_app_site24x7.config_from_object('django.conf:settings')
celery_app_site24x7.autodiscover_tasks(lambda: settings.INSTALLED_APPS)

问题是，如果Redis关闭，重新建立连接，则添加到队列中的新任务不会执行：

[2020-01-13 10:10:14,517: ERROR/MainProcess] consumer: Cannot connect to redis://xxx.xxx.xxx.xx:6380/10: Error while reading from socket: ('Connection closed by server.',).
Trying again in 2.00 seconds...

[2020-01-13 10:10:16,590: INFO/MainProcess] Connected to redis://xxx.xxx.xxx.xx:6380/10
[2020-01-13 10:10:16,699: INFO/MainProcess] mingle: searching for neighbors
[2020-01-13 10:10:17,766: INFO/MainProcess] mingle: all alone

我已经通过django shell手动调用了一个celery 任务，如下所示：
celery任务站点24 x7测试延迟（）
它向我返回异步任务ID，但工作进程不处理此任务。

<AsyncResult:ff634b85-edb5-44d4-bdb1-17a220761fcc>

如果我继续延迟启动任务，队列将不断增加：

127.0.0.1:6379[10]> llen site24x7
(integer) 4
127.0.0.1:6379[10]> llen site24x7
(integer) 5

下面是celery 的输出状态和检查
$ celery -外部监控--应用程序=外部监控. celerys.site24x7
状态错误：没有节点在时间限制内回复。
$ celery -外部监控--应用程序=监控外部. celerys.site24x7检查活动
错误：在时间限制内没有节点回复。