OushuDB データソースを使用すると、Dataphin は OushuDB からデータを読み取ったり、OushuDB にデータを書き込んだりできます。このトピックでは、その作成方法について説明します。
制限事項
データソースを作成するには、[New Data Source] 権限を持つカスタムグローバルロール、または次のいずれかのシステムロールが必要です：スーパー管理者、データソース管理者、データドメインアーキテクト、または プロジェクト管理者。
操作手順
Dataphin ホームページで、トップナビゲーションバーから[管理センター] > [データソース管理]を選択します。
[データソース] ページで、[+ 新規データソース] をクリックします。
[新しいデータソース] ページの[リレーショナルデータベース] セクションで、 [OushuDB] を選択します。
最近 OushuDB を使用したことがある場合は、[最近使用した項目] セクションから [OushuDB] を選択することもできます。 または、検索ボックスに OushuDB のキーワードを入力してクイック検索を実行できます。
[新規 OushuDB データソース] ページで、データソースの接続パラメーターを設定します。
データソースの基本情報を設定します。
パラメータ
説明
[データソース名]
命名規則は次のとおりです。
名前には、中国語の文字、英大文字と英小文字、数字、アンダースコア (_) 、ハイフン (-) のみを使用できます。
64 文字以内にする必要があります。
[データソースコード]
データソースコードを設定すると、Flink_SQL タスクで
data_source_code.table_nameまたはdata_source_code.schema.table_nameの形式を使用して、このデータソースのテーブルを参照できます。現在の環境のデータソースに自動的にアクセスするには、変数形式${data_source_code}.tableまたは${data_source_code}.schema.tableを使用します。詳細については、「Dataphin データソーステーブルの開発方法」および「」をご参照ください。重要データソースコードは、一度構成すると変更できません。
データソースコードが構成された後でのみ、アセットディレクトリおよびアセットチェックリストのオブジェクト詳細ページでデータをプレビューできます。
Flink SQL では、現在、MySQL、Hologres、MaxCompute、Oracle、StarRocks、Hive、SelectDB、および GaussDB データウェアハウスサービス (DWS) のデータソースのみがサポートされています。
[バージョン]
サポートされるバージョンは[6.4.0]のみです。
[データソースの説明]
OushuDB データソースの説明。最大 128 文字まで入力できます。
[タイムゾーン]
Dataphin は、統合タスクで時間ベースのデータを処理するために、選択したタイムゾーンを使用します。デフォルトは [Asia/Shanghai] です。[変更] をクリックして、別のタイムゾーンを選択します:
[GMT]：[GMT-12:00]、[GMT-11:00]、[GMT-10:00]、[GMT-09:30]、[GMT-09:00]、[GMT-08:00]、[GMT-07:00]、[GMT-06:00]、[GMT-05:00]、[GMT-04:00]、[GMT-03:00]、[GMT-03:00]、[GMT-02:30]、[GMT-02:00]、[GMT-01:00]、[GMT+00:00]、[GMT+01:00]、[GMT+02:00]、[GMT+03:00]、[GMT+03:30]、[GMT+04:00]、[GMT+04:30]、[GMT+05:00]、[GMT+05:30]、[GMT+05:45]、[GMT+06:00]、[GMT+06:30]、[GMT+07:00]、[GMT+08:00]、[GMT+08:45]、[GMT+09:00]、[GMT+09:30]、[GMT+10:00]、[GMT+10:30]、[GMT+11:00]、[GMT+12:00]、[GMT+12:45]、[GMT+13:00]、および[GMT+14:00]。
[夏時間]： [Africa/Cairo]、[America/Chicago]、[America/Denver]、[America/Los_Angeles]、[America/New_York]、[America/Sao_Paulo]、[Asia/Bangkok]、[Asia/Dubai]、[Asia/Kolkata]、[Asia/Shanghai]、[Asia/Tokyo]、[Atlantic/Azores]、[Australia/Sydney]、[Europe/Berlin]、[Europe/London]、[Europe/Moscow]、[Europe/Paris]、[Pacific/Auckland]、および [Pacific/Honolulu]。
[データソース設定]
データソースに本番環境と開発環境が分かれているかどうかに応じて選択します。
データソースが本番環境と開発環境に分離されている場合は、[production + dev data source] を選択します。
データソースの環境が分かれていない場合は、[production data source] を選択します。
[タグ]
タグを追加してデータソースを分類できます。タグの作成方法については、「Manage data source tags」および「」をご参照ください。
データソースと Dataphin 間の接続パラメータの設定
[production + dev data source] を選択した場合は、本番環境と開発環境の両方の接続情報を設定する必要があります。[production data source] を選択した場合は、本番環境の接続情報のみを設定します。
説明ベストプラクティスとして、本番環境と開発環境のデータソースは別インスタンスとして設定し、環境を分離して、開発作業が本番に影響しないようにすることを推奨します。ただし Dataphin では、同一のパラメータ値を入力することで、両方に同じデータソースを使用することもできます。
[設定方法] には、[JDBC URL] または [ホスト] を選択できます。 デフォルトは JDBC URL です。
[JDBC URL]
パラメータ
説明
[JDBC URL]
接続 URL の形式は
jdbc:oushudb://host1:port1,host2:port2/databaseです。[スキーマ]
ユーザー名に関連付けられているスキーマを入力します。
[ユーザー名]と[パスワード]
データベース認証用のユーザー名とパスワードを入力します。タスクが期待どおりに実行されるように、アカウントに必要なデータ権限が付与されていることを確認してください。
[Host]
ホスト設定
パラメータ
説明
[サーバーアドレス]
Enter the IP address and port number of the server.
You can click [+ Add] to add multiple IP addresses and port numbers. Click the
icon to delete an entry. You must keep at least one entry.[データベース名]
データベース名を入力します。
パラメータ設定
パラメータ
説明
[Parameter]
[Parameter name]：既存のパラメータ名を選択するか、カスタム名を入力します。
カスタムのパラメータ名には、英大文字と英小文字、数字、ピリオド (.)、アンダースコア (_) 、ハイフン (-) のみを使用できます。
[Parameter value]：パラメータ名を選択した場合、このフィールドは必須です。値には、英字、数字、ピリオド (.)、アンダースコア (_) 、ハイフン (-) のみを使用できます。256 文字以内にする必要があります。
説明[+ パラメーターの追加] をクリックして複数のパラメーターを追加し、
アイコンをクリックしてパラメーターを削除できます。最大 30 個のパラメーターを追加できます。[スキーマ]
ユーザー名に関連付けられているスキーマを入力します。
[ユーザー名]と[パスワード]
データベース認証用のユーザー名とパスワードを入力します。タスクが期待どおりに実行されるように、アカウントに必要なデータ権限が付与されていることを確認してください。
説明[host] 方式でデータソースを作成し、その後 [JDBC URL] 方式に切り替えた場合、システムは指定された IP アドレスとポートから JDBC URL を自動的に生成します。
データソースの詳細設定
パラメータ
説明
[connectTimeout]
データベースの接続タイムアウトです (単位：秒)。デフォルトは 900 秒 (15 分) です。
説明JDBC URL で
connectTimeoutパラメーターも設定する場合、JDBC URL の値が優先されます。[ソケットタイムアウト]
データベースのソケットタイムアウトです (単位：秒)。デフォルトは 1,800 秒 (30 分) です。
説明JDBC URL で
socketTimeoutパラメーターも設定した場合、JDBC URL の値が優先されます。[接続再試行]
データベース接続がタイムアウトした場合、指定したリトライ回数に達するまでシステムが自動的に接続を再試行します。最大リトライ回数に達しても接続できない場合、接続は失敗します。
説明デフォルトのリトライ回数は 1 です。この値は 0～10 の整数で設定できます。
接続リトライ回数は、デフォルトで オフライン統合タスク と [グローバル品質] に適用されます。[グローバル品質] 機能を有効にする必要があります。オフライン統合タスク については、タスクレベルでもリトライ回数を設定できます。
説明重複する parameters には、以下の優先順位ルールが適用されます。
パラメータが [JDBC URL]、[詳細設定]、および [host] 設定に指定されている場合は、[JDBC URL] の値が優先されます。
パラメータが [JDBC URL] と [詳細設定] の両方に指定されている場合は、[JDBC URL] の値が優先されます。
パラメータが [詳細設定] と [host] 設定の両方に指定されている場合は、[詳細設定] の値が優先されます。
[デフォルトのリソースグループ] を選択します。このリソースグループは、データベース SQL、オフラインのフルデータベース移行、データプレビューなど、データソースに関連するタスクの実行に使用されます。
[接続テスト] または [OK] をクリックして、設定を保存し、OushuDB データソースを作成します。
[接続テスト] をクリックすると、システムは Dataphin がデータソースに接続できるかどうかを検証します。[OK] を直接クリックすると、システムは選択したすべてのクラスターの接続を自動的にテストします。接続テストが失敗した場合でも、データソースを作成できます。
接続テスト は、デフォルトクラスター または Dataphin に登録済みかつ正常に稼働中の 登録済みスケジューリングクラスター に対して実行されます。デフォルトクラスター がデフォルトで選択され、解除することはできません。登録済みスケジューリングクラスターにリソースグループが未作成の場合、接続テストはサポートされません。接続テストを実行するには、まずリソースグループを作成してください。
選択されたクラスターは、現在のデータソースとのネットワーク接続性をテストする目的でのみ使用され、今後の関連タスク実行には使用されません。
接続テストは通常 2 分以内に完了します。タイムアウトした場合は、
アイコンをクリックして具体的な原因を確認し、再試行できます。テスト結果が 接続失敗、接続成功、または 警告あり接続成功 のいずれであっても、最終結果の生成時刻が記録されます。
説明デフォルトクラスター のテスト結果のみが、警告あり接続成功、接続成功、接続失敗 の 3 種類のステータスを含みます。登録済みスケジューリングクラスター のテスト結果は、接続成功 および 接続失敗 の 2 種類のみです。
テスト結果が 接続失敗 の場合、
アイコンをクリックして具体的な失敗原因を確認できます。テスト結果が 警告あり接続成功 の場合、アプリケーションクラスターへの接続は成功しましたが、スケジューリングクラスターへの接続に失敗しています。この状態では、現在のデータソースをデータ開発および統合に使用できません。
アイコンをクリックしてログ情報を確認できます。