Referência do conector RabbitMQ
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 |
|---|---|---|---|
| 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 é |
Esquema da tabela de destino
O conector RabbitMQ grava em tabelas de transmissão (somente anexadas). Cada tabela de destino contém o corpo da mensagem decodificado e as colunas de metadados do RabbitMQ, incluindo uma coluna _redelivered que é true para mensagens que foram reenviadas após uma falha de reconhecimento.