OpenSearch データソースを作成して、Dataphin から OpenSearch にデータを書き込むことができます。このトピックでは、OpenSearch データソースの作成方法について説明します。
権限
次のロールを持つユーザーのみがデータソースを作成できます: スーパー管理者、データソース管理者、ボードアーキテクト、プロジェクト管理者、および データソースの作成 権限を持つカスタムグローバルロール。
手順
Dataphin のホームページで、上部のメニューバーから [管理センター] > [データソース管理] を選択します。
[データソース] ページで、[+新規データソース] をクリックします。
[新規データソース] ページの [NoSQL] セクションで、[OpenSearch] を選択します。
最近 OpenSearch を使用した場合は、[最近使用] セクションから選択することもできます。または、検索ボックスに「OpenSearch」と入力してすばやく見つけることもできます。
[OpenSearch データソースの作成] ページで、接続パラメーターを設定します。
データソースの基本情報を設定します。
パラメーター
説明
データソース名
データソースの名前を入力します。名前は次の規則に従う必要があります:
中国語の文字、英字、数字、アンダースコア (_)、ハイフン (-) を含めることができます。
長さは 64 文字以内にする必要があります。
データソースコード
データソースコードを設定すると、Flink_SQL ノードまたは Dataphin Java Database Connectivity (JDBC) クライアントから Dataphin データソーステーブルに直接アクセスできます。すばやくアクセスするには、
DataSourceCode.TableNameまたはDataSourceCode.schema.TableNameのフォーマットを使用します。タスク実行環境に基づいてデータソースを自動的に切り替えるには、変数フォーマット${DataSourceCode}.tableまたは${DataSourceCode}.schema.tableを使用します。詳細については、「Dataphin データソーステーブルを開発する」をご参照ください。重要データソースコードは、設定後に変更することはできません。
データソースコードを設定した後にのみ、アセットディレクトリおよびアセットインベントリのオブジェクト詳細ページでデータをプレビューできます。
Flink SQL では、MySQL、Hologres、MaxCompute、Oracle、StarRocks、Hive、および SelectDB データソースのみがサポートされています。
バージョン
バージョン 2.x のみがサポートされています。
データソースの説明
データソースの簡単な説明を入力します。説明は最大 128 文字です。
データソース構成
設定するデータソースを選択します:
ビジネスデータソースに本番環境と開発環境が分かれている場合は、[本番 + 開発データソース] を選択します。
ビジネスデータソースに環境が分かれていない場合は、[本番データソース] を選択します。
タグ
タグを追加してデータソースを分類します。タグを作成するには、「データソースタグを管理する」をご参照ください。
Dataphin の接続パラメーターを設定します。
前のステップで [本番 + 開発データソース] を選択した場合、本番と開発の両方のデータソースの設定ページが表示されます。[本番データソース] を選択した場合、本番データソースの設定ページのみが表示されます。
説明通常、開発環境を本番環境から分離するために、本番データソースと開発データソースを異なるデータソースとして設定する必要があります。この方法により、開発アクティビティが本番データソースに与える影響を軽減できます。ただし、Dataphin では、同じパラメーター値を使用して同じデータソースとして設定することもできます。
パラメーター
説明
エンドポイント
OpenSearch エンドポイントを入力します。例:
http://opensearch-host:9200。ユーザー名、パスワード
OpenSearch インスタンスで認証が有効になっている場合は、インスタンスにアクセスするためのユーザー名とパスワードを入力します。
[デフォルトリソースグループ] を選択します。このリソースグループは、データベース SQL タスク、オフライン完全データベース移行、データプレビューなど、データソースに関連するタスクを実行します。
[接続テスト] をクリックするか、[OK] をクリックして設定を保存し、OpenSearch データソースを作成します。
[接続テスト] をクリックすると、システムは Dataphin とデータソース間の接続性をテストします。[OK] を直接クリックすると、システムは選択したすべてのクラスターの接続を自動的にテストします。接続テストが失敗した場合でも、データソースは作成されます。
[接続テスト] は、Dataphin に登録され、通常使用されている デフォルトクラスター または 登録済みスケジューリングクラスター の接続をテストします。デフォルトクラスター はデフォルトで選択されており、選択を解除することはできません。登録済みスケジューリングクラスター の下にリソースグループがない場合、接続テストはサポートされません。接続をテストする前に、まずリソースグループを作成する必要があります。
選択したクラスターは、現在のデータソースとのネットワーク接続をテストするためにのみ使用され、後で関連タスクを実行するためには使用されません。
接続テストは通常 2 分未満で完了します。タイムアウトした場合は、
アイコンをクリックして具体的な理由を表示し、リトライできます。テスト結果が [接続に失敗しました]、[接続に成功しました]、または [警告付きで成功] のいずれであっても、システムは最終結果の生成時刻を記録します。
説明デフォルトクラスター のテスト結果には、警告付きで成功、接続に成功しました、接続に失敗しました の 3 つの接続ステータスが含まれます。Dataphin の 登録済みスケジューリングクラスター のテスト結果には、接続に成功しました と 接続に失敗しました の 2 つの接続ステータスのみが含まれます。
テスト結果が [接続に失敗しました] の場合、
アイコンをクリックして具体的な失敗理由を表示できます。テスト結果が [警告付きで成功] の場合、アプリケーションクラスターの接続は成功しましたが、スケジューリングクラスターの接続が失敗したことを意味します。現在のデータソースは、データ開発および統合には使用できません。
アイコンをクリックしてログ情報を表示できます。