Работает ли брокер mongoDB для сельдерея путем опроса?

Question

Celery documentation for the mongoDB broker не говорит, работает ли это путем опроса. Я прочитал в this blog post, что pub/sub возможно с mongoDB, но я не знаю, так ли это делает брокер mongoDB для Celery.

Два подвопросы:

1. если брокер работает путем опроса, что частота и как я могу настроить его?
2. Если брокер работает с хвостовыми курсорами, совместим ли он с окантовкой (по имени очереди).

Большое спасибо.

Answer 1

Я взял быстрый взгляд на исходный код: Сельдерей основан на Kombu, и, судя по исходному коду транспортного MongoDB (kombu.transport.mongodb), метод drain_events просто унаследовал от kombu.transport.virtual.Transport класса, который просто опрашивает каждую секунду.

Можно переопределить интервал опроса, установив атрибут polling_interval в параметрах транспорта (см. this commit).