我正在尝试使用云 AMQP 设置 celery 代理。
由于云 AMQP 服务只提供 Java SDK,所以我用 Python 重写了加密代码,连接工作正常。
但是,producer发送任务有一个问题:我的项目启动一段时间后,与云AMQP服务的连接将失效,因为Celery amqp pruducer/connection无法刷新连接参数。错误是 .530 Time Expired
这意味着密码无效
这是我的芹菜配置:
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 连接参数没有更新。
环境:
Python 2.7
kombu 4.0.2
celery 4.1.0
rabbitmq 0.2.0
Celery 是否提供了在运行时更新 amqp 连接参数的方法?
谁能给我建议?提前致谢..
一些链接:
https://www.cloudamqp.com/docs/celery.html
补充:
调试结果
amqp 连接密码(从未更改)
芹菜更新 conf