DataWorks:DRDS ノードを構成する

背景情報

以前は DRDS と呼ばれていた PolarDB for Xscale (PolarDB-X) は、分散データベースサービスです。スケールアウト操作を実行して、リレーショナルデータベースを大量のデータのストレージとアクセスをサポートする分散システムにアップグレードできます。 PolarDB-X は、MySQL などのリレーショナルデータベースの元の機能を維持します。 詳細については、「概要」をご参照ください。

前提条件

• ワークフローが作成されている。

  DataStudio では、さまざまなタイプの計算エンジンの開発操作がワークフローに基づいて実行されます。したがって、ノードを作成する前に、ワークフローを作成する必要があります。 詳細については、「ワークフローを作成する」をご参照ください。

• DRDS データソースが追加されている。

  データベース内のデータにアクセスするためにデータソースを使用する前に、PolarDB-X データベースを DRDS データソースとして DataWorks に追加する必要があります。 データソースを追加する方法については、「データソースを追加および管理する」をご参照ください。 DataWorks で DRDS データソースを使用する方法については、「DRDS (PolarDB-X 1.0) データソース」をご参照ください。

  説明

  Java Database Connectivity (JDBC) 接続文字列モードで DataWorks に追加された DRDS データソースのみに基づいて DRDS ノードを作成できます。

• データソースとリソースグループの間にネットワーク接続が確立されている。

  目的のデータソースが、使用するリソースグループに接続されていることを確認する必要があります。 ネットワーク接続を構成する方法の詳細については、「リソースグループとデータソース間のネットワーク接続を確立する」をご参照ください。

• (RAM ユーザーを使用してタスクを開発する場合に必要) RAM ユーザーがメンバーとして DataWorks ワークスペースに追加され、[開発] ロールまたは [ワークスペース管理者] ロールが割り当てられている。 ワークスペース管理者ロールには、必要以上の権限があります。 ワークスペース管理者ロールを割り当てる場合は注意してください。 メンバーを追加し、メンバーにロールを割り当てる方法の詳細については、「ワークスペースメンバーを追加し、ロールを割り当てる」をご参照ください。

制限

このタイプのノードは、中国 (杭州)、中国 (上海)、中国 (北京)、中国 (深圳)、中国 (成都)、中国 (香港)、シンガポール、マレーシア (クアラルンプール)、ドイツ (フランクフルト)、米国 (シリコンバレー)、米国 (バージニア) の各リージョンでサポートされています。

ステップ 1: DRDS ノードを作成する

1. DataStudio ページに移動します。

   DataWorks コンソール にログオンします。 上部のナビゲーションバーで、目的のリージョンを選択します。 左側のナビゲーションペインで、[データ開発とガバナンス] > [データ開発] を選択します。 表示されるページで、ドロップダウンリストから目的のワークスペースを選択し、[データ開発に移動] をクリックします。

2. DataStudio ページで、目的のワークフローを見つけ、ワークフロー名を右クリックして、[ノードの作成] > [データベース] > [DRDS] を選択します。

3. [ノードの作成] ダイアログボックスで、[名前] パラメーターを構成し、[確認] をクリックします。 次に、作成したノードを使用して、タスクを開発および構成できます。

ステップ 2: DRDS タスクを開発する

(オプション) DRDS データソースを選択する

ワークスペースに複数の DRDS データソースが追加されている場合は、ビジネス要件に基づいて、ノードの構成タブの上部にある [データソースの選択] ドロップダウンリストから 1 つを選択する必要があります。 ワークスペースに DRDS データソースが 1 つだけ追加されている場合は、その DRDS データソースを使用してタスクが開発されます。

SQL コードを開発する: 簡単な例

DRDS ノードの構成タブにあるコードエディターで、タスクコードを記述します。 サンプルコード:

SELECT * FROM usertablename;

SQL コードを開発する: スケジューリングパラメーターを使用する

DataWorks は、定期的なスケジューリングシナリオでのスケジューリングパラメーターの構成に基づいて、タスクのコードで値が動的に置き換えられるスケジューリングパラメーターを提供します。 ${Variable} 形式でタスクコードに変数を定義し、[プロパティ] タブの [パラメーター] セクションで変数に値を割り当てることができます。 サポートされているスケジューリングパラメーターの形式とスケジューリングパラメーターの構成方法については、「サポートされているスケジューリングパラメーターの形式」および「スケジューリングパラメーターを構成して使用する」をご参照ください。

サンプルコード:

SELECT '${var}'; -- var 変数に特定のスケジューリングパラメーターを割り当てることができます。

ステップ 3: タスクスケジューリングプロパティを構成する

システムでノード上のタスクを定期的に実行する場合、ノードの構成タブの右側ナビゲーションペインにある [プロパティ] をクリックして、ビジネス要件に基づいてタスクスケジューリングプロパティを構成できます。 詳細については、「スケジュール」をご参照ください。

ステップ 5: タスクをコミットしてデプロイする

ノード上のタスクが構成されたら、タスクをコミットしてデプロイする必要があります。 タスクをコミットしてデプロイすると、システムはスケジューリング構成に基づいてタスクを定期的に実行します。

1. 上部ツールバーの アイコンをクリックして、タスクを保存します。

2. 上部ツールバーの アイコンをクリックして、ノード上のタスクをコミットします。

   [送信] ダイアログボックスで、[変更の説明] パラメーターを構成します。 次に、ビジネス要件に基づいて、タスクのコミット後にタスクコードを確認するかどうかを決定します。

   説明

   • タスクをコミットする前に、[プロパティ] タブで [再実行] パラメーターと [親ノード] パラメーターを構成する必要があります。

   • コードレビュー機能を使用して、タスクのコード品質を確保し、無効なタスクコードによって発生するタスク実行エラーを防ぐことができます。 コードレビュー機能を有効にすると、コミットされたノードコードは、コードレビューに合格した後でのみデプロイできます。 詳細については、「コードレビュー」をご参照ください。

標準モードのワークスペースを使用する場合は、タスクをコミットした後に、本番環境にタスクをデプロイする必要があります。 ノード上のタスクをデプロイするには、ノードの構成タブの右上隅にある [デプロイ] をクリックします。 詳細については、「タスクをデプロイする」をご参照ください。

次のステップ

タスク O&M: タスクをコミットしてデプロイすると、タスクはスケジューリング構成に基づいて定期的に実行されます。 対応するノードの構成タブの右上隅にある [オペレーションセンター] をクリックしてオペレーションセンターに移動し、タスクのスケジューリングステータスを表示できます。 詳細については、「自動トリガーされたタスクを表示および管理する」をご参照ください。