ListDatabaseTables 2025.5.31.15

Pacote

org.apache.nifi | nifi-standard-nar

Descrição

Gera um conjunto de FlowFiles, cada um contendo atributos correspondentes a metadados sobre uma tabela de uma conexão de banco de dados. Uma vez que os metadados sobre uma tabela tenham sido obtidos, eles não serão obtidos novamente até que o intervalo de atualização (se definido) tenha decorrido ou até que o estado tenha sido limpo manualmente.

Tags

database, jdbc, list, sql, table

Requisito de entrada

FORBIDDEN

Oferece suporte a propriedades dinâmicas confidenciais

falso

Propriedades

Propriedade

Descrição

list-db-include-count

Se você deve incluir a contagem de linhas da tabela como um atributo FlowFile. Isso afeta o desempenho, pois será gerada uma consulta a banco de dados para cada tabela da lista recuperada.

list-db-refresh-interval

O tempo que deve transcorrer antes de redefinir o estado do processador, fazendo com que todas as tabelas atuais sejam listadas. Durante esse intervalo, o processador pode continuar a ser executado, mas as tabelas que já foram listadas não serão listadas novamente. No entanto, tabelas novas/adicionadas serão listadas à medida que o processador for executado. Um valor zero significa que o estado nunca será redefinido automaticamente; o usuário deve limpar o estado manualmente.

list-db-tables-catalog

O nome de um catálogo a partir do qual as tabelas do banco de dados serão listadas. O nome deve corresponder ao nome do catálogo, pois ele está armazenado no banco de dados. Se a propriedade não for definida, o nome do catálogo não será usado para restringir a pesquisa de tabelas. Se a propriedade for definida como uma cadeia de caracteres vazia, as tabelas sem um catálogo serão listadas.

list-db-tables-db-connection

O Controller Service usado para obter conexão ao banco de dados

list-db-tables-name-pattern

Um padrão para correspondência de tabelas no banco de dados. Em um padrão, “%” significa corresponder a qualquer substring de 0 ou mais caracteres, e “_” significa corresponder a qualquer caractere. O padrão deve corresponder ao nome da tabela conforme está armazenado no banco de dados. Se a propriedade não for definida, todas as tabelas serão recuperadas.

list-db-tables-schema-pattern

Um padrão para correspondência de esquemas no banco de dados. Em um padrão, “%” significa corresponder a qualquer substring de 0 ou mais caracteres, e “_” significa corresponder a qualquer caractere. O padrão deve corresponder ao nome do esquema, conforme armazenado no banco de dados. Se a propriedade não for definida, o nome do esquema não será usado para restringir a pesquisa de tabelas. Se a propriedade for definida como uma cadeia de caracteres vazia, as tabelas sem um esquema serão listadas.

list-db-tables-types

Uma lista de tipos de tabela separados por vírgulas a serem incluídos. Por exemplo, alguns bancos de dados oferecem suporte aos tipos TABLE e VIEW. Se a propriedade não for definida, serão retornadas tabelas de todos os tipos.

record-writer

Especifica o Record Writer a ser usado para criar a listagem. Se não for especificado, será criado um FlowFile para cada entidade listada. Se o Record Writer for especificado, todas as entidades serão gravadas em um único FlowFile em vez de adicionar Rastreamento de entidades atributos aos FlowFiles.

Gerenciamento do estado

Escopos

Descrição

CLUSTER

Depois de realizar uma listagem de tabelas, o carimbo de data/hora da consulta é armazenado. Isso permite que o processador não liste novamente as tabelas na próxima vez em que for executado. A especificação do intervalo de atualização nas propriedades do processador indicará que, quando o processador detectar que o intervalo já passou, o estado será redefinido e as tabelas serão listadas novamente como resultado. Esse processador deve ser executado somente no nó primário.

Relações

Nome

Descrição

success

Todos os FlowFiles que são recebidos são encaminhados para a relação “success”

Grava atributos

Nome

Descrição

db.table.name

Contém o nome de uma tabela de banco de dados da conexão

db.table.catalog

Contém o nome do catálogo ao qual a tabela pertence (pode ser nulo)

db.table.schema

Contém o nome do esquema ao qual a tabela pertence (pode ser nulo)

db.table.fullname

Contém o nome da tabela totalmente qualificado (possivelmente incluindo catálogo, esquema etc.)

db.table.type

Contém o tipo da tabela do banco de dados da conexão. Os tipos típicos são “TABLE”, “VIEW”, “SYSTEM TABLE”, “GLOBAL TEMPORARY”, “LOCAL TEMPORARY”, “ALIAS”, “SYNONYM”

db.table.remarks

Contém o nome de uma tabela de banco de dados da conexão

db.table.count

Contém o número de linhas na tabela

Casos de uso que envolvem outros componentes

Executa uma carga completa de um banco de dados, recuperando todas as linhas de todas as tabelas ou de um conjunto específico de tabelas.