RunMongoAggregation 2025.10.2.19¶

Bundle¶

org.apache.nifi | nifi-mongodb-nar

Description¶

Un processeur qui exécute une requête d’agrégation chaque fois qu’il reçoit un FlowFile.

Balises¶

aggregate, aggregation, mongo

Exigences en matière d’entrées¶

ALLOWED

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

false

Propriétés¶

Propriété	Description
Batch Size	Le nombre d’éléments renvoyés par le serveur en un lot.
Mongo Collection Name	Nom de la collection à utiliser
Mongo Database Name	Nom de la base de données à utiliser
allow-disk-use	Définir cette option sur “true” pour activer l’écriture des données dans des fichiers temporaires afin d’éviter de dépasser la limite maximale d’utilisation de la mémoire lors de l’agrégation par étapes lors du traitement de grands ensembles de données.
type JSON	Par défaut, le pilote Java de MongoDB renvoie « extended JSON ». Certaines fonctionnalités de cette variante de JSON peut poser des à d’autres analyseurs JSON qui n’acceptent que les types et conventions JSON standard. Ce paramètre de configuration permet de choisir entre l’utilisation de JSON étendu ou l’affichage d’une vue claire conforme au JSON standard.
mongo-agg-query	La requête d’agrégation à exécuter.
mongo-charset	Spécifie le jeu de caractères des données du document.
mongo-client-service	Si cette propriété est configurée, elle utilisera le service client attribué pour le pooling de connexions.
mongo-date-format	La chaîne de format de date à utiliser pour le formatage des champs Date renvoyés par Mongo. Elle n’est appliquée que lorsque le format de JSON en sortie est paramétré sur Standard JSON.
mongo-query-attribute	Si cette valeur est définie, la requête sera écrite dans un attribut spécifié dans les FlowFiles de sortie.
résultats par FlowFile	Nombre de résultats à introduire simultanément dans un FlowFile. Le corps entier sera traité comme un tableau JSON de résultats.

Relations¶

Nom	Description
failure	Le FlowFile d’entrée est envoyé vers cette relation lorsque la requête échoue.
original	Le FlowFile d’entrée est envoyé vers cette relation lorsque la requête réussit.
results	Le jeu de résultats de l’agrégation sera envoyé à cette relation.