channel = connection.channel()
q, j, c = channel.queue_declare('celery', passive=True)
print('celery %d jobs in queue' % j)
Как спланировать структуру очереди/работника для поддержки больших задач в нескольких средах?