DeleteByQueryElasticsearch 2025.5.31.15¶

Bundle¶

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

Description¶

Effectuer une suppression 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.

Balises¶

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

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-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.delete.took	Temps qu’il a fallu pour effectuer l’opération de suppression, en ms.
elasticsearch.delete.error	Message d’erreur fourni par Elasticsearch en cas d’erreur lors d’exécution de la suppression.