/alibabacloud-dts-task-query

name: alibabacloud-dts-task-query
description: >
  Query DTS (Data Transmission Service) task status and details across all Alibaba Cloud regions.
  **v12.1: Enhanced reliability** - Timeout increased to 10s, exponential backoff (0.2s, 0.4s) for better timeout handling.
  Parallel execution remains **6-8x faster** than v10 (39s → 6s with --workers 16).
  **API retry logic ensures consistent results (no count variations)**. Supports filtering by instance ID or job name. Automatically polls all 27 regions and 3 job types.
  Strictly filters for PrePaid/PostPaid tasks and outputs a full Chinese report with Region information.
  Tasks are grouped by type (Migration/Sync/Subscribe) and sorted by CreateTime within each group.
  **Use this skill when: checking DTS task status, finding migration/sync tasks, verifying task counts, or filtering tasks by instance ID or job name.**
metadata:

⚠️ CRITICAL OUTPUT COMPLETENESS REQUIREMENT

**When using this skill, you MUST output the COMPLETE script result without ANY truncation, omission, or summarization. The script outputs EVERY task row in full - your model response MUST do the same. NEVER use "..." placeholders or summarize task counts. Display ALL rows exactly as shown.**

DTS Task Status Query

Query DTS task status using Alibaba Cloud CLI. Outputs results in Chinese.

Prerequisites

**CRITICAL: AI-Mode and Plugin Setup Required**

Before using this skill, you MUST configure AI-Mode and update plugins:

# Enable AI-Mode for plugin-based API calls
aliyun configure ai-mode enable

# Set user agent for proper plugin compatibility
aliyun configure ai-mode set-user-agent --user-agent "AlibabaCloud-Agent-Skills/alibabacloud-dts-task-query"

# Update all plugins to latest version
aliyun plugin update --all

# Verify DTS plugin is installed
aliyun plugin list

# To disable AI-Mode later (if needed)
aliyun configure ai-mode disable

**Note**: This skill uses plugin mode commands (`aliyun dts describe-dts-jobs`). AI-Mode must be enabled for these commands to work correctly.

Required RAM Permissions

See detailed RAM policy requirements in [references/ram-policies.md](references/ram-policies.md).

Supported Regions

Automatically queries all 27 public cloud regions if no region is specified.

Usage

python scripts/query_dts_tasks.py [--region <id>] [--instance-id <id>] [--job-name <name>] [--workers <N>]

**⚠️ MANDATORY - Model Response Rules:**

• **ALWAYS output COMPLETE data**: Display every single task row without any omission
• **NEVER truncate**: No "..." placeholders, no "showing first N tasks", no summaries
• **ALWAYS list ALL tasks**: Every task in migration/sync/subscribe groups must be shown line-by-line
• **Script outputs 100%**: The script GUARANTEES complete output - your response MUST match 100%
• **Remember**: When the script has 23 tasks, you output ALL 23 rows. NO EXCEPTIONS.

**Performance Tuning:**

• `--workers`: Number of concurrent API calls (default: 8). Recommended values:
• **8**: Default, stable performance (~10 seconds full scan)
• **12-16**: Optimal for high-bandwidth networks (~6-8 seconds full scan)
• **>16**: May hit API rate limits or local resource constraints

**Reliability Features (v12):**

• **API retry logic**: Retries failed API calls up to 3 times with exponential backoff to ensure consistent results
• **Problem solved**: Eliminates count variations caused by transient API failures and timeouts
• **Impact**: Script now always returns the same task count (e.g., consistently 34 tasks instead of 32-34)
• **v12.1**: Increased timeout to 10s and added exponential backoff (0.2s, 0.4s) for better reliability
• **Thread-safe collection**: Uses Lock to prevent race conditions during parallel data collection
• **Strict response validation**: Only accepts responses with valid "DtsJobList" field
• **Detailed error logging**: Distinguishes between timeout errors and other exceptions for easier debugging
• **Verified**: Tested with 50+ consecutive runs - all returned identical results

Execution Rules (Mandatory)

1. **Full Polling**: Must iterate through all 27 regions and 3 job types (`MIGRATION`, `SYNC`, `SUBSCRIBE`) unless a specific region is provided. 2. **Region Injection**: The script must inject the `_QueryRegion` field into each task object during the query phase. 3. **Endpoint for Overseas Regions**: For overseas regions, the script must add the `--endpoint` parameter to query tasks successfully. 4. **PayType Filtering**: After reading the temporary file, strictly filter tasks to include ONLY those where `PayType` is `PrePaid` or `PostPaid`. 5. **Chinese Output**: All output (summary and table headers) must be in Chinese. JobType must be mapped (e.g., migration -> 迁移). 6. **Grouped Output**: Tasks are grouped by type (迁移/同步/订阅), with each group sorted by CreateTime (newest first). 7. **Parallel Execution**: The script MUST use ThreadPoolExecutor for parallel queries (v11+). Default 8 workers, configurable via `--workers`. 8. **API Retry**: The script retries failed API calls up to 3 times to ensure reliability (v12+). 9. **Thread Safety**: The script uses Lock for thread-safe data collection to prevent race conditions (v12+). 10. **Parameter Strictness**: MUST use the exact region ID and filter keywords provided in user input. DO NOT substitute regions (e.g. cn-shanghai) even if user input seems ambiguous. 11. **Filter Enforcement**: If --job-name is provided, it MUST be passed to the script without omission.

Output Format

1. 统计摘要

• **任务总量**: [Count]
• **地域分布**: [List of regions and counts]
• **状态分布**: [List of statuses and counts]
• **类型分布**: [List of job types and counts]

2. 任务明细

**⚠️ CRITICAL - Output Completeness:**

• **Script GUARANTEES complete output**: The script ALWAYS outputs ALL tasks without truncation
• **ALWAYS display ALL rows**: Every single task MUST be listed row-by-row, no exceptions
• **NEVER use placeholders**: No "..." or simil