UpdateByQueryElasticsearch 2025.5.31.15¶

Bundle¶

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

Beschreibung¶

Aktualisieren Sie Dokumente in einem Elasticsearch-Index mithilfe einer Abfrage. Die Abfrage kann aus einem FlowFile-Body oder aus dem Abfrageparameter geladen werden. Die geladene Abfrage kann alle von der API „_update_by_query“ von Elasticsearch akzeptierten JSON-Daten enthalten, beispielsweise ein „query“-Objekt zur Identifizierung der zu aktualisierenden Dokumente sowie ein „script“ zur Definition der durchzuführenden Aktualisierungen.

Tags¶

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

Eingabeanforderung¶

ALLOWED

Unterstützt sensible dynamische Eigenschaften¶

false

Eigenschaften¶

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-script	Ein „Skript“, das während der Operation ausgeführt wird, in der JSON-Syntax. Bsp.: {„source“: „ctx._source.count++“, „lang“: „painless“}
el-rest-type	Der Typ dieses Dokuments (wird von Elasticsearch für die Indizierung und Suche verwendet).

Beziehungen¶

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.

Schreibt Attribute¶

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