如何用Apache NiFi的PutElasticsearchHttp处理器删除Elasticsearch数据？

1. 使用PutElasticsearchHttp处理器删除数据的可行性及配置 #

可以使用该处理器实现删除操作，报错通常是配置缺失导致，正确配置步骤如下：

• 核心参数设置：将Index Operation设为delete
• 必填文档ID：在Document ID属性中指定要删除的Elasticsearch文档ID，可通过NiFi表达式语言从FlowFile属性或内容中提取，例如${ff_attr.document_id}（假设FlowFile有document_id属性）
• 索引与类型配置：
  • 填写Index Name为目标索引名（支持表达式）
  • 若Elasticsearch版本为7.x及以上，Type Name填_doc（ES7+已移除自定义类型）
• URL与权限检查：
  • 确保Elasticsearch URL填写正确的远程集群地址（如http://your-es-host:9200）
  • 确认NiFi服务器能访问该URL，且ES账号具备delete权限（若开启安全认证）
• 请求内容：删除操作无需FlowFile包含内容，空内容即可被ES正确处理

常见报错原因：未指定Document ID导致ES无法定位文档；索引名/类型配置错误；权限不足；ES版本与处理器版本不兼容（如ES8+需配置HTTPS及API Key）

2. 替代处理器：DeleteElasticsearchHttp的配置 #

若PutElasticsearchHttp仍无法满足需求，可使用专门的DeleteElasticsearchHttp处理器，配置要点：

• 基础连接：Elasticsearch URL填写远程ES集群地址
• 目标定位：
  • Index Name指定要操作的索引
  • Document ID必填，通过表达式指定要删除的文档ID
• 安全配置：
  • 若ES开启用户名密码认证，填写Username和Password
  • 若使用API Key认证，配置API Key属性
  • 若为HTTPS连接，需关联SSL Context Service并配置证书
• 批量操作：若需批量删除，可设置Batch Size，并确保FlowFile中包含多个文档ID的结构化数据（如JSON数组）

额外：使用PutElasticsearchHttp实现更新操作 #

将Index Operation设为update，配合以下配置：

• 指定Document ID以定位要更新的文档
• FlowFile内容为更新后的文档JSON数据
• 可选配置Update Strategy为upsert，实现“存在则更新，不存在则插入”的逻辑

内容的提问来源于stack exchange，提问作者just learner