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 互換)

    • Oracle

    • Dameng (DM)

    • Db2

  • NoSQL データベース: Lindorm

  • データウェアハウス:

    • AnalyticDB for MySQL

    • AnalyticDB for PostgreSQL

    • Data Lake Analytics (DLA)

    • MaxCompute

    • Hologres

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

注意事項

インスタンスのコントロールモードが「柔軟な管理」または「安定的な変更」の場合は、編集するタスクフローのオーナーであることを確認してください。そうでない場合、タスクフローのノード構成を編集した後にタスクフローが失敗する可能性があります。インスタンスのコントロールモードが「セキュリティコラボレーション」の場合は、この要件は不要です。タスクフローのオーナーを指定する方法の詳細については、「概要」をご参照ください。

準備

この例では、test という名前のソーステーブルを使用します。次のステートメントを実行して、test テーブルを作成し、データを 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');

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

手順