功能

在 Web 管理端把「跨库同步 / 批处理 / 调存储过程」配成可复用任务,通过 MQ / 定时 / 手动触发执行,并提供完整的日志、脏数据、死信与审计能力。

能力说明

对应产品介绍中的数据源、MQ、编排、运维与治理。

数据源——连上库再说

按库类型选 JDBC 模板,填写账号密码与连接池;保存前可测试连接。密码加密存储,编辑时留空表示不改。支持导出 / 导入。

消息队列——按需接入 RocketMQ

消息队列为可选项:仅当任务启用「MQ 触发」时需要配置。仅使用定时 / 手动触发时,可不配置、不部署 RocketMQ。配置 NameServer;云 MQ 一般开启 ACL。

任务编排——节点与触发

触发支持 MQ / 定时 / 手动,可多选、至少一种。节点:依赖条件(可选)→ 数据抽取 → 数据加载(可多个)→ 执行 SQL 或 SQL 脚本。执行超时任务级默认 30 分钟。草稿保存只要求名称;完整校验在测试 / 发布时进行。

执行与运维——看得见、查得清

从任务行可打开执行日志抽屉(运行中自动刷新)。运维菜单提供全局查询、脏数据、死信、健康与审计:加载失败可导出排查,死信可按策略重投。

安全与治理——可管、可控

三角色(超管 / 管理员 / 普通用户)、IP 白名单、系统标题配置。右上角支持个人信息与修改密码;新建 / 重置密码后须先改密再进业务。

下载 RockPipe

ZIP 绿色包,解压即可启动。需要试用、部署协助或技术交流,也可通过顶栏「联系」沟通。