ScrollElasticsearchHttp处理器计数在Nifi

Question

我正在尝试简单计数"ScrollElasticsearchHttp"nifi中的处理器。并在此处理器之后使用QueryRecord。我已经创建了一个新的变量和使用下面Sql

"select count(1) from FLOFILE"

我在等待结果。计数值10000，这是我的记录计数，但它总是显示记录。1.

有人可以建议我应该如何采取这个ScrollElasticsearchHttp流计数。

谢谢! !

Answer 1

ScrollElasticsearchHttp文档处理器:

返回结果的每一页，包装在JSON对象中，如下所示:: [，，]}.

首先使用EvaluateJsonPath处理器:

• Destination:flowfile-content
• Return Type:auto-detect
• hits(dynamic):$.hits

然后使用QueryRecord处理器:

• count:SELECT COUNT(1) AS COUNT FROM FLOWFILE