Data Management:タスクオーケストレーション

前提条件

• タスクオーケストレーション機能を使用するインスタンスがDMSに登録されています。 ApsaraDBインスタンスの登録方法の詳細については、「Alibaba Cloudデータベースインスタンスの登録」をご参照ください。

• インスタンスのステータスは正常です。 インスタンスのステータスを表示するには、次の操作を実行します。DMSコンソールの [ホーム] ページに移動します。 左側のナビゲーションウィンドウで、クエリするインスタンスの上にポインターを移動します。 次に、表示されるヒントからインスタンスのステータスを表示します。

• 次の種類のデータベースがサポートされています。

  サポートされるソースデータベースタイプ

  • リレーショナルデータベース

    • MySQL: ApsaraDB RDS for MySQL、PolarDB for MySQL、ApsaraDB MyBase for MySQL、PolarDB for Xscale、およびその他のソースのMySQLデータベース

    • SQL Server: ApsaraDB RDS for SQL Server、ApsaraDB MyBase for SQL Server、および他のソースのSQL Serverデータベース

    • PostgreSQL: ApsaraDB RDS for PostgreSQL、PolarDB for PostgreSQL、ApsaraDB MyBase for PostgreSQL、および他のソースのPostgreSQLデータベース

    • OceanBase: MySQLモードのApsaraDB for OceanBase、OracleモードのApsaraDB for OceanBase、および自己管理型OceanBaseデータベース

    • PolarDB for PostgreSQL (Oracleと互換)

    • オラクル

    • ダメン (DM)

    • Db2

  • NoSQLデータベース: Lindorm

  • データウェアハウス:

    • AnalyticDB for MySQL

    • AnalyticDB for PostgreSQL

    • データレイク分析 (DLA)

    • MaxCompute

    • ホログラム

  • オブジェクトストレージ: Object storage Service (OSS)

使用上の注意

インスタンスのコントロールモードがFlexible ManagementまたはStable Changeの場合、編集するタスクフローの所有者であることを確認します。 そうしないと、タスクフローのノード設定を編集した後にタスクフローが失敗する可能性があります。 インスタンスの制御モードがSecurity Collaborationの場合、この要件は不要です。 タスクフローの所有者を指定する方法の詳細については、「概要」をご参照ください。

準備

この例では、testという名前のソーステーブルが使用されます。 次のステートメントを実行して、テストテーブルを作成し、テストテーブルにデータを挿入できます。

-- Create a table.
CREATE TABLE test (
    `id` bigint(20) UNSIGNED NOT NULL PRIMARY KEY AUTO_INCREMENT COMMENT 'Primary key',
      `gmt_create` DATETIME NOT NULL COMMENT 'Creation time',
      `gmt_modified` DATETIME NOT NULL COMMENT 'Modification time',
    `content` TEXT COMMENT 'Test data'
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='Table for a task orchestration test';

-- Insert data into the table.
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');

DMSの [SQLConsole] タブで、またはデータ変更チケットを送信して、テストテーブルを作成することもできます。 詳細については、[SQLConsole] タブの [データベースの管理] トピックの「テーブルの作成」セクションと [通常のデータ変更] トピックをご参照ください。

手順