芹菜可以在运行时刷新amqp连接参数吗？

Question

我正在尝试用云AMQP建立芹菜经纪人。

由于云AMQP服务只提供Java SDK，所以我用Python重写了加密代码，连接工作正常。

但是，生成器发送任务有问题：在我的项目启动一段时间后，与云AMQP服务的连接将无效，因为Celery amqp pruducer / connection无法刷新连接参数。错误是530 Time Expired.which表示密码无效

这是我的芹菜配置：

task_ignore_result=True,
task_default_queue='default',
task_default_exchange='default',
result_exchange='default',
task_default_exchange_type='direct',
broker_login_method='PLAIN',
task_create_missing_queues=True,
task_serializer='json',
result_serializer='json',
result_expire=1,
accept_content=['json'],
broker_connection_retry=False,
task_queues=(
    Queue(name='tesu', exchange=Exchange(name='test', type='direct'), routing_key='test'),
),
task_routes=(
    {'tasks.add': {
        'queue': 'test_lukou',
        'routing_key': 'test_lukou'
    }},
),
broker_url='amqp://{username}:{password}@{host}:{port}/{virtual_host}'.format(username=provider.get_user_name(),
                                                                              password=provider.get_password(),
                                                                              host=PUBLIC_HOST,
                                                                              port=PORT,
                                                                              virtual_host=VHOST_NAME),
broker_pool_limit=0,
broker_heartbeat=10,
broker_connection_timeout=30, 
result_backend=None, 
event_queue_expires=60,  
worker_prefetch_multiplier=1,

我在发送任务时更新了broker_url，但是没有更新amqp连接参数。

环境： qazxsw poi

Celery是否提供了在运行时更新amqp连接参数的方法？ 有人能给我建议吗？提前致谢..

一些链接：

Python 2.7
 kombu 4.0.2
 celery 4.1.0
 rabbitmq 0.2.0

Celery creating a new connection for each task

加成： 调查结果 qazxsw poi qazxsw poi

Answer 1

Sloved

通过为每个任务创建新的生成器池来设置Celery amqp，如下所示：

https://www.cloudamqp.com/docs/celery.html

希望这可以帮助那些陷入类似问题的人。