示例:把 MySQL 表同步到 Databend
调用前请先阅读概览,了解鉴权、请求约定和错误处理。
Agent 可以用一个 API token 完成以下步骤,每一步都注明了对应接口。
- 检查连接是否可用。调用测试数据源连接,传
serviceId: 2和mysqlCredentials。 - 保存数据源。用相同的请求体调用创建数据源,记下返回的
id。 - 查找源表。调用列出 MySQL 表。涉及多个数据库时,改为调用预览 MySQL 表规则。
- 选择计算集群。调用列出计算集群。
- 创建任务。调用创建任务,传
mysqlTask.syncMode: 3,记下返回的id。 - 启动任务。调用操作任务,传
operate: 1。 - 查看进度。调用获取任务,读取
taskStatus和lastRunData.mysqlLastRun。查看趋势时,调用获取同步指标并传queryType: MySQLSync。 - 如果运行失败,调用列出任务运行记录和获取任务运行详情,读取
responseData.error。 - 检查数据。通过 Query API 执行
SELECT count(*) FROM raw_shop.orders。
第 2、5、6 步会修改资源,并可能消耗 credits。调用前请先让用户确认。

