DeleteByQueryElasticsearch 2025.5.31.15¶

Bundle¶

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

Löscht aus einem Elasticsearch-Index mithilfe einer Abfrage. Die Abfrage kann aus einem FlowFile-Body oder aus dem Abfrageparameter geladen werden.

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

ALLOWED

false

Eigenschaft	Beschreibung
Max JSON Field String Length	Die maximal zulässige Länge eines Zeichenfolgenwertes bei der Analyse eines JSON-Dokuments oder -Attributs.
el-abfrage-attribut	Wenn diese Option gesetzt ist, wird die ausgeführte Abfrage auf jedes Ergebnis-Flowfile im angegebenen Attribut gesetzt.
el-rest-client-service	Ein Elasticsearch-Clientdienst, der für Abfragen verwendet wird.
el-rest-fetch-index	Der Name des zu verwendenden Indexes.
el-rest-query	Eine Abfrage in JSON-Syntax, nicht in Lucene-Syntax. Beispiel: {„query“:{„match“:{„somefield“:“somevalue“}}}. Wenn dieser Parameter nicht gesetzt ist, wird die Abfrage aus dem FlowFile-Inhalt gelesen. Wenn die Abfrage (Eigenschaft und FlowFile-Inhalt) leer ist, wird ein leeres JSON-Standardobjekt verwendet, was zu einer „match_all“-Abfrage in Elasticsearch führt.
el-rest-query-clause	Eine „Abfrage“-Klausel in JSON-Syntax, nicht in Lucene-Syntax. Beispiel: {„match“:{„somefield“:“somevalue“}}. Wenn die Abfrage leer ist, wird ein standardmäßiges JSON-Objekt verwendet, was zu einer „match_all“-Abfrage in Elasticsearch führt.
el-rest-query-definition-style	Wie die JSON-Abfrage für die Verwendung durch den Prozessor definiert werden soll.
el-rest-type	Der Typ dieses Dokuments (wird von Elasticsearch für die Indizierung und Suche verwendet).

Name	Beschreibung
failure	Wenn die „by query“-Operation fehlschlägt und ein FlowFile gelesen wurde, wird es an diese Beziehung gesendet.
retry	Alle FlowFiles, die aufgrund der Server-/Clusterverfügbarkeit fehlschlagen, werden an diese Beziehung weitergeleitet.
success	Wenn die „by query“-Operation erfolgreich war und ein FlowFile gelesen wurde, wird es diese Beziehung gesendet.

Name	Beschreibung
elasticsearch.delete.took	Die Zeit, die für den Abschluss der Löschoperation benötigt wurde, in Millisekunden.
elasticsearch.delete.error	Die von Elasticsearch gelieferte Fehlermeldung, wenn bei der Ausführung des Löschvorgangs ein Fehler auftritt.