DataWorks:PolarDB for MySQL

背景情報

PolarDB for MySQL は Alibaba Cloud が開発した次世代クラウドネイティブデータベースです。コンピューティングとストレージの分離アーキテクチャを採用し、ソフトウェアとハードウェアの利点を融合することで、高いスケーラビリティ、パフォーマンス専有型、セキュリティ、およびマスストレージを備えたデータベースサービスを提供します。このサービスは MySQL および PostgreSQL エコシステムに 100% 互換があり、Oracle 構文にも高い互換性があります。詳細については、「PolarDB for MySQL」をご参照ください。

前提条件

• ビジネスプロセスを作成します。

  DataStudio では、開発作業をビジネスプロセス単位で管理します。ノードを作成する前に、ビジネスプロセスを作成しておく必要があります。詳細については、「ワークフローの作成」をご参照ください。

• PolarDB for MySQL データソースが作成されます。

  PolarDB for MySQL データベースのデータにアクセスするには、事前に DataWorks にそのデータベースをデータソースとして追加しておく必要があります。データソースの作成方法については、「データソース管理」をご参照ください。DataWorks での PolarDB for MySQL データソースの利用方法については、「PolarDB データソース」をご参照ください。

  説明

  PolarDB for MySQL ノードは、Java Database Connectivity (JDBC) 接続文字列を使用して作成された PolarDB for MySQL データソースのみをサポートします。

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

  使用するリソースグループからデータソースに接続できることを確認してください。ネットワーク接続の設定方法については、「ネットワーク接続ソリューション」をご参照ください。

• （オプション：RAM ユーザーの場合必須）RAM ユーザーをワークスペースに追加し、開発ロールまたは ワークスペース管理者ロールを割り当てます。ワークスペース管理者ロールは権限が高いため、慎重に付与してください。詳細については、「ワークスペースへのメンバー追加」をご参照ください。

制限事項

サポート対象リージョン：中国 (杭州)、中国 (上海)、中国 (北京)、中国 (深セン)、中国 (成都)、中国 (香港)、シンガポール、マレーシア (クアラルンプール)、ドイツ (フランクフルト)、米国 (シリコンバレー)、米国 (バージニア)。

手順 1：PolarDB for MySQL ノードの作成

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

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

2. 対象のビジネスプロセスを右クリックし、ノードの新規作成 > データベース > PolarDB for MySQL を選択します。

3. ノードの作成 ダイアログボックスで、ノードの 名前 を入力し、OK をクリックします。ノードが作成されたら、タスクの開発および構成が可能になります。

手順 2：PolarDB for MySQL タスクの開発

（オプション）PolarDB for MySQL データソースの選択

ワークスペースに複数の PolarDB for MySQL データソースが存在する場合、ノード編集ページで必要なデータソースを選択します。データソースが 1 つしかない場合は、デフォルトでそのデータソースが使用されます。

SQL コードの開発：シンプルな例

PolarDB for MySQL ノードのコードエディタで、タスク用の SQL コードを記述します。以下のコードはその例です。

SELECT * FROM usertablename;

SQL コードの開発：スケジューリングパラメーターの使用

DataWorks では、定期的にスケジュール実行されるタスクで動的な入力を可能にするための スケジューリングパラメーター を提供しています。${variable_name} 形式でコード内に変数を定義できます。その後、ノード編集ページの右側ナビゲーションウィンドウで スケジュール ＞ スケジューリングパラメーター セクションに変数の値を割り当てます。サポートされるフォーマットおよびスケジューリングパラメーターの設定方法の詳細については、「スケジューリングパラメーターのサポートフォーマット」および「スケジューリングパラメーターの設定と使用」をご参照ください。

以下のコードはその例です。

SELECT '${var}'; -- スケジューリングパラメーターと併用できます。

手順 3：タスクスケジュールの構成

タスクをスケジュールするには、右側の スケジューリング構成 をクリックしてプロパティを設定します。詳細については、「概要」をご参照ください。

手順 4：タスクコードのデバッグ

タスクが正しく実行されることを確認するために、デバッグを行います。

1. （オプション）デバッグ用リソースグループを選択し、パラメーター値を割り当てます。

   • ツールバーの アイコンをクリックします。パラメーター ダイアログボックスで、リソースグループを選択します。

   • デバッグ用にスケジューリングパラメーターに値を割り当てます。パラメーター割り当てのロジックの詳細については、「タスクデバッグプロセス」をご参照ください。

2. タスクコードを保存して実行します。

   アイコンをクリックして保存し、その後 アイコンをクリックして実行します。

3. （オプション）スモークテストを実行します。

   提出中または提出後に開発環境での実行を検証するため、スモークテストを実行できます。詳細については、「スモークテストの実施」をご参照ください。

手順 5：タスクの提出と公開

ノードを提出および公開して、スケジュールを有効化します。

1. ツールバーの アイコンをクリックしてノードを保存します。

2. ツールバーの アイコンをクリックしてノードタスクを提出します。

   提出 ダイアログボックスで、変更内容の説明 を入力し、コードレビューのオプションを選択します。

   説明

   • 提出前に、再実行プロパティ および 上流依存ノード を必ず構成してください。

   • コードレビューは品質を保証します。有効化されている場合、公開前にレビュアーによる承認が必要です。詳細については、「コードレビュー」をご参照ください。

標準モードのワークスペースでは、右上隅の 公開 をクリックして本番環境にデプロイします。詳細については、「タスクの公開」をご参照ください。

次のステップ

タスクが提出および公開されると、ノードの構成に基づいて定期的に実行されます。ノード構成タブの右上隅にある O&M をクリックすると、オペレーションセンターに移動できます。オペレーションセンターでは、定期タスクのスケジューリング状況および実行状況を確認できます。詳細については、「定期タスクの管理」をご参照ください。