PutMongoRecord 2025.5.31.15¶

Bundle¶

org.apache.nifi | nifi-mongodb-nar

Description¶

Ce processeur est un processeur d’enregistrement pour l’insertion/la réinsertion de données dans MongoDB. Il utilise un Record Reader et un schéma configurés pour lire un ensemble d’enregistrements entrants à partir du corps d’un FlowFile, puis insère/met à jour par lots ces enregistrements dans une collection MongoDB configurée. Ce processeur ne prend pas en charge les suppressions. Le nombre de documents à insérer/supprimer à la fois est contrôlé par la propriété de configuration « Batch Size ». Cette valeur doit être paramétrée à une taille raisonnable afin que MongoDB ne soit pas surchargé par un trop grand nombre d’opérations à la fois.

Balises¶

insert, mongodb, put, record, update, upsert

Exigences en matière d’entrées¶

REQUIRED

Prend en charge les propriétés dynamiques sensibles¶

false

Propriétés¶

Propriété	Description
Mongo Collection Name	Nom de la collection à utiliser
Mongo Database Name	Nom de la base de données à utiliser
bypass-validation	Activer ou désactiver le contournement de la validation du schéma du document lors des opérations d’insertion ou de mise à jour. Le contournement de la validation des documents est une action de privilège dans MongoDB. L’activation de cette propriété peut entraîner des erreurs d’autorisation pour les utilisateurs ayant des privilèges limités.
insert_count	Le nombre d’enregistrements à regrouper pour une seule opération d’insertion/upsert sur MongoDB.
mongo-client-service	Si cette propriété est configurée, elle utilisera le service client attribué pour le pooling de connexions.
ordered	Effectuer des opérations ordonnées ou non ordonnées
record-reader	Spécifie le Controller Service à utiliser pour analyser les données entrantes et déterminer le schéma des données
update-key-fields	Liste de champs séparés par des virgules permettant d’identifier les documents à mettre à jour. Si ce paramètre est défini, NiFi tentera une opération d’upsert sur tous les documents. Si cette propriété n’est pas paramétrée, tous les documents seront insérés.
update-mode	Vous avez le choix entre la mise à jour d’une seule documentation ou de plusieurs documents par enregistrement entrant.

Relations¶

Nom	Description
failure	Tous les FlowFiles qui ne peuvent pas être écrits dans MongoDB sont routés vers cette relation
success	Tous les FlowFiles qui sont écrits dans MongoDB sont routés vers cette relation