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