跳到主要内容

示例:把 MySQL 表同步到 Databend

调用前请先阅读概览,了解鉴权、请求约定和错误处理。

Agent 可以用一个 API token 完成以下步骤,每一步都注明了对应接口。

  1. 检查连接是否可用。调用测试数据源连接,传 serviceId: 2 和 mysqlCredentials。
  2. 保存数据源。用相同的请求体调用创建数据源,记下返回的 id。
  3. 查找源表。调用列出 MySQL 表。涉及多个数据库时,改为调用预览 MySQL 表规则。
  4. 选择计算集群。调用列出计算集群。
  5. 创建任务。调用创建任务,传 mysqlTask.syncMode: 3,记下返回的 id。
  6. 启动任务。调用操作任务,传 operate: 1。
  7. 查看进度。调用获取任务,读取 taskStatus 和 lastRunData.mysqlLastRun。查看趋势时,调用获取同步指标并传 queryType: MySQLSync。
  8. 如果运行失败,调用列出任务运行记录和获取任务运行详情,读取 responseData.error。
  9. 检查数据。通过 Query API 执行 SELECT count(*) FROM raw_shop.orders。

第 2、5、6 步会修改资源,并可能消耗 credits。调用前请先让用户确认。