使用 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格式输出