DataWorks の DM ノードを使用して、DM タスクを開発し、定期的にスケジューリングしたり、他のジョブと統合したりできます。このトピックでは、DM ノードを使用したタスク開発のワークフローについて説明します。
背景情報
Dameng (DM) は、業務システムに統合されるオンライントランザクション処理 (OLTP) データベースです。分散システム、エラスティックコンピューティング、クラウドコンピューティングの利点を兼ね備えています。DM は柔軟性、使いやすさ、信頼性、そして高い安全性を特徴としています。詳細については、Dameng (DM) の公式サイトをご参照ください。
前提条件
ビジネスフローの作成
DataStudio では、ビジネスフローによって開発が整理されます。ノードを作成する前に、ビジネスフローを作成する必要があります。詳細については、「ワークフローの作成」をご参照ください。
DM データソースの作成
DM データベースのデータにアクセスするには、そのデータベースを DataWorks のデータソースとして追加する必要があります。データソースの作成方法の詳細については、「データソース管理」をご参照ください。DataWorks での DM データソースの使用方法の詳細については、「DM (Dameng) データソース」をご参照ください。
説明DM ノードは、Java Database Connectivity (JDBC) 接続文字列を使用して作成された DM データソースのみをサポートします。
データソースとリソースグループ間のネットワーク接続の確立
使用するリソースグループにデータソースが接続できることを確認してください。ネットワーク接続の設定方法については、「ネットワーク接続ソリューション」をご参照ください。
(オプション。RAM ユーザーには必須) RAM ユーザーをワークスペースに追加し、[開発] または [ワークスペース管理者] ロールを割り当てます。ワークスペース管理者ロールは高い権限を持つため、付与は慎重に行ってください。詳細については、「ワークスペースにメンバーを追加する」をご参照ください。
制限事項
サポートされているリージョン:中国 (杭州)、中国 (上海)、中国 (北京)、中国 (深セン)、中国 (成都)、中国 (香港)、シンガポール、マレーシア (クアラルンプール)、ドイツ (フランクフルト)、米国 (シリコンバレー)、および米国 (バージニア)。
ステップ 1:DM ノードの作成
DataStudio ページに移動します。
DataWorks コンソールにログインします。上部のナビゲーションバーで、目的のリージョンを選択します。左側のナビゲーションウィンドウで、を選択します。表示されたページで、ドロップダウンリストから目的のワークスペースを選択し、[データ開発へ] をクリックします。
対象のビジネスフローを右クリックし、 を選択します。
[Create Node] ダイアログボックスで、ノードの [Name] を指定し、[Confirm] をクリックします。ノードが作成された後、ノードエディターでタスクを開発および設定できます。
ステップ 2:DM タスクの開発
(任意) DM データソースの選択
ワークスペースに複数の DM データソースが作成されている場合は、ノードエディターページでデータソースを選択します。DM データソースが 1 つしか作成されていない場合は、それがデフォルトで使用されます。
DM ノードは、Java Database Connectivity (JDBC) 接続文字列を使用して作成された DM データソースのみをサポートします。
SQL コードの開発:簡単な例
DM ノードのコードエディタでタスクコードを記述します。次のコードは一例です。
SELECT * FROM usertablename;SQL コードの開発:スケジュールパラメーターの使用
DataWorks は、定期的なスケジュールでコード内で動的パラメーターを使用できるスケジュールパラメーターを提供します。ノードタスクでは、${variable_name} 形式で変数を定義します。次に、右側のナビゲーションウィンドウの [スケジュール] セクションで、[パラメーター] に移動し、変数に値を割り当てます。サポートされているフォーマットとスケジュールパラメーターの設定方法の詳細については、「スケジュールパラメーターのフォーマット」および「スケジュールパラメーターの設定と使用」をご参照ください。
次のコードは一例です。
SELECT '${var}'; -- スケジュールパラメーターと併用できます。ステップ 3:タスクスケジュールの設定
タスクをスケジューリングするには、右側の [スケジューリング設定] をクリックしてプロパティを設定します。詳細については、「概要」をご参照ください。
送信する前に、[再実行プロパティ] と [依存する上流ノード] を設定してください。
ステップ 4:タスクコードのデバッグ
タスクをデバッグして、正常に実行されることを確認します。
(任意) デバッグ用のリソースグループを選択し、パラメーター値を割り当てます。
ツールバーの
アイコンをクリックします。[パラメーター]ダイアログボックスで、リソースグループを選択します。デバッグ用にスケジュールパラメーターに値を割り当てます。パラメーターの割り当てロジックの詳細については、「タスクのデバッグプロセス」をご参照ください。
タスクコードを保存して実行します。
アイコンをクリックして保存し、
アイコンをクリックして実行します。(任意) スモークテストの実行
送信中または送信後にスモークテストを実行して、開発環境での実行を検証します。詳細については、「スモークテストの実行」をご参照ください。
ステップ 5:タスクの送信と公開
ノードを送信して公開し、スケジュールを有効化します。
ツールバーの
アイコンをクリックしてノードを保存します。ツールバーの
アイコンをクリックしてノードタスクを送信します。「[送信]」ダイアログボックスで、「[変更の説明]」を入力し、コードレビューのオプションを選択します。
説明送信する前に、[再実行プロパティ] と [依存する上流ノード] を設定してください。
コードレビューは品質を保証します。有効になっている場合、公開前にレビュー担当者がコードを承認する必要があります。詳細については、「コードレビュー」をご参照ください。
標準モードのワークスペースでは、右上隅にある[公開]をクリックして本番環境にデプロイします。詳細については、「タスクの公開」をご参照ください。
次のステップ
タスクが送信されて公開されると、ノードの設定に基づいて定期的に実行されます。ノード設定タブの右上にある [運用保守] をクリックして、オペレーションセンターに移動できます。オペレーションセンターでは、定期タスクのスケジュールと実行ステータスを表示できます。詳細については、「定期タスクの管理」をご参照ください。