GetMongoRecord 2025.5.31.15

Bundle

org.apache.nifi | nifi-mongodb-nar

Description

Une version de GetMongo basée sur les enregistrements qui utilise les Record Writers pour écrire le jeu de résultats de MongoDB.

Balises

fetch, get, json, mongo, mongodb, record

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 à renvoyer du serveur en un seul lot

Limit

Le nombre maximum d’éléments à renvoyer

Mongo Collection Name

Nom de la collection à utiliser

Mongo Database Name

Nom de la base de données à utiliser

Projection

Les champs à renvoyer à partir des documents du jeu de résultats ; il doit s’agir d’un document BSON valide

Requête

Les critères de sélection pour effectuer la recherche. Si le champ n’est pas renseigné, une connexion entrante provenant d’un autre processeur sera recherchée pour fournir la requête sous la forme d’un document JSON valide dans le corps du FlowFile. Si ce champ n’est pas renseigné et qu’un temporisateur est activé au lieu d’une connexion entrante, le résultat sera une requête « {} » pour l’ensemble de la collection.

Trier

Les champs par lesquels le tri doit être effectué ; il doit s’agir d’un document BSON valide

get-mongo-record-writer-factory

Le Record Writer à utiliser pour écrire les jeux de résultats.

mongo-client-service

Si cette propriété est configurée, elle utilisera le service client attribué pour le pooling de connexions.

mongo-query-attribute

Si cette valeur est définie, la requête sera écrite dans un attribut spécifié dans les FlowFiles de sortie.

mongodb-schema-name

Le nom du schéma du registre de schémas configuré à utiliser pour les résultats de la requête.

Relations

Nom

Description

failure

Tous les FlowFiles en entrée qui font partie de l’exécution d’une requête qui a échoué sont placés ici.

original

Tous les FlowFiles en entrée qui font partie de l’exécution réussie d’une requête sont placés ici.

success

Tous les FlowFiles qui contiennent les résultats de l’exécution réussie d’une requête sont placés ici.

Écrit les attributs

Nom

Description

mongo.database.name

La base de données d’où proviennent les résultats.

mongo.collection.name

La collection d’où proviennent les résultats.