このトピックでは、Dataphin が KingbaseES からビジネスデータを読み取ったり、KingbaseES にデータを書き込んだりできるようにする KingbaseES データソースの作成方法について説明します。
権限要件
データソースの作成権限を持つカスタムグローバルロール、およびスーパー管理者、データソース管理者、ドメインアーキテクト、プロジェクト管理者などのシステムロールのみがデータソースを作成できます。
手順
Dataphin のホームページで、トップメニューバーから [Management Hub] > [Datasource Management] を選択します。
[Datasource] ページで、[+Create Data Source] をクリックします。
[データソースの作成] ページで、[リレーショナルデータベース] セクションから KingbaseES を選択します。
最近 KingbaseES を使用した場合は、[最近使用] セクションから選択することもできます。または、検索ボックスにキーワードを入力して KingbaseES を検索することもできます。
[KingbaseES データソースの作成] ページで、データソースの接続パラメーターを構成します。
データソースの基本情報を構成します。
パラメーター
説明
データソース名
名前は次の要件を満たす必要があります:
中国語の文字、英字、数字、アンダースコア (_)、ハイフン (-) のみを含めることができます。
長さは 64 文字までです。
データソースコード
データソースコードを構成した後、Flink_SQL ノードで
datasource_code.table_nameまたはdatasource_code.schema.table_nameのフォーマットを使用してテーブルを参照できます。対応する環境のデータソースに自動的にアクセスするには、変数フォーマット${datasource_code}.tableまたは${datasource_code}.schema.tableを使用します。詳細については、「Dataphin データソーステーブルの開発メソッド」および「」をご参照ください。重要データソースコードは、構成後に変更することはできません。
データソースコードが構成された後でのみ、アセットディレクトリおよびアセットインベントリのオブジェクト詳細ページでデータをプレビューできます。
Flink SQL では、MySQL、Hologres、MaxCompute、Oracle、StarRocks、Hive、および SelectDB データソースのみがサポートされています。
バージョン
サポートされているバージョンは V8R3、V8R6、および V9R1 です。
データソースの説明
KingbaseES データソースの説明。説明は 128 文字までです。
データソース構成
ビジネスデータソースが本番環境と開発環境を個別に利用しているかどうかに基づいて:
ビジネスデータソースが個別の環境を使用している場合は、[本番 + 開発データソース] を選択します。
ビジネスデータソースが個別の環境を使用していない場合は、[本番データソース] を選択します。
タグ
データソースにタグを追加して分類できます。タグの作成方法の詳細については、「データソースタグの管理」をご参照ください。
接続パラメーターを構成します。
[データソース構成] を [本番 + 開発データソース] に設定した場合は、両方の環境の接続情報を構成する必要があります。[本番データソース] に設定した場合は、本番データソースの接続情報のみを構成する必要があります。
説明通常、本番データソースと開発データソースは、環境を分離し、開発活動が本番に与える影響を軽減するために、別々のデータソースとして構成する必要があります。ただし、Dataphin は、同じパラメーター値を持つ同一のデータソースとして構成することもサポートしています。
[構成メソッド] を [JDBC URL] または [ホスト] に設定します。デフォルトは JDBC URL です。
JDBC URL 構成メソッド
パラメーター
説明
JDBC URL
接続 URL のフォーマットは
jdbc:kingbase8://host:port/dbnameです。例:jdbc:kingbase8//192.168.*.212:54321/dataphin。スキーマ
[スキーマ] は KingbaseES インスタンス内のデータベースの名前です。データベース名は KingbaseES インスタンスのデータ管理ページで確認できます。
ユーザー名とパスワード
データベースへのログオンに使用するユーザー名とパスワード。
ホスト構成メソッド
ホスト構成メソッド
パラメーター
説明
サーバーアドレス
サーバーの IP アドレスとポート番号を入力します。
[+追加] をクリックして、複数の IP アドレスとポート番号を追加します。
アイコンをクリックして、余分なエントリを削除します。少なくとも 1 つのエントリを保持する必要があります。dbname
データベース名を入力します。
パラメーター構成
パラメーター
説明
パラメーター
パラメーター名: 既存のパラメーター名を選択するか、カスタムパラメーター名を入力します。
カスタムパラメーター名には、英字、数字、ピリオド (.)、アンダースコア (_)、ハイフン (-) のみを含めることができます。
パラメーター値: パラメーター名が選択されている場合に必須です。値には、英字、数字、ピリオド (.)、アンダースコア (_)、ハイフン (-) のみを含めることができ、長さは 256 文字までです。
説明[+パラメーターの追加] をクリックして、複数のパラメーターを追加します。
アイコンをクリックして、余分なパラメーターを削除します。最大 30 個のパラメーターを追加できます。ユーザー名、パスワード
KingbaseES データベースへのログオンに使用するユーザー名とパスワード。
説明ホスト構成メソッドを使用してデータソースを作成し、後で JDBC URL メソッドに切り替えると、システムはサーバーの IP アドレスとポート番号を連結して JDBC URL フィールドに入力します。
詳細設定を構成します。
パラメーター
説明
socketTimeout
データベースのソケットタイムアウト期間 (秒単位)。デフォルトは 1800 秒 (30 分) です。
説明JDBC URL で socketTimeout を構成した場合、JDBC URL の値が使用されます。
Dataphin V3.11 より前に作成されたデータソースの場合、デフォルトの socketTimeout は
-1で、タイムアウトがないことを示します。
connectTimeout
データベースの接続タイムアウト期間 (秒単位)。デフォルトは 900 秒 (15 分) です。
説明JDBC URL で connectTimeout を構成した場合、JDBC URL の値が使用されます。
Dataphin V3.11 より前に作成されたデータソースの場合、デフォルトの connectTimeout は
-1で、タイムアウトがないことを示します。
接続リトライ
データベース接続がタイムアウトした場合、システムは指定された回数まで自動的に接続をリトライします。最大リトライ回数を超えても接続が失敗した場合、接続試行は失敗します。
説明デフォルトのリトライ回数は 1 です。このパラメーターは 0 から 10 までの値に設定できます。
接続リトライ回数は、デフォルトでオフライン統合ノードとグローバル品質チェックに適用されます。グローバル品質チェックには、アセット品質モジュールを有効にする必要があります。オフライン統合ノードごとにリトライ回数を構成できます。
説明パラメーターの優先順位:
パラメーターが [JDBC URL]、[詳細設定]、および [ホスト構成] セクションで定義されている場合、[JDBC URL] の値が使用されます。
パラメーターが [JDBC URL] と [詳細設定] の両方のセクションで定義されている場合、[JDBC URL] の値が使用されます。
パラメーターが [詳細設定] と [ホスト構成] の両方のセクションで定義されている場合、[詳細設定] の値が使用されます。
[デフォルトリソースグループ] を選択します。このリソースグループは、データベースの SQL クエリ、オフラインのフルデータベース移行、データプレビューなど、データソースに関連するタスクを実行するために使用されます。
[接続テスト] をクリックするか、[OK] をクリックして構成を保存し、KingbaseES データソースを作成します。
[接続テスト] をクリックすると、システムは Dataphin への接続をテストします。[OK] をクリックすると、システムは選択したすべてのクラスターの接続を自動的にテストします。接続テストが失敗した場合でも、データソースは作成されます。