版本更新
0.1.4 · 2026-10-11
Agent 管理接入与无需 Node.js 的独立运行程序。
- MCP 管理接入：使用 Streamable HTTP 与现有受限 API Key 连接 /mcp，查询目录、管理草稿、预览 Pipeline、发布与启停数据流，并配置目标、Worker 和业务设置；沿用校验、脱敏、版本冲突和操作记录。
- MCP 设置：在「系统设置 → 管理 API」开启，默认关闭。开关重启后保持，只读 Key 仅提供读取工具；重新进入和刷新时保留未提交输入，提供连接配置与内置指南。
- 独立运行：安装与运行静态 Go 二进制不需要 Node.js、npm 或 Go 编译器，管理 UI、帮助、图标和 Pipeline 图形编辑器均内嵌。
- 安装指南：五语言内置帮助及中英文官网统一提供安装包、启动、监听、升级与授权说明。
验证与升级
两个 Linux 架构在断网且无 Node.js 或开发工具的 Alpine 环境通过安装、登录、内嵌资源校验、原生 Pipeline、真实 HTTP 投递及重启恢复。升级保留配置、队列和凭证；先备份并停止服务，再安装。
MCP 接入说明 下载 0.1.40.1.3 · 2026-10-11
降低目标发送和同步确认成本，保持持久化与至少一次投递契约。
- Protobuf 透传：按 SDK 报文格式校验字段、长度及嵌套消息，直接发送原字节，减少 Point 对象构建；保留未知字段、数值及时间精度。
- 批量发送：Redis 使用 Pipeline；PostgreSQL 在原事务内批量 INSERT；AMQP 使用最多 64 条的发布确认窗口；Pub/Sub 使用 SDK 批量发布。检查全部结果，保留回滚、NACK 和未路由消息失败语义。
- 连接复用：按数据流、目标和不可变版本隔离客户端，跨发送轮转及短暂空队列复用连接。最多缓存 32 个客户端，错误、版本切换和退出时关闭。
- 持久确认：同时到达的最多 64 个发送确认共用同步日志事务，计数与有序采集游标一起提交，落盘成功后才返回成功。检查点在写入锁外编码和同步；稀疏日志分步回收，并保留快照之后的新事务。
- 部署指南：同步存储、发送和运维说明，补全内置帮助五种语言的监听地址、公网访问、HTTPS 代理与容器端口映射示例。
实测结果
OrbStack Linux arm64、Go 1.26.7、2 CPU；前后各五轮微基准与六轮交替端到端测试，以下为中位数。
| 指标 | 优化前 → 优化后 | 变化 |
|---|---|---|
| 四目标吞吐 | 34,908 → 37,331 输入点/s | +6.9% |
| 相同工作量服务 CPU 时间 | 1.685 → 1.564 s | −7.2% |
| Protobuf/gzip，500 点耗时 | 274.46 → 140.48 µs | −48.8% |
| Protobuf/gzip 分配量 | 290,832 → 11,892 B/op | −95.9% |
| 32 路并发确认，同步提交次数/确认 | 1.000 → 0.093 | −90.7% |
端到端路径为 DataKit → Pipeline → 组合分流 → 两个 Dataway、HTTP Protobuf 和 HTTP NDJSON。每目标每轮核对 64,020 个唯一 ID、摘要、Tag、大整数和纳秒时间，最终重复、积压与失败均为零。
局部确认收益不能直接推广到整条数据流吞吐。尾延迟和内存峰值未显示明确改善；本地样本不作为生产容量或长稳认证。
验证与升级
源码包测试、vet 和相关包 race 通过，真实 Redis、PostgreSQL、RabbitMQ 批量与失败联调及本地 Pub/Sub SDK 回归通过。无需配置或队列格式迁移，保持同步落盘、AES-GCM 校验、不可变版本快照和目标独立重试。
升级前备份数据和凭证、停止服务，再安装新包。完整性能和验证记录随安装包文档提供。
当前发行包