任务编排

应用场景

DMS的任务编排功能提供了强大的自动化编排和调度能力，满足数据同步、数据归档、数据备份、数据分析、数据挖掘等需求，可帮助企业实现数据管理的自动化和标准化，提高数据管理的效率与质量。

• DTS数据迁移节点可用于跨库、单个表或整个数据库的数据迁移。

• 离线数据节点可用于数据库之间的数据同步。

• 跨库Spark SQL节点可用于跨库数据同步和跨库数据加工。

• AnalyticDB MySQL Spark节点可用于机器学习、图像处理、报表分析等场景。

更多信息，请参见任务类型介绍。

前提条件

• 已将目标实例录入DMS中。录入实例操作，请参见云数据库录入。

• 实例状态正常。您可在DMS控制台首页的数据库实例区域，单击实例名称，查看实例状态。

• 支持的数据库类型如下：

  支持的数据库类型详情

  • 关系型数据库：

    • MySQL：RDS MySQL、PolarDB MySQL版、MyBase MySQL、PolarDB分布式版、其他来源MySQL

    • SQL Server：RDS SQL Server、MyBase SQL Server、其他来源SQL Server

    • PostgreSQL：RDS PostgreSQL、PolarDB PostgreSQL版、MyBase PostgreSQL、其他来源PostgreSQL

    • OceanBase：OceanBase MySQL模式、OceanBase Oracle模式、自建OceanBase

    • PolarDB PostgreSQL版（兼容Oracle）

    • Oracle

    • 达梦数据库

    • DB2

  • NoSQL：Lindorm

  • 数据仓库：

    • AnalyticDB MySQL版

    • AnalyticDB PostgreSQL版

    • DLA

    • MaxCompute

    • Hologres

  • 对象存储：OSS

使用限制

若实例的管控模式为自由操作或稳定变更时，需保证您为该任务流的责任人，否则在编辑任务流的节点后，可能会导致任务流运行失败。若实例的管控模式为安全协同，则不存在该考虑。设置任务流责任人的操作，请参见任务编排概述。

准备工作

本示例已提前创建test表，建表语句如下：

-- 创建表
CREATE TABLE test (
    `id` bigint(20) UNSIGNED NOT NULL PRIMARY KEY AUTO_INCREMENT COMMENT '主键',
      `gmt_create` DATETIME NOT NULL COMMENT '创建时间',
      `gmt_modified` DATETIME NOT NULL COMMENT '修改时间',
    `content` TEXT COMMENT '测试数据'
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='任务编排测试表';

-- 插入数据
INSERT INTO test( `gmt_create`, `gmt_modified`, `content`) VALUES ('2020-01-01 01:00:00', '2020-01-01 01:00:00', 'value1');
INSERT INTO test( `gmt_create`, `gmt_modified`, `content`) VALUES ('2020-02-01 01:00:00', '2020-02-01 01:00:00', 'value2');
INSERT INTO test( `gmt_create`, `gmt_modified`, `content`) VALUES ('2020-03-01 01:00:00', '2020-03-01 01:00:00', 'value3');
INSERT INTO test( `gmt_create`, `gmt_modified`, `content`) VALUES ('2020-04-01 01:00:00', '2020-04-01 01:00:00', 'value4');
INSERT INTO test( `gmt_create`, `gmt_modified`, `content`) VALUES ('2020-05-01 01:00:00', '2020-05-01 01:00:00', 'value5');
INSERT INTO test( `gmt_create`, `gmt_modified`, `content`) VALUES ('2020-06-01 01:00:00', '2020-06-01 01:00:00', 'value6');
INSERT INTO test( `gmt_create`, `gmt_modified`, `content`) VALUES ('2020-07-01 01:00:00', '2020-07-01 01:00:00', 'value7');
INSERT INTO test( `gmt_create`, `gmt_modified`, `content`) VALUES ('2020-08-01 01:00:00', '2020-08-01 01:00:00', 'value8');
INSERT INTO test( `gmt_create`, `gmt_modified`, `content`) VALUES ('2020-09-01 01:00:00', '2020-09-01 01:00:00', 'value9');
INSERT INTO test( `gmt_create`, `gmt_modified`, `content`) VALUES ('2020-10-01 01:00:00', '2020-10-01 01:00:00', 'value10');

您可通过SQL窗口或提交数据变更工单创建表。更多信息，请参见在SQL窗口创建表和普通数据变更。

操作步骤