RabbitMQ データソースを作成することで、Dataphin が RabbitMQ からビジネスデータを読み取ったり、RabbitMQ にデータを書き込んだりできるようになります。このトピックでは、RabbitMQ データソースを作成する方法について説明します。
権限要件
Dataphin では、データソースの作成 権限を持つユーザー、または スーパー管理者、データソース管理者、アーキテクチャデザイナー、プロジェクト管理者 ロールが割り当てられているユーザーのみが、データソースを作成できます。
手順
Dataphin ホームページの上部ナビゲーションバーで、[管理センター] > [データソース管理] を選択します。
[データソース] ページで、[+データソースの作成] をクリックします。
[データソースの作成] ページで、[メッセージキュー] セクションの [RabbitMQ] を選択します。
最近 RabbitMQ を使用したことがある場合は、[最近使用したデータソース] セクションで RabbitMQ を選択することもできます。検索ボックスにキーワードを入力して、RabbitMQ をすばやく検索することもできます。
[RabbitMQ データソースの作成] ページで、接続パラメーターを構成します。
データソースの基本情報を構成します。
パラメーター
説明
データソース名
名前は次の要件を満たしている必要があります。
名前には、漢字、英字、数字、アンダースコア (_)、およびハイフン (-) のみを含めることができます。
名前は最大 64 文字まで使用できます。
データソースコード
データソースコードを構成した後、Flink_SQL ノードで
data source code.table nameまたはdata source code.schema.table name形式を使用して、データソース内のテーブルを参照できます。現在の環境に基づいて対応する環境のデータソースに自動的にアクセスするには、変数形式${data source code}.tableまたは${data source code}.schema.tableを使用します。詳細については、「Dataphin データソーステーブルを開発する」をご参照ください。重要データソースコードは、正常に構成された後は変更できません。
データソースコードが正常に構成されると、アセットディレクトリとアセットインベントリのオブジェクト詳細ページでデータをプレビューできます。
Flink SQL では、現在、MySQL、Hologres、MaxCompute、Oracle、StarRocks、Hive、および SelectDB データソースのみがサポートされています。
バージョン
バージョン 3.6.5 のみサポートされています。
[データソースの説明]
データソースの簡単な説明。説明は 128 文字を超えることはできません。
[データソースの構成]
構成するデータソースを選択します。
ビジネスデータソースが本番データソースと開発データソースに分割されている場合は、[本番 + 開発データソース] を選択します。
ビジネスデータソースが本番データソースと開発データソースに分割されていない場合は、[本番データソース] を選択します。
タグ
タグに基づいてデータソースを分類およびラベル付けできます。タグの作成方法については、「データソースタグを管理する」をご参照ください。
データソースと Dataphin 間の接続パラメーターを構成します。
データソース構成で [本番 + 開発データソース] を選択した場合は、[本番 + 開発データソース] の接続情報を構成する必要があります。データソース構成が [本番データソース] の場合は、[本番データソース] の接続情報のみを構成する必要があります。
説明一般的に、本番データソースと開発データソースは、環境分離を実現し、開発データソースが本番データソースに与える影響を軽減するために、異なるデータソースとして構成する必要があります。ただし、Dataphin では、同じパラメーター値を持つ同じデータソースとして構成することもサポートされています。
パラメーター
説明
サーバーアドレス
サーバーの IP アドレスとポート番号を入力します。サポートされているサーバーアドレスは 1 つだけです。複数のサーバーアドレスを追加することはできません。
ユーザー名、パスワード
認証ユーザーのユーザー名とパスワード (または資格情報) を入力します。タスクが適切に実行されるように、ユーザーに必要なデータ権限があることを確認してください。
仮想ホスト
仮想ホストを入力します。デフォルト値は
/です。
[OK] をクリックして、RabbitMQ データソースを作成します。