使用 NiFi 使用 QueryDatabase 表获取记录时限制行

Question

我正在尝试通过 Apache NiFi 使用 QueryDatabase 处理器 有什么方法可以限制记录，例如：“select * from table limit 100”

NiFi 中的任何其他处理器支持此操作吗？

Answer 1

在这种情况下使用 ExecuteSQL 处理器。

• 配置/启用 DBCP 连接池

• 在 SQL select query 属性值中保留您的选择查询

  select * from table limit 100

现在处理器运行配置的sql select查询并将查询结果输出为AVRO格式的流文件