【问题标题】:Configure Celery Beat to attempt to reconnect to Rabbit if connection fais如果连接失败,配置 Celery Beat 以尝试重新连接到 Rabbit
【发布时间】:2018-01-12 12:01:04
【问题描述】:

如果 celerybeat 失去与 RabbitMQ 的连接,它似乎不会尝试重新连接,它只是静静地坐着,不做任何事情(这几乎可以肯定是由于我配置它的方式)。

有没有办法配置 celerybeat,以便在连接断开时尝试重新连接到 RabbitMQ?

【问题讨论】:

  • 你找到方法了吗?即使我正在寻找一种方法来做到这一点。除非重新启动 celerybeat,否则即使与 RabbitMQ 服务器的连接出现故障也会导致完全中断。

标签: python celerybeat


【解决方案1】:

他们Github页面上关于这个问题的讨论表明使用redis作为broker可以解决重连问题。

https://github.com/celery/celery/issues/3409

RabbitMQ 肯定不支持重新连接,这令人失望。但是我不确定redis作为代理是否支持重试。

在我的用例中,不使用重试,所以我自己打算将我的 celery beat 代理切换到 redis。

【讨论】:

    猜你喜欢
    • 2011-12-05
    • 1970-01-01
    • 2023-01-11
    • 2020-12-15
    • 1970-01-01
    • 1970-01-01
    • 2019-02-21
    • 2013-03-26
    • 1970-01-01
    相关资源
    最近更新 更多