GetElasticsearch 2025.5.31.15

Bundle

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

Beschreibung

Elasticsearch-Get-Prozessor, der die offiziellen Elastic REST-Client-Bibliotheken verwendet, um ein einzelnes Dokument anhand seiner _id aus Elasticsearch abzurufen. Beachten Sie, dass der gesamte Text des Dokuments in den Speicher eingelesen wird, bevor er zur Übertragung in ein FlowFile geschrieben wird.

Tags

elasticsearch, elasticsearch5, elasticsearch6, elasticsearch7, elasticsearch8, index, json, put, record

Eingabeanforderung

ALLOWED

Unterstützt sensible dynamische Eigenschaften

false

Eigenschaften

Eigenschaft

Beschreibung

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-type

Der Typ dieses Dokuments (wird von Elasticsearch für die Indizierung und Suche verwendet).

get-es-attribute-name

Der Name des FlowFile-Attributs, das für die Ausgabe des abgerufenen Dokuments verwendet werden soll.

get-es-destination

Gibt an, ob das abgerufene Dokument in den Inhalt des FlowFile oder in ein FlowFile-Attribut geschrieben wird.

get-es-id

Die _id des abzurufenden Dokuments.

Beziehungen

Name

Beschreibung

Dokument

Abgerufene Dokumente werden an diese Beziehung weitergeleitet.

failure

Alle FlowFiles, die aus Gründen, die nicht mit der Serververfügbarkeit zusammenhängen, fehlschlagen, werden an diese Beziehung weitergeleitet.

not_found

Ein FlowFile wird an diese Beziehung weitergeleitet, wenn das angegebene Dokument nicht im Elasticsearch-Cluster vorhanden ist.

retry

Alle FlowFiles, die aufgrund der Server-/Clusterverfügbarkeit fehlschlagen, werden an diese Beziehung weitergeleitet.

Schreibt Attribute

Name

Beschreibung

filename

Das Attribut „filename“ wird auf den Dokument-Bezeichner gesetzt

elasticsearch.index

Der Elasticsearch-Index, der das Dokument enthält

elasticsearch.type

Der Dokumenttyp von Elasticsearch

elasticsearch.get.error

Die von Elasticsearch gelieferte Fehlermeldung, wenn beim Abrufen des Dokuments ein Fehler auftritt.

Siehe auch: