DataWorks では、MySQL ノードを使用して MySQL タスクを開発し、定期的にスケジュールし、他のタスクと統合できます。 このトピックでは、開発プロセスについて説明します。
前提条件
-
ビジネスフローが作成されている必要があります。
Data Studio では、ビジネスフローに基づいてエンジン固有の開発操作を実行します。ノードを作成する前に、まずビジネスフローを作成してください。詳細については、「ビジネスフローの作成」をご参照ください。
-
MySQL データソースが追加済みであること。
MySQL データベースのデータにアクセスする前に、DataWorks でデータベースを MySQL データソースとして追加する必要があります。 詳細については、「MySQL データソース」をご参照ください。
説明MySQL ノードは、接続文字列モードで追加された MySQL データソースのみをサポートします。
-
(オプション。RAM ユーザーの場合は必須) タスク開発に使用する RAM ユーザーがターゲットワークスペースに追加され、[Development] または [スペースマネージャー] ロール (広範な権限を付与するため、慎重に割り当ててください) のいずれかが割り当てられている必要があります。メンバーの追加と権限の付与の詳細については、「ワークスペースへのメンバーの追加」をご参照ください。
制限事項
-
MySQL ノードは、本番環境に接続文字列モードで追加された MySQL データソースのタスク開発のみをサポートします。データソースのモードを確認するには、「MySQL データソースを設定する」の説明に従って Data source management ページに移動し、対象のデータソースを見つけ、操作 列の Edit をクリックします。
-
MySQL ノードは、MySQL 8.0 以降をサポートしていません。
-
サポートされているリージョン:China (Hangzhou)、China (Shanghai)、China (Beijing)、China (Shenzhen)、China (Chengdu)、China (Hong Kong)、Singapore、Malaysia (Kuala Lumpur)、Indonesia (Jakarta)、および US (Virginia)。
ネットワーク接続
-
ネットワーク接続
MySQL データベースは、サーバーレスリソースグループ (推奨) または 専用スケジューリングリソースグループ とのネットワーク接続が必要です。 詳細については、「ネットワーク接続ソリューション」をご参照ください。
-
IP アドレスホワイトリストの設定
MySQL データベースが IP アドレスホワイトリストによって保護されている場合は、サーバーレスリソースグループ (推奨) または 専用スケジューリングリソースグループ の VPC CIDR ブロックとパブリック IP アドレスをデータベースの IP アドレスホワイトリストに追加する必要があります。 詳細については、「IP アドレスホワイトリストの設定」をご参照ください。
-
ネットワーク接続のテスト
DataWorks データソースを追加するときに、ネットワーク接続をテストできます。 詳細については、「ネットワーク接続のテスト」をご参照ください。
MySQL タスクの開発
-
Data Studio ページに移動します。
DataWorks コンソールにログインします。 左側のナビゲーションウィンドウで、[Data Integration] をクリックします。 表示されるページで、ドロップダウンリストから目的のワークスペースを選択し、[Data Integrationに移動] をクリックします。
-
[Workflow]を作成します。
既存の [Workflow] がある場合は、この手順をスキップしてください。
-
アイコンにカーソルを合わせ、Create Workflow を選択します。 -
Create Workflow ダイアログボックスで、Workflow Name を入力します。
-
Create をクリックします。
-
-
[MySQL] ノードを作成します。
-
アイコンにカーソルを合わせ、 を選択します。ワークフローを見つけて、その名前を右クリックし、 を選択することもできます。
-
Create Node ダイアログボックスで、Name を入力し、Node Type と Path を選択します。
説明ノード名には、大文字と小文字の英字、漢字、数字、アンダースコア (_)、ピリオド (.) のみを含めることができます。 名前の長さは 128 文字を超えることはできません。
-
OK をクリックして、MySQL ノードエディターを開きます。
-
-
[MySQL] ノードを使用して MySQL タスクを開発します。
-
データソースを選択します。
Select DataSource ドロップダウンリストから、ターゲットデータソースを選択します。 必要なデータソースがリストにない場合は、右側の New data source をクリックします。 次に、Data source management ページでデータソースを作成します。 詳細については、「MySQL データソースの設定」をご参照ください。
説明-
ワークスペースが標準モードの場合、ドロップダウンリストには、開発環境と本番環境の両方で設定されている MySQL データソースのみが表示されます。
-
MySQL ノードは、本番環境で接続文字列モードで追加された MySQL データソースのタスク開発のみをサポートします。 データソースのモードを確認するには、「MySQL データソースの設定」で説明されているように Data source management ページに移動し、データソースを見つけて、操作 列の Edit をクリックします。
-
-
リソースグループを選択します。
ツールバーで、
アイコンをクリックします。 Parameter ダイアログボックスで、スケジューリングリソースグループを選択します。説明-
パブリックインターネットまたは VPC 経由でデータソースにアクセスするには、データソースとの接続性テストに合格したスケジューリングリソースグループを使用する必要があります。 詳細については、「ネットワーク接続ソリューション」をご参照ください。
-
特定の実行でリソースグループを変更するには、[パラメーターを指定して実行]
をクリックして、別のスケジューリングリソースグループを選択します。
-
-
SQL 文を使用してタスクを作成します。
SQL エディターに SQL 文を記述します。
たとえば、次の SQL 文は xc_emp テーブルのデータをクエリします。
select * from xc_emp;クエリの実行後、結果は [結果] タブのテーブルに返されます。 このテーブルには、empno、aname、job、mgr、hiredate、sal、comm、deptno の列が含まれます。
タスクの実行に失敗した場合は、エラーメッセージを表示し、「よくある質問:タスクが「JDBC driver not supported」エラーで失敗する」を参照して問題をトラブルシューティングできます。
-
SQL 文を保存して実行します。
ツールバーで、
アイコンをクリックして SQL 文を保存し、
アイコンをクリックしてタスクを実行します。
-
-
タスクのスケジューリングプロパティを設定します。
ノードを定期的に実行するには、右側のペインで Scheduling をクリックし、そのスケジューリングプロパティを設定します。
-
タスクの基本的なスケジューリングプロパティを設定します。 詳細については、「基本プロパティの設定」をご参照ください。
-
スケジューリングサイクル、再実行プロパティ、および依存関係を設定します。 詳細については、「時間プロパティの設定」および「同一サイクルスケジューリング依存関係の設定」をご参照ください。
説明ノードをコミットする前に、ノードの Rerun attribute と Parent Nodes を設定する必要があります。
-
リソースプロパティを設定します。 詳細については、「リソースプロパティの設定」をご参照ください。 パブリックインターネットまたは VPC 経由で MySQL データソースにアクセスするには、MySQL データソースにネットワーク接続できるスケジューリングリソースグループを選択します。 詳細については、「ネットワーク接続ソリューション」をご参照ください。
-
-
タスクをコミットしてデプロイします。
-
ツールバーで、
アイコンをクリックしてノードを保存します。 -
ツールバーで、
アイコンをクリックしてタスクをコミットします。 -
Commit Node ダイアログボックスで、Change Description を入力します。
-
Determine をクリックします。
標準モードのワークスペースでは、タスクをコミットした後、本番環境にデプロイする必要があります。 上部のメニューバーで、[デプロイ] をクリックします。 詳細については、「タスクのデプロイ」をご参照ください。
-
-
スケジュールされたタスクを表示します。
-
エディターの右上隅にある O&M Personnel をクリックして、本番環境のオペレーションセンターを開きます。
-
実行中のスケジュールされたタスクを表示します。 詳細については、「スケジュールされたタスクの管理」をご参照ください。
スケジュールされたタスクの詳細を表示するには、上部のメニューバーで Operation Center をクリックします。 詳細については、「オペレーションセンターの概要」をご参照ください。
-
よくある質問:タスクが "JDBC driver not supported" エラーで失敗する
-
問題の説明
タスクがエラーメッセージ
sql execute failed! JDBC driver not supportedで失敗します。 -
原因
このエラーは、接続文字列モードで作成されていない MySQL データソースを選択した場合に発生します。
-
解決策
接続文字列モードで作成されたデータソースを選択します。データソースのモードを確認するには、「MySQL データソースを設定する」の説明に従って Data source management ページに移動し、対象のデータソースを見つけ、操作 列の Edit をクリックします。
よくある質問:接続性テストには合格するがタスクが失敗する
-
考えられる原因 1:接続性テストで誤ったリソースグループが選択されています。 テストにはスケジューリングリソースグループが使用されていることを確認してください。 詳細については、「ネットワーク接続のテスト」をご参照ください。
-
考えられる原因 2:接続性テストで使用したスケジューリングリソースグループと、タスクの実行で選択したリソースグループが異なっています。 この問題を解決するには、[パラメーターを指定して実行]
をクリックして、正しいスケジューリングリソースグループを選択します。