一句话面向生产数据库的高频写入缓冲、批处理与可靠投递服务。
定价免费额度 + 按月订阅 + 超额计量 Free:$0/月,10K steps、50MB 传输、10K 秒 pull-wait,硬上限无超额付费;Starter:$10/月,1M steps、4GB、1M 秒,超额 $0.50/百万 steps、$0.50/GB、$0.50/百万秒;Growth:$50/月,100M steps、400GB、100M 秒,超额 $0.35;Scale:$200/月
适合谁需要向 Postgres/MySQL 或客户系统写入大量小记录、突发事件、审计日志、指标、AI/Agent traces 的开发团队。
核心功能单记录或批量 JSON ingest API按流配置批处理策略:时间、大小或自定义策略背压与速率控制保护数据库push 或 pull 批量投递重试、死信队列与可观测性幂等与去重可选基础仪表盘与可导出指标JavaScript SDK 与 REST API管道、目标、API Key 的管理 API
功能与用途BatchPipe 用于接收高频逐条写入请求,将数据缓冲并按时间、大小或自定义策略批量投递到数据库或 API。它强调保护生产数据库,处理流量尖峰、宕机重试、背压、死信队列和可观测性。
支持语言/框架文中明确提供 JavaScript SDK,支持浏览器 ES module,无需 npm;Node 可使用可选 batchpipe-sdk workspace package。未提及其他语言或具体框架。
自托管选项文中提到 Base URL、PUBLIC_DATA_BASE_URL、single-host deployments 等部署相关环境配置,但未明确说明是否向用户提供自托管版本。
定价Free、Starter、Growth、Scale 四档。按 monthly steps、data transfer、pull-wait time 计量;付费档按各自 meter 独立收取超额费用。
API/SDK提供 REST/HTTP API:/v1/ingest/:pipe_id、/v1/pull/:destination_id、/v1/health,以及 pipes、destinations、limits、allowed-origins、api-keys 等管理 API。认证使用 Authorization Bearer API key。提供 JavaScript SDK 与 SDK API reference。
集成与生态目标包括 Postgres/MySQL、数据库和 API、客户系统。底层接受到 buffer 后异步投递;文档中提到 NATS JetStream 作为 accepted buffer。提供 PostgreSQL/MySQL DDL 示例用于 website stats/events。
文档质量文档覆盖 API 路由、认证、CORS、状态码、错误、管理自动化、术语表、SDK 指南和示例 curl,细节较完整。但 HTTP API 页面说明 OpenAPI 文档尚未作为 source of truth 发布,存在一定成熟度信号不一致。
中国访问未知
适用场景活动流与用户事件、审计与合规日志、指标/计数器/统计更新、后台任务遥测、AI/Agent traces 与 tool-calls、向客户数据库或 API 安全投递批量数据。
同类Kafka、NATS JetStream、RabbitMQ、AWS SQS/Kinesis、Cloudflare Queues、Temporal、自建批处理 worker