如何在 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/celery 调用以查找该工作人员“订阅”了哪个队列？

（我不想直接找到 $QUEUE_NAME 的值）

Answer 1

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