首页 > 解决方案 > apache NIFI ScrollElasticsearchHttp 过滤掉具有空字段的记录

问题描述

我正在尝试构建一个 ScrollElasticSearchHttp 处理器,该处理器将查询并过滤掉“描述”字段为空或空的记录

我在这里找到了一个查询来做到这一点,当我使用 POST 而不是 GET 时,它在 REST API 客户端中对我有用。 https://www.elastic.co/guide/en/elasticsearch/reference/current/query-dsl-exists-query.html 当我使用 URL 进行查询(https://. ../_search?q=(user%20is%20not%20null)

我应该在 nifi ScrollElasticSearchHttp 处理器配置属性查询中放入什么查询行,以像在浏览器或 REST API 客户端中一样执行相同的操作?

谢谢。

标签: elasticsearchfilternullfieldapache-nifi

解决方案


ScrollElasticSearchHttp处理器的参数query采用 Lucene 查询语法。请参阅文档

在此处查看有关 Lucene 语法的 Elastic 文档

此页面not null演示了with 的查询_exists_

所以你可以_exists_:description用来得到结果 where descriptionisnot null

这个 SO 答案为我指明了正确的方向


推荐阅读