Как работают tailable cursors в MongoDB и какие у них основные use cases с capped collections?

Что такое Tailable Cursor

Tailable cursor — это специальный курсор, предназначенный для использования с capped collections. В отличие от обычных курсоров, которые закрываются после возврата всех результатов, tailable cursor остаётся открытым и продолжает доставлять новые документы по мере их вставки — работает как команда Unix tail -f.

Как это работает

• Курсор исчерпывает начальные результаты, но не закрывается
• Он ждёт новые документы, вставляемые в capped collection
• MongoDB поддерживает соединение курсора, позволяя клиенту получать непрерывный поток данных
• Если новые документы не поступают, курсор блокируется до их появления

Ключевые требования

• Tailable cursors работают только с capped collections — коллекциями фиксированного размера, которые хранят документы в порядке вставки
• Коллекция должна быть capped, и документы должны вставляться последовательно
• Их невозможно использовать с обычными коллекциями или с запросами, содержащими sort

Основные сценарии использования

• Мониторинг логов в реальном времени — непрерывное чтение логов приложения или системы по мере появления новых записей
• Очереди сообщений — обработка сообщений или событий в том порядке, в котором они поступают
• Ленты активности — потоковая передача пользовательской активности или данных audit trail потребителям
• Системы оповещения об изменениях — уведомление сервисов о новых записях без накладных расходов на постоянный опрос

Пример

Опция awaitData указывает курсору ненадолго подождать новых данных перед возвратом пустого результата, снижая количество лишних сетевых round-trip'ов.

Резюме

Tailable cursors обеспечивают эффективный push-based паттерн чтения для capped collections, что делает их идеальными для любого сценария, требующего непрерывного упорядоченного потребления вновь вставляемых данных.