Advertisement

6. 消息重复发送最多三次

阅读量:

当消息传输遭遇中断时,Celery具备自动尝试重新发送的功能,用户可根据实际需求对这一重试机制进行参数配置,例如设定重试间隔时间、限定最大尝试次数,甚至选择完全关闭重试功能。

然而,这仅仅是官方文档中所描述的情况。我在Windows系统上进行了相关测试,特意将broker的地址设置为局域网中未被使用的IP地址,原本预期会如文档所述,在尝试三次后返回错误提示,但实际情况却并非如此,始终无法得到响应;随后查阅了配置文档,并尝试调整了多项相关参数设置,结果仍然如此。直到在Linux环境下运行程序后才恢复正常!这让我深刻体会到,在Windows平台上使用Celery确实存在诸多不易察觉的问题与障碍!

复制代码
 from celery import Celery

    
  
    
  
    
 app = Celery('tasks',
    
          backend='amqp://agent:agent@*.*.*.*:5672',
    
          broker='amqp://agent:agent@*.*.*.*:5672')
    
  
    
 app.conf.update(broker_connection_timeout=4.0, broker_connection_max_retries=3)
    
  

全部评论 (0)

还没有任何评论哟~