PutElasticsearchJson 2025.10.9.21¶
Bundle¶
org.apache.nifi | nifi-elasticsearch-restapi-nar
Beschreibung¶
Ein Elasticsearch-Put-Prozessor, der die offiziellen Elastic REST-Clientbibliotheken verwendet. Jedes FlowFile wird als Dokument behandelt, das an die Elasticsearch _bulk-API gesendet wird. Mehrere FlowFiles können in jeder an Elasticsearch gesendeten Anfrage zusammengefasst werden.
Eingabeanforderung¶
REQUIRED
Unterstützt sensible dynamische Eigenschaften¶
false
Eigenschaften¶
Eigenschaft |
Beschreibung |
|---|---|
Batch Size |
Die bevorzugte Anzahl von FlowFiles, die in einem einzigen Batch übertragen werden soll |
Zeichensatz |
Gibt den Zeichensatz der Dokumentdaten an. |
Client Service |
Ein Elasticsearch-Clientdienst, der für Abfragen verwendet wird. |
Dynamic Templates |
Die dynamic_templates für das Dokument. Muss als JSON-Objekt geparst werden können. Erfordert Elasticsearch 7+ |
Identifier Attribute |
Der Name des FlowFile-Attributs, das den Bezeichner für das Dokument enthält. Wenn die Index-Operation „index“ lautet, kann diese Eigenschaft leer gelassen werden oder einen leeren Wert ergeben. In diesem Fall wird der Bezeichner des Dokuments automatisch von Elasticsearch generiert. Bei allen anderen Indexoperationen muss das Attribut einen nicht leeren Wert ergeben. |
Index |
Der Name des zu verwendenden Indexes. |
Index Operation |
Der Typ der Operation, der für die Indizierung verwendet wird (Erstellen, Löschen, Indizieren, Aktualisieren, Upsert) |
Log Error Responses |
Wenn dies aktiviert ist, werden Fehler in den NiFi-Protokollen auf der Ebene des Fehlerprotokolls protokolliert. Andernfalls werden sie nur protokolliert, wenn die Debug-Protokollierung für NiFi insgesamt aktiviert ist. Der Zweck dieser Option ist es, dem Benutzer die Möglichkeit zu geben, fehlgeschlagene Operationen zu debuggen, ohne die Debug-Protokollierung einschalten zu müssen. |
Max JSON Field String Length |
Die maximal zulässige Länge eines Zeichenfolgenwertes bei der Analyse eines JSON-Dokuments oder -Attributs. |
Output Error Responses |
Wenn dies aktiviert ist, werden Antwortmeldungen von Elasticsearch, die als „Fehler“ markiert sind, an die Beziehung „error_responses“ ausgegeben. Dies hat keinen Einfluss auf die Ausgabe von Flowfiles an die Beziehungen „erfolgreich“ oder „Fehler“. |
Script |
Das Skript für die Aktualisierung/das Upsert von Dokumenten. Gilt nur für Update-/Upsert-Operationen. Muss als JSON-Objekt geparst werden können. Wenn Sie das Feld leer lassen, wird der Inhalt des FlowFile für die Aktualisierung/das Update des Dokuments verwendet |
Scripted Upsert |
Whether to add the scripted_upsert flag to the Upsert Operation. If true, forces Elasticsearch to execute the Script whether or not the document exists, defaults to false. If the Upsert Document provided (from FlowFile content) will be empty, but sure to set the Client Service controller service’s Suppress Null and Empty Values to Never Suppress or no „upsert“ doc will be, included in the request to Elasticsearch and the operation will not create a new document for the script to execute against, resulting in a „not_found“ error |
Treat Not Found as Success |
Wenn „true“, werden „not_found“-Datensätze des zugehörigen Elasticsearch-Dokuments an die Beziehung „successful“ weitergeleitet, andernfalls an die Beziehung „errors“. Wenn „Output Error Responses“ „true“ ist, werden „not_found“-Antworten von Elasticsearch an die Beziehung „error_responses“ gesendet. |
Typ |
Der Typ dieses Dokuments (wird von Elasticsearch für die Indizierung und Suche verwendet). |
Beziehungen¶
Name |
Beschreibung |
|---|---|
Fehler |
Datensätze/Flowfile(s), die Elasticsearch-Dokumenten entsprechen, die zu einem „error“ (innerhalb von Elasticsearch) geführt haben, werden hierher weitergeleitet. |
failure |
Alle FlowFiles, die aus Gründen, die nicht mit der Serververfügbarkeit zusammenhängen, fehlschlagen, werden an diese Beziehung weitergeleitet. |
original |
Alle FlowFiles, die ohne Anfragefehler an Elasticsearch gesendet werden, gehen an diese Beziehung. |
retry |
Alle FlowFiles, die aufgrund der Server-/Clusterverfügbarkeit fehlschlagen, werden an diese Beziehung weitergeleitet. |
successful |
Datensätze/Flowdateien, die Elasticsearch-Dokumenten entsprechen, die keinen „Fehler“ (innerhalb von Elasticsearch) verursacht haben, werden hierher weitergeleitet. |
Schreibt Attribute¶
Name |
Beschreibung |
|---|---|
elasticsearch.put.error |
Die Fehlermeldung, wenn es ein Problem beim Parsen des FlowFile, beim Senden des geparsten Dokuments an Elasticsearch oder beim Parsen der Elasticsearch-Antwort gibt |
elasticsearch.bulk.error |
Die _bulk-Antwort, wenn bei der Verarbeitung des Dokuments in Elasticsearch ein Fehler aufgetreten ist. |