← Cloudflare Pipelines / pipelines

Streams

Streams jsou trvalé fronty s vyrovnávací pamětí, které přijímají a ukládají události ke zpracování v Cloudflare Pipelines. Zajišťují spolehlivý příjem dat prostřednictvím HTTP endpointů a Worker bindings, takže nedochází ke ztrátě dat ani při zpoždění nebo selhání navazujícího zpracování.

Jeden stream může číst více pipelines, což umožňuje směrovat stejná data do různých cílů nebo na ně aplikovat různé transformace. Uživatelské události tak můžete odesílat současně do pipeline pro analýzu v reálném čase i do pipeline pro datový sklad.

Streams v současnosti přijímají události ve formátu JSON a podporují jak strukturované události s definovaným schématem, tak nestrukturovaný JSON. Pokud je zadáno schéma, streamy podle něj validují a vynucují ho u příchozích událostí.