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

前提条件

開始する前に、以下を確認してください。

• DMS に登録済みのデータベースインスタンス。詳細については、「Alibaba Cloud データベースインスタンスの登録」をご参照ください。

• 正常ステータスのインスタンス。確認するには、DMS コンソールホームページに移動し、左側のナビゲーションウィンドウでインスタンスにカーソルを合わせ、ステータスツールチップを読み取ります。

• インスタンスコントロールモードが 柔軟な管理 または 安定的な変更 の場合、タスクフローへの所有者アクセスが必要です。この要件は、[セキュリティコラボレーション] モードのインスタンスには適用されません。詳細については、「概要」をご参照ください。

ソーステーブルのセットアップ

このチュートリアルでは、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 の SQLConsole タブ上、またはデータ変更チケットを提出することで実行できます。詳細については、「SQLConsole タブでデータベースを管理する」および「通常のデータ変更」をご参照ください。

ステップ1: タスクフローの作成

1. DMS コンソール V5.0 にログインします。

2. トップナビゲーションバーで、[すべての機能] > [データ + AI] > [データ開発] > [タスクオーケストレーション] を選択します。

   DMS コンソールの通常モードを使用している場合、左上隅のアイコンにマウスを合わせて、[データ + AI] > [データ開発] > [タスクオーケストレーション] を選択します。

3. [タスクフローの作成]をクリックします。

4. [新規タスクフロー] ダイアログボックスで、[タスクフロー名]と[説明]を入力し、[OK] をクリックします。

ステップ2: 時間変数の設定

タスクフローは、アーカイブウィンドウが現在の日付を基準に自動的に6ヶ月遡るように、SQL フィルター条件として2つの時間変数を使用します。タスクフロー内のすべてのノードは、構文 ${variable_name} を使用してこれらの変数を参照できます。

ページの下部の[変数設定]タブで、左側のペインの[タスクフロー変数]をクリックし、以下の 2 つの変数を作成します：

• yearmonth6_name は、アーカイブテーブル名のサフィックスとして使用されます (例: test_2022-12)。

• yearmonth6_date は、両方の SQL ノードの WHERE 句におけるカットオフ日付として使用されます。

変数の完全な構文とオプションについては、「変数」をご参照ください。

ステップ3: ノードの作成と構成

タスクフローには、2つの単一インスタンス SQL ノードが必要です。1つはデータをアーカイブテーブルに移行するため、もう1つはソーステーブルから移行された行を削除するためです。

ステップ4: ノードの接続とスケジューリングの設定

ステップ5: タスクフローの実行と結果の確認

次のステップ

• 概要

• 変数

• タスクフローの公開または非公開