Streams 是接收并存储事件以供 Basin Pipelines 处理的持久化缓冲队列。它们通过 HTTP 端点和 Worker 绑定提供可靠的数据摄取,即使下游处理延迟或失败,也能确保数据不会丢失。
单个 stream 可被多个 pipeline 读取,使您能够将相同数据路由到不同目的地或应用不同转换。例如,您可以将用户事件同时发送到实时分析 pipeline 和数据仓库 pipeline。
Stream 目前接受 JSON 格式的事件,支持具有定义 schema 的结构化事件和非结构化 JSON。提供 schema 时,stream 将对传入事件进行验证和执行。
管理 stream
使用 Wrangler 或 API 创建、配置和删除 stream。
写入 stream
通过 HTTP 端点或 Worker 绑定向 stream 发送事件。
Logpush 作为数据源
使用 Cloudflare Logpush 将 Cloudflare 产品的日志发送到 Basin Pipelines stream。