芹菜-测试-将工作放到哪个队列

Question

简单的问题。当定义了多个队列时，如何确定作业转到哪个队列?虽然我知道我说的是进入优先队列，但我如何检查是否真的是这样呢?

Answer 1

有几种方法可以最终找到答案。当它在处理的时候，这是最好的方法就是用芹菜中的工具。对于给定的task_id执行此操作。

from celery.app import app_or_default
app = app_or_default()
inspect = app.control.inspect()
pprint.pprint(inspect.query_task([task_id]))
{u'[e-mail]':
    {u'ebe2d165-92f6-4c81-bbf5-b2644e0dbcaf':
        [u'reserved',
            {u'acknowledged': False,
             u'args': u'[]',
             u'delivery_info': {u'exchange': u'celery',
                                u'priority': None,
                                u'redelivered': False,
                                u'routing_key': u'celery'},
             u'hostname': u'[e-mail]',    
             u'id': u'ebe2d165-92f6-4c81-bbf5-b2644e0dbcaf',
             u'kwargs': u"{'status_ids': [5072L, 7643L]}",
             u'name': u'apps.home.tasks.update_home_stats',
             u'time_start': None,
             u'worker_pid': None}]}}    

delivery_info告诉您交换队列名称