DataWorks の KingbaseES ノードを使用すると、KingbaseES タスクの開発、定期的なスケジュール設定、および他のジョブとの統合が可能です。本トピックでは、KingbaseES ノードを用いたタスク開発の主なワークフローについて説明します。
背景情報
KingbaseES は、SQL 標準をサポートする大規模なリレーショナルデータベース管理システム (RDBMS) です。大量のデータを扱い、高い同時実行性と高可用性を要求するエンタープライズ向けアプリケーションに最適です。詳細については、「KingbaseES 公式ウェブサイト」をご参照ください。
前提条件
ビジネスプロセスを作成します。
DataStudio では、開発がビジネスプロセス単位で整理されます。ノードを作成する前に、必ずビジネスプロセスを作成してください。詳細については、「ワークフローの作成」をご参照ください。
KingbaseES データソースが作成されました。
DataWorks から KingbaseES データにアクセスするには、KingbaseES データベースを DataWorks のデータソースとして登録する必要があります。データソースの作成方法については、「データソース管理」をご参照ください。また、DataWorks における KingbaseES データソースの利用方法については、「KingbaseES データソース」をご参照ください。
説明KingbaseES ノードでは、Java Database Connectivity (JDBC) 接続文字列を使用して作成された KingbaseES データソースのみがサポートされます。
データソースとリソースグループ間のネットワーク接続が確立されています。
使用するリソースグループに対してデータソースが正しく接続できることを確認してください。ネットワーク接続の設定方法については、「ネットワーク接続ソリューション」をご参照ください。
(任意:RAM ユーザーの場合のみ必須)RAM ユーザーをワークスペースに追加し、開発者 または ワークスペース管理者 のロールを割り当てます。ワークスペース管理者ロールは権限が高いため、付与には十分な注意が必要です。詳細については、「ワークスペースへのメンバー追加」をご参照ください。
制限事項
対応リージョン:中国 (杭州)、中国 (上海)、中国 (北京)、、中国 (深セン)、中国 (成都)、中国 (香港)、シンガポール、マレーシア (クアラルンプール)、ドイツ (フランクフルト)、米国 (シリコンバレー)、米国 (バージニア)。
ステップ 1:KingbaseES ノードの作成
DataStudio ページに移動します。
DataWorks コンソール にログインします。上部ナビゲーションバーから対象のリージョンを選択します。左側ナビゲーションウィンドウで、 を選択します。表示されるページで、ドロップダウンリストから対象のワークスペースを選択し、データ開発へ移動 をクリックします。
対象のビジネスプロセスを右クリックし、 を選択します。
ノードの作成 ダイアログボックスで、ノードの 名前 を入力し、確認 をクリックします。これによりノードが作成され、タスクの開発および構成を開始できます。
ステップ 2:KingbaseES タスクの開発
(任意)KingbaseES データソースの選択
ワークスペースに複数の KingbaseES データソースが存在する場合、ノードの構成ページで使用するデータソースを選択する必要があります。KingbaseES データソースが 1 つのみ存在する場合は、デフォルトでそのデータソースが使用されます。
KingbaseES ノードでは、Java Database Connectivity (JDBC) 接続文字列を使用して作成された KingbaseES データソースのみがサポートされます。
SQL コードの開発:シンプルな例
KingbaseES ノードのコードエディタで、タスクのコードを記述します。以下のコードブロックは例です。
SELECT * FROM usertablename;SQL コードの開発:スケジューリングパラメーターの使用
DataWorks では、定期実行のシナリオにおいて変数に動的に値を渡すための スケジューリングパラメーター を提供しています。タスクコード内で変数を `${変数名}` の形式で定義できます。その後、右側ナビゲーションペインの パラメーター セクション(スケジュール タブ内)で、変数に値を割り当てます。サポートされるフォーマットおよびスケジューリングパラメーターの構成方法については、「スケジューリングパラメーターのサポートフォーマット」および「スケジューリングパラメーターの構成と使用」をご参照ください。
以下のコードブロックは例です。
SELECT '${var}'; -- スケジューリングパラメーターを使用します。ステップ 3:タスクのスケジュール構成
タスクをスケジュールするには、右側の スケジュール構成 をクリックし、各種プロパティを構成します。詳細については、「概要」をご参照ください。
提出前に、再実行プロパティ および 上流依存ノード を構成してください。
ステップ 4:タスクコードのデバッグ
タスクが正しく実行されることを確認するためにデバッグを行います。
(任意)デバッグ用のリソースグループを選択し、パラメーター値を割り当てます。
ツールバーの
アイコンをクリックします。パラメーター ダイアログボックスで、リソースグループを選択します。デバッグ用にスケジューリングパラメーターの値を割り当てます。パラメーター割り当てのロジックについては、「タスクデバッグの手順」をご参照ください。
タスクコードを保存して実行します。
アイコンをクリックして保存し、その後
アイコンをクリックして実行します。(任意)スモークテストを実行します。
提出中または提出後にスモークテストを実行し、開発環境での実行を検証します。詳細については、「スモークテストの実施」をご参照ください。
ステップ 5:タスクの提出および公開
スケジュールを有効化するため、ノードを提出および公開します。
ツールバーの
アイコンをクリックしてノードを保存します。ツールバーの
アイコンをクリックしてノードタスクを提出します。提出 ダイアログボックスで、変更内容の説明 を入力し、コードレビューのオプションを選択します。
説明提出前に、再実行プロパティ および 上流依存ノード を構成してください。
コードレビューは品質保証のための機能です。有効化した場合、公開前にレビュアーによる承認が必要となります。詳細については、「コードレビュー」をご参照ください。
標準モードのワークスペースでは、右上隅の 公開 をクリックして本番環境へデプロイします。詳細については、「タスクの公開」をご参照ください。
次のステップ
タスクが提出および公開されると、ノードの構成に基づき定期的に実行されます。ノード構成タブの右上隅にある 運用管理 をクリックすると、オペレーションセンターに移動できます。オペレーションセンターでは、定期実行タスクのスケジュール状態および実行状態を確認できます。詳細については、「定期実行タスクの管理」をご参照ください。