PutElasticsearchRecord 2025.10.9.21¶

Batch Size

Nombre d’enregistrements à envoyer en un seul lot.

Format de date

Spécifie le format à utiliser lors de la rédaction des champs Date. S’il n’est pas spécifié, le format par défaut “aaaa-MM-dd” est utilisé. Si elle est spécifiée, la valeur doit correspondre au format de date simple de Java (par exemple, MM/jj/aaaa pour un mois à deux chiffres, suivi d’un jour à deux chiffres, suivi d’une année à quatre chiffres, tous séparés par des caractères “/”, comme dans 01/25/2017).

Regrouper les résultats par type d’erreur de lot

The errored records written to the « errors » relationship will be grouped by error type and the error related to the first record within the FlowFile added to the FlowFile as « elasticsearch.bulk.error ». If « Treat Not Found as Success » is « false » then records associated with « not_found » Elasticsearch document responses will also be send to the « errors » relationship.

Index

Le nom de l’index à utiliser.

Chemin d’enregistrement de l’opération d’index

Une expression de chemin d’enregistrement pour récupérer le champ Opération d’index pour une utilisation avec Elasticsearch. Si elle est laissée vide, l’opération d’indexation sera déterminée à l’aide de la propriété principale d’opération d’indexation.

Log Error Responses

Si cette option est activée, les erreurs seront consignées dans les journaux NiFi au niveau “error”. Sinon, elles ne seront connectées que si la connexion de débogage est activée sur NiFi dans son ensemble. L’objectif de cette option est de donner à l’utilisateur la possibilité de déboguer les opérations qui ont échoué sans avoir à activer la connexion de débogage.

Output Error Responses

Si cette option est activée, les messages de réponse provenant d’Elasticsearch marqués comme « erreurs » seront envoyés vers la relation « error_responses ». Cela n’a pas d’incidence sur la sortie des fichiers de flux vers les relations « successful » ou « errors ».

Result Record Writer

La réponse d’Elasticsearch sera examinée pour détecter les enregistrements défaillants et ces derniers seront écrits dans un ensemble d’enregistrements avec ce service Record Writer et envoyés dans la relation « errors ». Les enregistrements réussis seront écrits dans un ensemble d’enregistrements avec ce service de rédaction d’enregistrements et envoyés à la relation « réussi ».

Retain Record Timestamp

Indique s’il faut conserver le champ existant utilisé comme chemin d’enregistrement pour le @timestamp.

Chemin d’upsert scripté des enregistrements

A RecordPath pointing to a field in the record(s) that contains the scripted_upsert boolean flag. Whether to add the scripted_upsert flag to the Upsert Operation. 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

Timestamp Format

Spécifie le format à utiliser lors de l’écriture des champs horodatage. S’il n’est pas spécifié, le format par défaut “aaaa-MM-dd HH: mm:ss” est utilisé. Si elle est spécifiée, la valeur doit correspondre au format de date simple de Java (par exemple, MM/jj/aaaa HH:mm:ss pour un mois à deux chiffres, suivi d’un jour à deux chiffres, suivi d’une année à quatre chiffres, tous séparés par des caractères “/” ; puis suivi d’une heure à deux chiffres au format 24 heures, suivie d’une minute à deux chiffres, suivie d’une seconde à deux chiffres, tous séparés par des caractères “:”, comme dans 01/25/2017 18:04:15).

Valeur d’horodatage

La valeur à utiliser comme champ @timestamp (exigence pour les flux de données Elasticsearch)

Type

Le type de ce document (utilisé par Elasticsearch pour l’indexation et la recherche).

errors

Enregistrements/FlowFiles correspondant à des documents Elasticsearch ayant entraîné une réponse « error » (au sein d’Elasticsearch) seront routés ici.

original

Tous les flowfiles qui sont envoyés à Elasticsearch sans échec de requête vont dans cette relation.

successful

Les enregistrements/fichiers de flux correspondant aux documents Elasticsearch qui n’ont pas donné lieu à une « erreur » (au sein d’Elasticsearch) seront routés ici.

elasticsearch.put.error

Le message d’erreur en cas de problème lors de l’analyse des enregistrements FlowFile, de l’envoi des documents analysés à Elasticsearch ou de l’analyse de la réponse d’Elasticsearch.

elasticsearch.put.success.count

Le nombre d’enregistrements qui ont été traités avec succès par la recherche Elastic _bulk API.