PutElasticsearchRecord 2025.10.9.21¶

批处理大小

单批发送的记录数。

日期格式

指定写入“Date”字段时使用的格式。如果未指定，则使用默认格式“yyyy-MM-dd”。如果已指定，则该值必须与 Java 简单日期格式相匹配（例如，MM/dd/yyyy 表示两位数月份，后面依次是两位数日期、四位数年份，全部由“/”字符分隔，如 01/25/2017）。

按批量错误类型对结果进行分组

写入到“errors”关系的错误记录将按错误类型分组，与 FlowFile 中第一条记录相关的错误将作为“elasticsearch.bulk.error”添加到 FlowFile 中。如果“Treat Not Found as Success”为“false”，则与“not_found”Elasticsearch 文档响应相关的记录也将发送到“errors”关系。

索引

要使用的索引的名称。

索引操作记录路径

用于检索“Index Operation”字段以供 Elasticsearch 使用的记录路径表达式。如果留空，将使用主索引操作属性来确定索引操作。

日志错误响应

如果启用了此属性，则将在错误日志级别将错误记录到 NiFi 日志中。否则，只有在 NiFi 上整体启用调试日志记录时，才会记录错误。此选项的目的是，使用户能够在不必打开调试日志记录的情况下调试失败的操作。

输出错误响应

如果启用此选项，则来自 Elasticsearch 的标记为“error”的响应消息将输出到“error_responses”关系。这不会影响 Flowfile 输出到“successful”或“errors”关系

结果记录编写器

将检查 Elasticsearch 的响应中是否存在失败的记录，将使用此记录写入器服务将失败的记录写入到记录集并发送到“errors”关系中。将使用此记录写入器服务将成功的记录写入到记录集，并发送到“successful”关系。

保留记录时间戳

是否保留用作 @timestamp 记录路径的现有字段。

脚本化更新插入记录路径

RecordPath 用于指向记录中包含 scripted_upsert 布尔标志的字段。是否将 scripted_upsert 标志添加到更新插入操作中。无论文档是否存在，都强制 Elasticsearch 执行脚本，默认值为 false。如果提供的更新插入文档（来自 FlowFile 内容）为空，请务必将客户端服务控制器服务的“Suppress Null and Empty Values”设置为“Never Suppress”，否则发送到 Elasticsearch 的请求中将不包含“upsert”文档，该操作不会创建新文档供脚本执行，最终将导致“not_found”错误

时间戳格式

指定写入“Timestamp”字段时使用的格式。如果未指定，则使用默认格式“yyyy-MM-dd HH:mm:ss”。如果指定，则该值必须与 Java 简单日期格式相匹配（例如，MM/dd/yyyy HH:mm:ss 表示两位数月份，后面依次是两位数日期、四位数年份，全部由“/”字符分隔；再后面依次是 24 小时格式的两位数小时、两位数分钟和两位数秒钟，全部由“:”字符分隔，如 01/25/2017 18:04:15）。

时间戳值

用作 @timestamp 字段的值（Elasticsearch 数据流的必填项）

类型

此文档的类型（由 Elasticsearch 用于建立索引和执行搜索）。

errors

与导致“error”（在 Elasticsearch 中）的 Elasticsearch 文档对应的记录/FlowFile 将路由到此处。

original

在没有请求失败的情况下发送到 Elasticsearch 的所有 FlowFile 都将转到此关系。

successful

与未导致“error”（在 Elasticsearch 中）的 Elasticsearch 文档对应的记录/FlowFile 将路由到此处。

elasticsearch.put.error

如果在解析 FlowFile 记录、将已解析的文档发送到 Elasticsearch 或解析 Elasticsearch 响应时出现问题，则显示此错误消息。

elasticsearch.put.success.count

由 Elasticsearch _bulk API 成功处理的记录数。