RunMongoAggregation 2025.5.31.15¶

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 MongoDBrenvoie « extended JSON ». Certaines fonctions de cette variante de JSON peuvent poser des problèmes à d’autres analyseurs JSON qui n’attendent que les types et conventions standard de JSON. Ce paramètre de configuration permet de déterminer s’il convient d’utiliser la version étendue de JSON ou de fournir une vue propre conforme à la version standard de JSON.
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.