Как получить список имен подписанных очередей в 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>, каждый узел отправит вам отчет о том, на какую очередь он подписан.