RabbitMQ コネクタ リファレンス

備考

ベータ版

この機能はベータ版です。ワークスペース管理者は、 プレビュー ページからこの機能へのアクセスを制御できます。Databricksのプレビューを管理するを参照してください。

このページには、LakeFlow Connectのマネージド RabbitMQ コネクタのリファレンスが含まれています。

コネクターオプション

次のオプションで、取り込みパイプライン内の各送信先テーブルの RabbitMQ ソースを構成します。パイプライン定義の connector_options.rabbitmq_options で、これらのオプションを指定してください。完全なパイプラインの例については、「例」を参照してください。

オプション	Type	デフォルト	説明
queue	String	—	(必須) 消費元のRabbitMQクラシックキューの名前

接続プロパティ

カタログエクスプローラで Unity Catalog RabbitMQ 接続を作成するときは、次のプロパティを指定する必要があります。接続作成のステップについては、RabbitMQ 接続を作成するを参照してください。

属性	説明
接続名	Unity Catalog内の接続の一意の名前。
接続タイプ	RabbitMQ を選択してください。
ホスト	RabbitMQブローカーのホスト名。
ユーザー名	RabbitMQ ブローカーとの認証に使用されるユーザー名。
パスワード	RabbitMQブローカーでの認証に使用されるパスワードです。
仮想ホスト	RabbitMQブローカーの仮想ホスト。デフォルトの仮想ホストは/です。
ポート	RabbitMQブローカーのポートです。デフォルトのポートは 5672です。

宛先テーブルスキーマ

RabbitMQ コネクタはストリーミングテーブル（追記専用）に書き込みます。各宛先テーブルには、デコードされたメッセージ本文とRabbitMQメタデータ列、および肯定応答の失敗後に再配信されたメッセージに対してtrueである_redelivered列が含まれています。