UpdateByQueryElasticsearch 2025.5.31.15¶

Bundle¶

org.apache.nifi | nifi-elasticsearch-restapi-nar

Description¶

Met à jour les documents d’un index Elasticsearch à l’aide d’une requête. La requête peut être chargée à partir d’un corps de FlowFile ou du paramètre Requête. La requête chargée peut contenir tout JSON accepté par l’API _update_by_query d’Elasticsearch API, par exemple un objet query pour identifier quels documents doivent être mis à jour, plus un script pour définir les mises à jour à effectuer.

Balises¶

elastic, elasticsearch, elasticsearch5, elasticsearch6, elasticsearch7, elasticsearch8, query, update

Exigences en matière d’entrées¶

ALLOWED

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

false

Propriétés¶

Propriété	Description
Max JSON Field String Length	Longueur maximale autorisée pour une valeur de chaîne lors de l’analyse d’un document ou d’un attribut JSON.
el-query-attribute	Si l’option est activée, la requête exécutée sera définie sur chaque FlowFile de résultats dans l’attribut spécifié.
el-rest-client-service	Un service client Elasticsearch à utiliser pour l’exécution des requêtes.
el-rest-fetch-index	Le nom de l’index à utiliser.
el-rest-query	Requête dans la syntaxe JSON et non dans la syntaxe Lucene. Ex : {« query »:{« match »:{« somefield »: »somevalue »}}}. Si ce paramètre n’est pas défini, la requête sera lue à partir du contenu du FlowFile. Si la requête (propriété et contenu du FlowFile) est vide, un objet JSON vide par défaut sera utilisé, ce qui aboutira à une requête « match_all » dans Elasticsearch.
el-rest-query-clause	Clause « query » dans la syntaxe JSON et non dans la syntaxe Lucene. Ex : {« match »:{« somefield »: »somevalue »}}. Si la requête est vide, un objet JSON par défaut sera utilisé, ce qui aboutira à une requête « match_all » dans Elasticsearch.
el-rest-query-definition-style	Manière dont la requête JSON sera définie pour être utilisée par le processeur.
el-rest-script	Un « script » à exécuter pendant l’opération, dans la syntaxe JSON. Exemple : {« source »: « ctx._source.count++ », « lang »: « painless »}
el-rest-type	Le type de ce document (utilisé par Elasticsearch pour l’indexation et la recherche).

Relations¶

Nom	Description
failure	Si l’opération « by query » échoue et qu’un FlowFile a été lu, il sera envoyé à cette relation.
retry	Tous les FlowFiles qui échouent en raison de la disponibilité du serveur/cluster sont dirigés vers cette relation.
success	Si l’opération « by query » réussit et qu’un FlowFile a été lu, il sera envoyé à cette relation.

Écrit les attributs¶

Nom	Description
elasticsearch.update.took	Temps nécessaire à la réalisation de l’opération de mise à jour, en ms.
elasticsearch.update.error	Le message d’erreur fourni par Elasticsearch en cas d’erreur d’exécution de la mise à jour.