让第一条数据,走通完整链路。
构建、启动、配置并验证一次真实投递。
准备环境
取得 FlowPort 源码后,在项目根目录执行下列命令。构建需要 Go 1.26 与 Node.js 24。首次启动设置至少 12 个字符的管理员密码,后续在系统设置中修改。
go version
node --version构建与启动
构建前端后再构建 Go 服务,页面资源会内嵌进二进制。默认社区版同时运行管理服务和本机单 Worker。
npm ci --prefix web
npm run build --prefix web
go build -o bin/collectway ./cmd/collectway
export COLLECTWAY_ADMIN_PASSWORD='replace-with-your-own-long-password'
./bin/collectway添加目标并发布数据流
打开 http://127.0.0.1:8080 并登录。先在「发送目标」添加可达的 HTTP、Dataway 或其他目标,再创建数据流,选择 HTTP Server 和 JSON 格式,设置独立 Source Token。
在 Pipeline 加上标签规则,选择默认发送目标并发布。保存草稿不会启动新版本;等待 Worker 安装完成再发送数据。
set_tag("env", environment)
set_tag("processed", "yes")验证下游收据
将下列示例中的 YOUR_FLOW_ID 和 YOUR_SOURCE_TOKEN 替换为实际配置。8081 是默认接入端口,8080 用于管理页面。
curl -i -X POST 'http://127.0.0.1:8081/ingest/YOUR_FLOW_ID' \
-H 'Authorization: Bearer YOUR_SOURCE_TOKEN' \
-H 'Content-Type: application/json' \
--data '{"message":"hello FlowPort","service":"checkout","environment":"production"}'确认交付
HTTP 204 表示本地持久入队,实际投递请确认下游收据。运行页面应出现接收和发送计数,同时检查待发送队列与失败记录。
正式部署应使用 TLS、独立接入 Token、持久数据目录、足够磁盘空间和可靠系统时钟。不要把管理员密码用于上游采集。