マネージド ストリーミング コネクタ

Databricks LakeFlow Connect は、メッセージバスやイベントストリーミングソースからストリーミングテーブルにデータを継続的に取り込むための、フルマネージドのストリーミングコネクタを提供します。各コネクタは、宣言型構成を介して、ソース固有の認証、メッセージのデコード、およびパイプラインのライフサイクル管理を処理します。そのため、構造化ストリーミング コードを直接記述する必要はありません。

サポートされているコネクタ

• • ラビットMQ
  • RabbitMQクラシックキューからメッセージをストリーミングテーブルにストリームする。

コネクターコンポーネント

ストリーミングコネクタには、以下のコンポーネントがあります。

コンポーネント	説明
接続	ストリーミングソースのソースエンドポイントと認証資格情報を格納する、Unity Catalog のセキュリティ保護可能なオブジェクトです。マネージド コネクタは、パイプライン構成で資格情報を必要とせずに、この接続を使用して認証を行います。
取り込みパイプライン	ストリーミングソースからメッセージを継続的に読み取り、結果をストリーミングテーブルに書き込むパイプライン。パイプラインはサーバレスコンピュートで実行されます。
宛先テーブル	取り込み パイプラインがデータを書き込むストリーミングテーブル。