PutMongoRecord 2025.5.31.15¶
Pacote¶
org.apache.nifi | nifi-mongodb-nar
Descrição¶
Esse é um processador com reconhecimento de registros para inserir/executar upsert de dados no MongoDB. Ele usa um Record Reader e esquema configurados para ler um conjunto de registros de entrada do corpo de um FlowFile e, em seguida, insere/executa upsert de lotes desses registros em uma coleção MongoDB configurada. Esse processador não é compatível com exclusões. O número de documentos a serem inseridos/executarem upsert de cada vez é controlado pela propriedade de configuração “Batch Size” (Tamanho do lote). Esse valor deve ser definido como um tamanho razoável para garantir que o MongoDB não seja sobrecarregado com muitas operações ao mesmo tempo.
Requisito de entrada¶
REQUIRED
Oferece suporte a propriedades dinâmicas confidenciais¶
falso
Propriedades¶
Propriedade |
Descrição |
|---|---|
Nome da coleção Mongo |
O nome da coleção a ser usada |
Nome do banco de dados Mongo |
O nome do banco de dados a ser usado |
bypass-validation |
Ativar ou desativar o desvio da validação do esquema do documento durante as operações de inserção ou atualização. Contornar a validação de documentos é uma ação de privilégio no MongoDB. A ativação dessa propriedade pode resultar em erros de autorização para usuários com privilégios limitados. |
insert_count |
O número de registros a serem agrupados para uma única operação de inserção/upsert no MongoDB. |
mongo-client-service |
Se configurada, essa propriedade usará o serviço de cliente atribuído para o pool de conexões. |
ordered |
Realiza operações ordenadas ou não ordenadas |
record-reader |
Especifica o Controller Service a ser usado para analisar os dados recebidos e determinar o esquema de dados |
update-key-fields |
Lista de campos separados por vírgula com base na qual você identifica os documentos que precisam ser atualizados. Se essa propriedade for definida, o NiFi tentará realizar uma operação upsert em todos os documentos. Se essa propriedade não for definida, todos os documentos serão inseridos. |
update-mode |
Escolha entre atualizar um único documento ou vários documentos por registro de entrada. |
Relações¶
Nome |
Descrição |
|---|---|
failure |
Todos os FlowFiles que não podem ser gravados no MongoDB são roteados para essa relação |
success |
Todos os FlowFiles que são gravados no MongoDB são roteados para essa relação |