Подсчет сообщений во время полета в Redis

Question

Подсчет сообщений во время полета в Redis

Я использую Redis как простой брокер pubsub, управляемый библиотекой redis-py, используя только основной канал по умолчанию. Есть ли метод в самом Redis или в оборачивающей библиотеке Python для подсчета количества сообщений в этой очереди? У меня нет более глубоких концептуальных знаний о Redis (в частности, о том, как он реализует функции брокера), поэтому я не уверен, имеет ли такой вопрос смысл.

Точный подсчет, предотвращение блокировки и т. Д. Не требуется; Мне нужно только периодически (порядка минут) проверять, пуста ли эта очередь

0

redis py-redis

Источник

user5339398 03 сен '19 в 22:33

1 ответ

Другие вопросы по тегам redis py-redis

user593425 05 сен '19 в 11:29 2019-09-05 11:29 · Answer 1 · 2019-09-05 11:29

Redis Pub/Sub не содержит никаких внутренних очередей сообщений, смотрите - https://redis.io/topics/pubsub.

Если вам нужен дополнительный механизм публикации на основе очередей, вы можете проверить Redis Streams. Redis Streams предоставляет два метода, которые могут помочь вам XLEN и XINFO.