toggle_incr_sync
所属分类:轻量操作 · Tool 名称:
toggle_incr_sync
功能说明
启动或停止指定管道的增量(实时)同步通道。增量同步是长驻运行(基于 Flink,部署在 K8s 上)的进程,启动 / 停止均为异步操作,操作受理后需通过 get_incr_sync_status 确认最终状态。
操作类 Tool
本 Tool 会真实改变增量同步通道的运行状态。停止增量同步会中断实时数据流,重启后按保存点 / 起始位点恢复。建议在 Agent 客户端开启 Tool 调用确认机制,由用户二次确认后执行。
输入参数
| 参数 | 类型 | 必填 | 说明 |
|---|---|---|---|
pipeline | string | 是 | 管道名称(可通过 list_pipeline 获取) |
action | string | 是 | 操作类型,枚举值:start(启动)/ stop(停止) |
输出结果
返回 TIS 标准信封结构(详见 总览 - 通用返回约定):
| 字段 | 类型 | 说明 |
|---|---|---|
success | boolean | 操作请求是否受理成功 |
errormsg | string[] | 错误信息列表。出现非空 errormsg 时调用端应立即终止后续执行并告知用户 |
msg | string[] | 操作结果描述,如「已停止管道 mysql2doris_orders 的增量同步」「增量同步启动请求已提交」 |
返回示例
{
"success": true,
"errormsg": [],
"msg": ["增量同步启动请求已提交,管道: mysql2doris_orders。请通过 get_incr_sync_status 查询启动结果。"]
}
错误返回
| 情况 | 表现 |
|---|---|
pipeline 为空 | MCP 层 isError: true,内容为参数错误描述文本 |
action 为空或不是 start / stop | MCP 层 isError: true,内容为参数错误描述文本 |
| 服务端内部异常 | MCP 层 isError: true,内容为通用错误提示文本 |
注意点
- 异步生效:启动 / 停止请求受理后,增量实例的状态变化需要一定时间(启动通常需数十秒完成 Flink 作业拉起)。请间隔数秒后调用
get_incr_sync_status确认state变为RUNNING/STOPPED。 - 前置条件:目标管道必须已配置增量同步通道(可先通过
get_incr_sync_status确认configured与state),未配置增量通道的管道请先在 TIS 控制台完成增量通道配置。 - 管道是否具备增量同步能力(
supportIncrSynchronize)可通过list_pipeline查询。
典型用法
在 Hermes 中的提问示例:
把 mysql2doris_orders 的实时同步停一下
使用 toggle_incr_sync 工具:启动 mysql2doris_orders 的增量同步,启动后帮我确认状态