如何在Celery/Django中获取订阅的队列名称列表

Question

我的工作程序运行时使用：

celery worker -A workerTasks -n Worker%h --concurrency=1 --loglevel=info -Q $QUEUE_NAME -f $WORKER_LOG_FILE --pidfile=/logs/worker_pid%h.pid

我想知道我是否可以在进程中调用python/celey，以查找该工作线程"订阅"了哪个队列？

(我不想直接查找$QUEUE_NAME的值(

Answer 1

celery -A workerTasks inspect active_queues -d <worker name>，其中worker name是特定节点的名称。如果省略-w <worker name>，则每个节点将向您发送关于其订阅的队列的报告。