← Cloudflare Pipelines / pipelines

Streams

Потоки представляют собой надёжные буферизованные очереди, которые принимают и сохраняют события для последующей обработки в Cloudflare Pipelines. Они обеспечивают надёжную доставку данных через HTTP-эндпоинты и Worker bindings, гарантируя отсутствие потери данных даже при задержках или сбоях в последующей обработке.

Один поток могут читать сразу несколько конвейеров, что позволяет направлять одни и те же данные в разные пункты назначения или применять к ним разные преобразования. Например, вы можете отправлять пользовательские события одновременно в конвейер аналитики в реальном времени и в конвейер для хранилища данных.

В настоящее время потоки принимают события в формате JSON и поддерживают как структурированные события с заданной схемой, так и произвольный JSON без схемы. Если схема указана, поток проверяет по ней все входящие события.