ラビットMQ コネクター
ベータ版
この機能はベータ版です。ワークスペース管理者は、 プレビュー ページからこの機能へのアクセスを制御できます。Databricksのプレビューを管理するを参照してください。
LakeFlow ConnectのマネージドRabbitMQコネクタを使用すると、RabbitMQクラシックキューからDatabricksのストリーミングテーブルにメッセージをストリーミングできます。コネクタは「最低 1 回」の配信セマンティクスを提供し、認証、メッセージデコード、確認応答、およびパイプラインのライフサイクル管理を処理するため、構造化ストリーミングコードを直接記述する必要はありません。
RabbitMQコネクターコンポーネント
コンポーネント | 説明 |
|---|---|
接続 | RabbitMQ ブローカーのブローカーエンドポイントおよび認証資格情報を格納する Unity Catalog セキュリティ保護可能なオブジェクトです。マネージド RabbitMQ コネクタは、この接続を使用して、パイプライン構成で資格情報を必要とせずに認証します。 |
取り込みパイプライン | 1つまたは複数のRabbitMQクラシックキューからメッセージを継続的に消費し、その結果をストリーミングテーブルに書き込むパイプラインです。パイプラインはサーバレスコンピュートで実行されます。 |
宛先テーブル | 取り込み パイプラインがデータを書き込むストリーミングテーブル。 |
RabbitMQから取り込みを開始してください
次の表は、ユーザータイプに基づいたエンドツーエンドのRabbitMQ取り込みフローの概要を示しています。
ユーザー | ステップ |
|---|---|
管理 | Catalog Explorer を使用して接続を作成することで、 |
管理者以外 | サポートされている任意のインターフェイスを使用して、既存の接続からパイプラインを作成します。「RabbitMQ からのデータを取り込む」を参照してください。 |
機能の利用可能状況
機能 | 可用性 |
|---|---|
UI ベースのパイプライン オーサリング |
|
API ベースのパイプライン オーサリング |
|
宣言型オートメーションバンドル |
|
継続的ストリーミング取り込み |
|
Unity Catalog ガバナンス |
|
Databricks Workflowsによるオーケストレーション |
|
SCDタイプ2 |
|
列の選択と選択解除 |
|
行フィルター |
|
サポートされていません（ベータ版）
サポートされています認証方法
認証方法 | 可用性 |
|---|---|
ユーザー名とパスワード |
|
サービス資格情報 |
|
OAuth U2M |
|
OAuth M2M |
|