Oto, w jaki sposób możesz uzyskać liczbę wiadomości w kolejce za pomocą selera, który jest niezależny od brokera.
Używając connection_or_acquire , możesz zminimalizować liczbę otwartych połączeń z brokerem, korzystając z wewnętrznego puli połączeń selera.
celery = Celery(app)
with celery.connection_or_acquire() as conn:
conn.default_channel.queue_declare(
queue='my-queue', passive=True).message_count
Możesz również rozszerzyć program Celery, aby zapewnić tę funkcję:
from celery import Celery as _Celery
class Celery(_Celery)
def get_message_count(self, queue):
'''
Raises: amqp.exceptions.NotFound: if queue does not exist
'''
with self.connection_or_acquire() as conn:
return conn.default_channel.queue_declare(
queue=queue, passive=True).message_count
celery = Celery(app)
num_messages = celery.get_message_count('my-queue')
