Referência do conector RabbitMQ

info

Beta

Este recurso está em Beta. Os administradores do espaço de trabalho podem controlar o acesso a esse recurso na página Pré-visualizações . Consulte Gerenciar prévias do Databricks.

Esta página contém a documentação de referência para o conector RabbitMQ gerenciado no LakeFlow Connect.

Opções de conector

As seguintes opções configuram a origem do RabbitMQ para cada tabela de destino no pipeline de ingestão. Especifique estas opções em connector_options.rabbitmq_options na definição do pipeline. Consulte Exemplos para obter exemplos completos de pipeline.

Opção	Tipo	Padrão	Descrição
queue	String	—	(Obrigatório) Nome da fila clássica RabbitMQ para consumir.

Opção	Tipo	Padrão	Descrição
queue	String	—	(Obrigatório) Nome da fila clássica RabbitMQ para consumir.

Propriedades de conexão

Ao criar a conexão Unity Catalog RabbitMQ no Catalog Explorer, é necessário especificar as seguintes propriedades. Consulte Criar uma conexão RabbitMQ para os passos de criação de conexão.

Propriedade	Descrição
Nome da conexão	Um nome exclusivo para a conexão do Unity Catalog.
Tipo de conexão	Selecionar **RabbitMQ**.
Host	O hostname do broker RabbitMQ.
Nome de usuário	O nome de usuário usado para autenticar com o broker RabbitMQ.
Senha	A senha usada para autenticar com o broker RabbitMQ.
Host virtual	O host virtual do broker RabbitMQ. O host virtual padrão é /.
Porta	A porta do broker RabbitMQ. A porta default é 5672.

Propriedade	Descrição
Nome da conexão	Um nome exclusivo para a conexão do Unity Catalog.
Tipo de conexão	Selecionar **RabbitMQ**.
Host	O hostname do broker RabbitMQ.
Nome de usuário	O nome de usuário usado para autenticar com o broker RabbitMQ.
Senha	A senha usada para autenticar com o broker RabbitMQ.
Host virtual	O host virtual do broker RabbitMQ. O host virtual padrão é /.
Porta	A porta do broker RabbitMQ. A porta default é 5672.

Esquema da tabela de destino

O conector RabbitMQ grava em tabelas de transmissão (somente de anexo). Por default, cada tabela de destino contém uma única coluna:

Coluna	Tipo	Descrição
body	BINARY	O conteúdo binário bruto do corpo da mensagem RabbitMQ. O conector não decodifica nem desserializa o corpo durante a ingestão. Decodifique-o downstream conforme necessário.

Coluna	Tipo	Descrição
body	BINARY	O conteúdo binário bruto do corpo da mensagem RabbitMQ. O conector não decodifica nem desserializa o corpo durante a ingestão. Decodifique-o downstream conforme necessário.

Incluir metadados de origem

Para também capturar metadados de mensagens do RabbitMQ, defina a opção source_metadata_column em table_configuration da tabela de destino. Quando definido, o conector adiciona uma coluna struct com esse nome ao lado de body, contendo os seguintes campos:

campo	Tipo	Descrição
exchange	STRING	A troca na qual a mensagem foi publicada.
routing_key	STRING	A chave de roteamento com a qual a mensagem foi publicada.
queue	STRING	A fila da qual a mensagem foi consumida.
redelivered	BOOLEAN	true se a mensagem foi reenviada após uma falha no reconhecimento.
message_id	STRING	O ID da mensagem definido pelo produtor, se presente.
correlation_id	STRING	O ID de correlação definido pelo produtor, se presente.
content_type	STRING	O tipo de conteúdo definido pelo produtor, se presente.
content_encoding	STRING	A codificação de conteúdo definida pelo produtor, se presente.
timestamp	BIGINT	O timestamp da mensagem definido pelo produtor, se presente.
headers	MAP<STRING, STRING>	Os cabeçalhos de mensagem definidos pelo produtor, se presentes.

campo	Tipo	Descrição
exchange	STRING	A troca na qual a mensagem foi publicada.
routing_key	STRING	A chave de roteamento com a qual a mensagem foi publicada.
queue	STRING	A fila da qual a mensagem foi consumida.
redelivered	BOOLEAN	true se a mensagem foi reenviada após uma falha no reconhecimento.
message_id	STRING	O ID da mensagem definido pelo produtor, se presente.
correlation_id	STRING	O ID de correlação definido pelo produtor, se presente.
content_type	STRING	O tipo de conteúdo definido pelo produtor, se presente.
content_encoding	STRING	A codificação de conteúdo definida pelo produtor, se presente.
timestamp	BIGINT	O timestamp da mensagem definido pelo produtor, se presente.
headers	MAP<STRING, STRING>	Os cabeçalhos de mensagem definidos pelo produtor, se presentes.

O nome escolhido não deve ser body (a coluna de saída reservada), não deve estar em branco e não deve conter um espaço ou qualquer um dos caracteres ,;{}(), uma nova linha, uma tab ou =. Quando source_metadata_column não está definido, o conector grava apenas a coluna body.

Para um exemplo de pipeline, consulte Pipeline com metadados de origem.