Alibabacloud Dts Task Manager — Alibabacloud DTS 任务管理器
v0.0.1创建、查看和管理Alibaba Cloud DTS数据迁移/同步任务。 当用户提及诸如"DTS task"、"DTS migration"、"DTS sync"、"data migration task"、"data sync task"、"create migration"、"create DTS"、"new DTS"、"DTS status"、"migration status"、"sync status"、"stop migration"、"suspend DTS"、"release DTS"等关键词时自动触发。
运行时依赖
安装命令
点击复制技能文档
Alibaba Cloud DTS 任务管理器概述 管理Alibaba Cloud DTS(数据传输服务)任务:创建数据迁移/同步任务,查看任务状态/延迟,停止/启动/释放任务。所有操作都以交互式方式进行。
参数解析 根据用户输入确定操作模式,并读取相应的参考文件以获取详细的工作流程:
用户意图关键字 操作 参考文件 创建迁移任务 empty / "create" / "new" / "migration" 交互式创建 references/create-task.md 创建同步任务 "sync" / "synchronization" 交互式同步任务创建 references/create-task.md 查看任务列表 "list" / "view" / "ls" 列出所有任务 references/list-tasks.md 查看任务状态 "status ID" 查看指定任务详细信息 references/task-status.md 停止任务 "stop ID" / "suspend ID" / "pause ID" 暂停指定任务 references/suspend-task.md 启动/恢复任务 "start ID" / "resume ID" 启动或恢复任务 references/start-task.md 释放任务 "release ID" / "delete ID" / "remove ID" 释放(删除)任务 references/delete-task.md 环境设置 "setup" / "configure" / "init" 检查和配置环境 references/setup.md
当没有提供参数时,提示用户选择所需的操作。
一步一步的操作工作流程 创建任务(迁移/同步) 步骤(详细信息请参阅references/create-task.md):
- 前置条件检查(CLI安装,认证配置)
- 选择区域 + 任务类型(MIGRATION或SYNC)
- 配置源:引擎类型,访问方法,连接信息,选项SSL
- 配置目标:引擎类型,访问方法,连接信息,选项SSL
- 定义迁移对象:整个数据库或特定表,带有可选的名称映射
- 选择迁移类型:schema / 全数据 / 增量(默认:全部)
- 选择实例类:micro / small / medium / large
- 查看摘要(密码显示为******)并确认
- 执行:CreateDtsInstance -> ConfigureDtsJob -> StartDtsJob
示例输入: "创建一个MySQL到Kafka的同步任务" 示例输出: DTS任务创建成功!实例ID: 任务ID: 状态:Initializing 要检查状态: aliyun dts DescribeDtsJobDetail --DtsJobId --RegionId cn-hangzhou
列出任务 步骤(详细信息请参阅references/list-tasks.md):
- 前置条件检查
- 按每个JobType(MIGRATION,SYNC,SUBSCRIBE)查询任务
- 以表格格式显示综合结果
示例输入: "列出我的DTS任务" 示例输出:
| 任务ID | 名称 | 类型 | 状态 | 源 | 目标 | 延迟 |
|---|---|---|---|---|---|---|
| migration-mysql-mysql-0401 | MIGRATION | 迁移中 | RDS MySQL | RDS MySQL | - | |
| sync-mysql-kafka-0401 | SYNC | 同步中 | RDS MySQL | Kafka | 128ms |
- 前置条件检查
- 解析ID:如果只提供一个ID,首先通过DescribeDtsJobs查找
- 调用DescribeDtsJobDetail
- 显示状态,进度,延迟(将毫秒转换为可读格式)
示例输入: "检查的状态" 示例输出: 任务:(migration-mysql-mysql-0401) 类型:MIGRATION 状态:迁移中 进度:schema迁移:完成 全数据迁移:完成(1,234,567行) 增量:运行中,延迟236ms 源:RDS MySQL (cn-hangzhou) 目标:RDS MySQL (cn-hangzhou)
停止/启动/释放任务 停止(详细信息请参阅references/suspend-task.md):
- 解析ID,显示任务信息,确认,然后调用SuspendDtsJob
启动/恢复(详细信息请参阅references/start-task.md):
- 解析ID,然后调用StartDtsJob
释放/删除(详细信息请参阅references/delete-task.md):
- 解析ID
- 预检查:调用DescribeDtsJobDetail检查当前状态
- 如果任务是活动的(同步中/迁移中/初始化数据加载),警告用户并要求明确确认
- 需要双重确认,然后调用DeleteDtsJob
环境设置 步骤(详细信息请参阅references/setup.md):
- 检查aliyun CLI安装
- 检查认证配置
- 测试与DescribeDtsJobs的连接
边缘情况 用户只提供一个ID:首先尝试作为DtsJobId;通过DescribeDtsJobs查找DtsInstanceId。如果DtsInstanceID字段在任务中为空,则只传递DtsJobId。 API参数大小写不一致:DescribeDtsJobDetail使用--DtsInstanceID(大写D),而DeleteDtsJob/ConfigureDtsJob使用--DtsInstanceId(小写d)。始终在调用之前使用aliyun dts help验证。 模糊ID格式:如果ID不明确匹配DtsJobId或DtsInstanceId模式,通过DescribeDtsJobs进行模糊搜索。 删除活动任务:永远不要在没有预检查的情况下删除运行中的任务。首先查询状态;如果是同步中/迁移中/初始化数据加载,警告用户并要求明确确认。