PolarDB-X データソースを作成することで、Dataphin が PolarDB-X からビジネスデータを読み取ったり、PolarDB-X にデータを書き込んだりできるようになります。このトピックでは、PolarDB-X データソースを作成する方法について説明します。
背景情報
PolarDB-X(DRDS のスペックアップバージョン)は、Alibaba が独自に開発したクラウドネイティブ分散データベースです。高スループット、大容量ストレージ、低レイテンシ、容易なスケーラビリティ、超高可用性というクラウド時代のデータベース要件を満たすために、Alibaba Cloud によって設計および開発された高パフォーマンスのクラウドネイティブ分散データベースプロダクトです。PolarDB-X を使用している場合は、データ開発のために Dataphin に接続する際に、最初に PolarDB-X データソースを作成する必要があります。
制限事項
現在、PolarDB-X データソースのバージョン 1.0 のみがサポートされています。
権限の説明
データソースの作成権限ポイントを持つカスタムグローバルロールと、スーパー管理者、データソース管理者、ドメインアーキテクト、プロジェクト管理者などのシステムロールのみがデータソースを作成できます。
手順
Dataphin ホームページの上部ナビゲーションバーで、[管理センター] > [データソース管理] を選択します。
[データソース] ページで、[+データソースの作成] をクリックします。
[データソースの作成] ページの [リレーショナルデータベース] セクションで、[PolarDB-X (旧称 DRDS)] を選択します。
最近 PolarDB-X を使用したことがある場合は、[最近使用したデータソース] セクションで PolarDB-X を選択することもできます。また、検索ボックスに PolarDB-X キーワードを入力して、すばやくフィルタリングすることもできます。
[PolarDB-X (旧称 DRDS) データソースの作成] ページで、データソースへの接続パラメーターを構成します。
データソースの基本情報を構成します。
パラメーター
説明
データソース名
データソースの名前を入力します。名前は次の要件を満たしている必要があります。
漢字、英字、数字、アンダースコア(_) 、およびハイフン(-) のみを含めることができます。
長さは 64 文字を超えることはできません。
データソースコード
データソースコードを構成した後、
data source code.table nameまたはdata source code.schema.table nameの形式で Flink_SQL タスクまたは Dataphin JDBC クライアントを使用して Dataphin データソーステーブルに直接アクセスし、迅速に利用できます。タスク実行環境に基づいてデータソースを自動的に切り替える必要がある場合は、変数形式${data source code}.tableまたは${data source code}.schema.tableを使用してアクセスしてください。詳細については、「Dataphin データソーステーブル開発方法」をご参照ください。重要データソースコードは、正常に構成された後は変更できません。
データソースコードが正常に構成された後、アセットディレクトリとアセットインベントリのオブジェクト詳細ページでデータをプレビューできます。
Flink SQL では、現在、MySQL、Hologres、MaxCompute、Oracle、StarRocks、Hive、および SelectDB データソースのみがサポートされています。
[データソースの説明]
データソースの簡単な説明。128 文字を超えることはできません。
[データソースの構成]
構成するデータソースを選択します。
ビジネスデータソースが本番データソースと開発データソースを区別する場合、[本番 + 開発データソース] を選択します。
ビジネスデータソースが本番データソースと開発データソースを区別しない場合、[本番データソース] を選択します。
タグ
タグに基づいてデータソースを分類およびタグ付けできます。タグの作成方法については、「データソースタグの管理」をご参照ください。
データソースと Dataphin 間の接続パラメーターを構成します。
データソースの構成で 本番 + 開発データソース を選択した場合は、本番 + 開発データソース 両方の接続情報を構成する必要があります。データソースの構成で 本番データソース を選択した場合は、本番データソース の接続情報のみを構成する必要があります。
説明通常、本番データソースと開発データソースは異なるデータソースとして構成し、開発環境を本番環境から分離して、開発データソースが本番データソースに与える影響を軽減する必要があります。ただし、Dataphin では、同じデータソースとして構成することもサポートされています。つまり、パラメーター値が同じになります。
パラメーター
説明
JDBC URL
接続アドレスの形式は
jdbc:mysql://host:port/dbnameです。[ユーザー名]、[パスワード]
データベースにログインするためのユーザー名とパスワード。
データソースの高度な設定を構成します。
パラメーター
説明
connectTimeout
データベースの connectTimeout の期間 (ミリ秒単位)。デフォルトは 900000 ミリ秒 (15 分) です。
説明JDBC URL に connectTimeout 構成がある場合、connectTimeout は JDBC URL に構成されているタイムアウト値になります。
Dataphin V3.11 より前に作成されたデータソースの場合、デフォルトの connectTimeout は
-1で、タイムアウト制限がないことを示します。
socketTimeout
データベースの socketTimeout の期間 (ミリ秒単位)。デフォルトは 1800000 ミリ秒 (30 分) です。
説明JDBC URL に socketTimeout 構成がある場合、socketTimeout は JDBC URL に構成されているタイムアウト値になります。
Dataphin V3.11 より前に作成されたデータソースの場合、デフォルトの socketTimeout は
-1で、タイムアウト制限がないことを示します。
接続再試行回数
データベース接続がタイムアウトした場合、設定されたリトライ回数に達するまで自動的に接続を再試行します。最大リトライ回数に達しても接続に失敗した場合は、接続は失敗します。
説明デフォルトのリトライ回数は 1 回 で、0 ~ 10 のパラメーターがサポートされています。
接続リトライ回数は、デフォルトで オフライン統合タスク と グローバル品質 (アセット品質機能モジュールを有効にする必要があります) に適用されます。オフライン統合タスクでは、タスクレベルのリトライ回数を個別に構成できます。
[デフォルトリソースグループ] を選択します。これは、データベース SQL、オフラインデータベースのフルマイグレーション、データプレビューなど、現在のデータソースに関連するタスクを実行するために使用されます。
[接続テスト] を実行するか、[OK] をクリックして保存し、PolarDB-X データソースの作成を完了します。
[接続テスト] をクリックすると、システムはデータソースが Dataphin と正常に接続できるかどうかをテストします。[OK] を直接クリックすると、システムは選択したすべてのクラスターの接続を自動的にテストしますが、選択したすべてのクラスターの接続に失敗した場合でも、データソースは正常に作成されます。
[接続テスト] は、Dataphin に登録され、正常に使用されている [デフォルトクラスタ] または [登録済みスケジューリングクラスタ] の接続をテストします。[デフォルトクラスタ] はデフォルトで選択されており、選択解除できません。[登録済みスケジューリングクラスタ] にリソースグループがない場合、接続テストはサポートされていません。接続をテストする前に、まずリソースグループを作成する必要があります。
選択したクラスターは、現在のデータソースとのネットワーク接続をテストするためにのみ使用され、後で関連タスクを実行するために使用されるわけではありません。
接続テストは通常 2 分未満で完了します。タイムアウトした場合は、
アイコンをクリックして具体的な理由を確認し、再試行できます。テスト結果が [接続失敗]、[接続成功]、または [警告付きで成功] のいずれであっても、システムは最終結果の生成時刻を記録します。
説明デフォルトクラスター のテスト結果のみ、警告付きで成功、接続成功、接続失敗 の 3 つの接続ステータスが含まれます。Dataphin の 登録済みスケジューリングクラスター のテスト結果には、接続成功 と 接続失敗 の 2 つの接続ステータスのみが含まれます。
テスト結果が [接続失敗] の場合は、
アイコンをクリックして具体的な失敗理由を確認できます。テスト結果が [警告付きで成功] の場合は、アプリケーションクラスターの接続は成功したが、スケジューリングクラスターの接続は失敗したことを意味します。現在のデータソースは、データ開発と統合に使用できません。
アイコンをクリックしてログ情報を表示できます。