/alibabacloud-dts-task-manager

name: alibabacloud-dts-task-manager
description: "Create, view, and manage Alibaba Cloud DTS data migration/synchronization tasks interactively. Automatically triggered when the user mentions keywords such as \"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 Task Manager

Overview

Manage Alibaba Cloud DTS (Data Transmission Service) tasks: create data migration/synchronization tasks, view task status/latency, stop/start/release tasks. All operations are guided interactively.

Parameter Parsing

Determine the operation mode based on user input, and read the corresponding references file for detailed workflow:

| User Intent | Keywords | Action | Reference File | |------------|----------|--------|---------------| | Create migration task | empty / "create" / "new" / "migration" | Interactive creation | `references/create-task.md` | | Create sync task | "sync" / "synchronization" | Interactive sync task creation | `references/create-task.md` | | View task list | "list" / "view" / "ls" | List all tasks | `references/list-tasks.md` | | View task status | "status ID" | View specified task details | `references/task-status.md` | | Stop task | "stop ID" / "suspend ID" / "pause ID" | Suspend specified task | `references/suspend-task.md` | | Start/Resume task | "start ID" / "resume ID" | Start or resume task | `references/start-task.md` | | Release task | "release ID" / "delete ID" / "remove ID" | Release (delete) task | `references/delete-task.md` | | Environment setup | "setup" / "configure" / "init" | Check and configure environment | `references/setup.md` |

When no parameters are provided, ask the user to choose the desired operation.

Step-by-Step Operation Workflows

Create Task (Migration / Sync)

**Steps** (full details in `references/create-task.md`): 1. Prerequisites check (CLI installed, auth configured) 2. Select Region + Task type (MIGRATION or SYNC) 3. Configure source: engine type, access method, connection info, optional SSL 4. Configure destination: engine type, access method, connection info, optional SSL 5. Define migration objects: full database or specific tables, with optional name mapping 6. Select migration types: schema / full data / incremental (default: all) 7. Select instance class: micro / small / medium / large 8. Review summary (passwords shown as `******`) and confirm 9. Execute: CreateDtsInstance -> ConfigureDtsJob -> StartDtsJob 10. On failure at any step after instance creation, auto-release the instance

**Example input**: "Create a MySQL to Kafka sync task" **Example output**:

DTS task created successfully!
  Instance ID: <dts-instance-id>
  Job ID:      <job-id>
  Status:      Initializing

To check status:  aliyun dts DescribeDtsJobDetail --DtsJobId <job-id> --RegionId cn-hangzhou

List Tasks

**Steps** (full details in `references/list-tasks.md`): 1. Prerequisites check 2. Query tasks by each JobType (MIGRATION, SYNC, SUBSCRIBE) separately 3. Display consolidated results in table format

**Example input**: "List my DTS tasks" **Example output**:

| Task ID        | Name                         | Type      | Status         | Source       | Destination  | Delay  |
|----------------|------------------------------|-----------|----------------|--------------|--------------|--------|
| <job-id-1>     | migration-mysql-mysql-0401   | MIGRATION | Migrating      | RDS MySQL    | RDS MySQL    | -      |
| <job-id-2>     | sync-mysql-kafka-0401        | SYNC      | Synchronizing  | RDS MySQL    | Kafka        | 128ms  |

View Task Status

**Steps** (full details in `references/task-status.md`): 1. Prerequisites check 2. Resolve ID: if only one ID given, look up via DescribeDtsJobs first 3. Call DescribeDtsJobDetail 4. Display status, progress, delay (convert ms to readable format)

**Example input**: "Check status of <job-id>" **Example output**:

Task: <job-id> (migration-mysql-mysql-0401)
Type:   MIGRATION
Status: Migrating
Progress:
  Schema migration:    Finished
  Full data migration: Finished (1,234,567 rows)
  Incremental:         Running, delay 236ms
Source:      RDS MySQL <source-instance-id> (cn-hangzhou)
Destination: RDS MySQL <dest-instance-id> (cn-hangzhou)

Stop / Start / Release Task

**Stop** (full details in `references/suspend-task.md`): 1. Resolve ID, display task info, confirm, then call SuspendDtsJob

**Start/Resume** (full details in `references/start-task.md`): 1. Resolve ID, then call StartDtsJob

**Release/Delete** (full details in `references/delete-task.md`): 1. Resolve ID 2. **Pre-check**: call DescribeDtsJobDetail to check current status 3. If task is active (Synchronizing/Migrating/InitializingDataLoad), warn user and require explicit confirmation 4. Double confirmation required before calling DeleteDtsJob

Environment Setup

**Steps** (full details in `references/setup.md`): 1. Check aliyun CLI installation 2. Check authentication configuration 3. Test connectivity with a DescribeDtsJobs call

Edge Cases

• **User provides only one ID**: Try it as DtsJobId first; look up DtsInstanceId via DescribeDtsJobs. If DtsInstanceID field is empty on the task, pass only DtsJobId.
• **API parameter case inconsistency**: `DescribeDtsJobDetail` uses `--DtsInstanceID` (uppercase D), while `DeleteDtsJob`/`ConfigureDtsJob` use `--DtsInstanceId` (lowercase d). Always verify with `aliyun dts <API> help` before calling.
• **Ambiguous ID format**: If the ID doesn't clearly match DtsJobId or DtsInstanceId pattern, fuzzy search via DescribeDtsJobs.
• **Delete active task**: Never delete a running task without pre-check. Query status first; if Synchronizing/Migrating, prompt user to suspend first or explicitly confirm forced deletion.
• **Creation failure mid-flow**: If CreateDtsI