时间戳

首页 > 解决方案 > Celery 路由错误：收到并删除了未知消息。目的地错误？

python - Celery 路由错误：收到并删除了未知消息。目的地错误？

问题描述

我在rabbitmq 中订阅了任务。

broker_url = app.config['BROKER_URL']

imports = (
    'tasks',
)

accept_content = ['json', 'msgpack', 'yaml']
task_serializer = 'json'
result_serializer = 'json'
worker_prefetch_multiplier = 1
worker_max_tasks_per_child = 1000
task_acks_late = True


task_default_queue = 'default'
task_default_exchange = 'default'
task_default_routing_key = 'default'

task_queues = [
    Queue('default', excenge=Exchange('default'), routing_key='default', max_priority=255),
]

task_routes = {
    'tasks.my_func': {'queue': 'default'},
}

发件人不包括标题消息 - 任务。

 Received and deleted unknown message.  Wrong destination?!?

The full contents of the message body was: body: '{"response": [], "success": 1}' (30b)
{content_type:None content_encoding:None
  delivery_info:{'consumer_tag': 'None5', 'delivery_tag': 1, 'redelivered': False, 'exchange': '', 'routing_key': 'databusq_queue_dim4_celery'} headers={}}

如何在我的默认功能中路由此消息？

标签： pythonrabbitmqcelery

解决方案

推荐阅读