RocketMQ データソースを作成することで、Dataphin が RocketMQ からビジネスデータを読み取ったり、RocketMQ にデータを書き込んだりできるようになります。このトピックでは、RocketMQ データソースを作成する方法について説明します。
背景情報
RocketMQ とは、Alibaba Cloud Message Queue for RocketMQ のことを指します。これは、Alibaba Cloud が Apache RocketMQ をベースに構築した分散型の「メッセージ、イベント、ストリーム」統合処理プラットフォームであり、低レイテンシ、高い同時実行性、 高信頼性を備えています。Alibaba Cloud Message Queue for RocketMQ を使用している場合は、データ開発のために Dataphin に接続する前に、RocketMQ データソースを作成する必要があります。詳細については、「ApsaraMQ for RocketMQ とは」をご参照ください。
権限ポリシー
データソースの作成 権限を持つカスタム グローバル ロールと、スーパー管理者、データソース管理者、ドメイン設計者、プロジェクト管理者 などのシステム ロールのみが、データソースを作成できます。
手順
Dataphin ホームページで、上部のナビゲーションバーの [管理センター] > [データソース管理] をクリックします。
[データソース] ページで、[+データソースの作成] をクリックします。
[データソースの作成] ページで、[メッセージキュー] セクションの [RocketMQ] を選択します。
最近 RocketMQ を使用したことがある場合は、[最近使用したデータソース] セクションで RocketMQ を選択することもできます。検索ボックスにキーワードを入力して RocketMQ をすばやく検索することもできます。
[RocketMQ データソースの作成] ページで、データソースに接続するためのパラメーターを設定します。
データソースの基本情報を設定します。
パラメーター
説明
[データソース名]
名前は次の要件を満たしている必要があります。
漢字、英字、数字、アンダースコア (_)、ハイフン (-) のみを含めることができます。
長さは 64 文字を超えることはできません。
[データソースコード]
データソースコードを設定した後、
データソースコード.テーブル名またはデータソースコード.スキーマ.テーブル名の形式を使用して、Flink_SQL ノードでデータソース内のテーブルを参照できます。現在の環境に基づいて対応する環境のデータソースに自動的にアクセスする必要がある場合は、変数形式${データソースコード}.tableまたは${データソースコード}.schema.tableを使用してアクセスします。詳細については、「Dataphin データソーステーブル開発方法」をご参照ください。重要データソースコードは、正常に設定された後は変更できません。
データソースコードが正常に設定されると、アセットディレクトリとアセットインベントリのオブジェクト詳細ページでデータをプレビューできます。
Flink SQL では、現在、MySQL、Hologres、MaxCompute、Oracle、StarRocks、Hive、SelectDB データソースのみがサポートされています。
データソースの説明
データソースの簡単な説明。128 文字を超えることはできません。
データソース設定
構成するデータソースを選択します。
ビジネスデータソースが本番データソースと開発データソースを区別する場合、[本番 + 開発データソース] を選択します。
ビジネスデータソースが本番データソースと開発データソースを区別しない場合、[本番データソース] を選択します。
データソースと Dataphin 間の接続パラメーターを構成します。
データソース構成で [本番 + 開発データソース] を選択した場合は、[本番 + 開発データソース] の両方の接続情報を構成する必要があります。 [本番データソース] を選択した場合は、[本番データソース] の接続情報のみを構成する必要があります。
説明通常、本番データソースと開発データソースは異なるデータソースとして設定し、開発データソースと本番データソース間の環境分離を実現し、開発データソースが本番データソースに与える影響を軽減する必要があります。ただし、Dataphin では、同じパラメーター値を持つ同じデータソースとして設定することもサポートされています。
パラメーター
説明
[エンドポイント]
RocketMQ インスタンスのエンドポイント。Message Queue for RocketMQ コンソール の [インスタンスの詳細] ページでエンドポイントを確認できます。
TCP プロトコルクライアントアクセスポイントにある内部ネットワークアクセス用のエンドポイントを選択することをお勧めします。重要内部ネットワークアクセス用のエンドポイントは、RocketMQ インスタンスと Dataphin インスタンスが同じリージョンにある場合にのみ使用できます。
[インスタンス ID]
RocketMQ インスタンスの ID。Message Queue for RocketMQ コンソール の [インスタンスの詳細] ページでインスタンス ID を確認できます。
[アクセス ID]、[アクセスキー]
RocketMQ データソースが属するアカウントの AccessKey ID と AccessKey Secret。取得方法については、「アクセスキーを作成する」をご参照ください。
重要RocketMQ データソースを作成する際、データソースが Dataphin に正常に接続できるかどうかのテストはサポートされていません。したがって、接続情報の正確性を確保する必要があります。
[OK] をクリックして、RocketMQ データソースの作成を完了します。