PolarDB データソースを作成することで、Dataphin が PolarDB からビジネスデータを読み取ったり、PolarDB にデータを書き込んだりできるようになります。このトピックでは、PolarDB データソースの作成方法について説明します。
背景情報
PolarDB は、Alibaba Cloud が独自に開発した新世代のリレーショナルデータベースです。MySQL および PostgreSQL 構文と互換性のあるクラウドホスト型データベースプロダクトです。コンピューティングとストレージの分離アーキテクチャの下で、ソフトウェアとハードウェアの統合の利点を活用して、究極の弾力性、高性能、マスストレージ、信頼性を備えたデータベースサービスをユーザーに提供します。PolarDB を使用している場合は、データ開発のために Dataphin に接続する前に、まず PolarDB データソースを作成する必要があります。
ポリシーの説明
データソース作成権限を持つカスタムグローバルロール、およびスーパー管理者、データソース管理者、ドメインアーキテクト、プロジェクト管理者のロールのみがデータソースを作成できます。
手順
Dataphin ホームページの上部のナビゲーションバーで、[管理センター] > [データソース管理] を選択します。
[データソース] ページで、[+データソースの作成] をクリックします。
[データソースの作成] ページの [リレーショナルデータベース] セクションで、[PolarDB] を選択します。
最近 PolarDB を使用したことがある場合は、[最近使用した] セクションで PolarDB を選択することもできます。また、検索ボックスに PolarDB のキーワードを入力して、すばやく検索することもできます。
[PolarDB データソースの作成] ページで、データソースに接続するためのパラメーターを設定します。
データソースの基本情報を設定します。
パラメーター
説明
データソース名
データソースの名前を入力します。名前は次の要件を満たす必要があります:
中国語の文字、英字、数字、アンダースコア (_)、ハイフン (-) のみを含めることができます。
名前の長さは最大 64 文字です。
データソースコード
データソースコードを設定すると、Flink_SQL タスクまたは Dataphin JDBC クライアントを使用して、
データソースコード.テーブル名またはデータソースコード.スキーマ.テーブル名のフォーマットで Dataphin データソーステーブルに直接アクセスして、迅速な消費が可能になります。タスク実行環境に基づいてデータソースを自動的に切り替えるには、変数フォーマット${データソースコード}.テーブルまたは${データソースコード}.スキーマ.テーブルを使用してアクセスしてください。詳細については、「Dataphin データソーステーブル開発メソッド」をご参照ください。重要データソースコードは、設定後に変更することはできません。
データソースコードを設定した後にのみ、アセットディレクトリおよびアセットインベントリのオブジェクト詳細ページでデータをプレビューできます。
Flink SQL では、MySQL、Hologres、MaxCompute、Oracle、StarRocks、Hive、および SelectDB データソースのみがサポートされています。
データソースの説明
PolarDB データソースの簡単な説明。128 文字を超えることはできません。
データベースタイプ
PolarDB の基盤となるエンジンタイプに基づいて、対応するデータベースタイプを選択します:
PolarDB の基盤となるエンジンが MySQL の場合は、[MYSQL] を選択します。
PolarDB の基盤となるエンジンが PostgreSQL の場合は、[POSTGRE_SQL] を選択します。
タイムゾーン
統合ノードの時間フォーマットのデータは、現在のタイムゾーンに基づいて処理されます。デフォルトのタイムゾーンは [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。
データソース構成
ビジネスデータソースが本番データソースと開発データソースを区別するかに基づいて:
ビジネスデータソースが本番データソースと開発データソースを区別する場合は、[本番 + 開発データソース] を選択します。
ビジネスデータソースが本番データソースと開発データソースを区別しない場合は、[本番データソース] を選択します。
タグ
タグに基づいてデータソースを分類し、タグ付けすることができます。タグの作成方法の詳細については、「データソースタグの管理」をご参照ください。
データソースと Dataphin 間の接続パラメーターを設定します。
データソース構成で [本番 + 開発データソース] を選択した場合は、本番 + 開発データソース の両方の接続情報を設定する必要があります。データソース構成で [本番データソース] を選択した場合は、本番データソース の接続情報のみを設定する必要があります。
説明通常、本番データソースと開発データソースは、開発環境と本番環境の間の環境分離を実現し、開発データソースが本番データソースに与える影響を軽減するために、異なるデータソースとして設定する必要があります。ただし、Dataphin は、それらを同じデータソースとして、つまり同一のパラメーター値で設定することもサポートしています。
パラメーター
説明
JDBC URL
選択したデータベースタイプに基づいて、対応するエンドポイントを設定します。
MySQL: フォーマット:
jdbc:mysql://host:port/dbnamePostgreSQL: フォーマット:
jdbc:postgresql://host:port/dbname
スキーマ
前のステップでデータベースタイプとして [PostgreSQL] を選択した場合、[スキーマ] を設定する必要があります。[スキーマ] は PostgreSQL インスタンスのデータベース名です。
ユーザー名、パスワード
PolarDB データソースエンジン MySQL または PostgreSQL にログインするために使用するユーザー名とパスワード。
データソースの高度な設定を構成します。
パラメーター
説明
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 データソースの作成を完了します。
[接続テスト] をクリックすると、システムはデータソースが Dataphin と正常に接続できるかどうかをテストします。直接 [OK] をクリックすると、システムは選択されたすべてのクラスターの接続を自動的にテストしますが、選択されたすべてのクラスターが接続に失敗した場合でも、データソースは正常に作成できます。