NiFi-1.0.0 - ExecuteSQL，事件驱动

Question

我有一个 NiFi 流，它将一些数据插入到一些表中。在我向表中插入一些数据后，我发送一个信号，然后 ExecuteSQL 在该表上运行一个聚合查询。表名基于文件名。

问题是当 ExecuteSQL 运行查询时，我只得到结果的一个子集。如果我在数据库的控制台中运行相同的查询，我会得到不同数量的返回行。

这可能是与事件驱动调度策略有关的问题吗？

如果 ExecuteSQL 停止，并且我在 ExecuteSQL 的队列中获取流文件（信号），然后我手动启动 ExecuteSQL，我会得到预期的结果。

Answer 1

如果您正在运行多个插入（例如使用 PutSQL）并且希望仅在所有插入完成后运行 ExecuteSQL，并且它们完成的顺序不确定，您可以尝试以下两种方法之一：

• MergeContent - 在 PutSQL 之后使用 MergeContent 处理器，设置最小条目数和/或最大 Bin Age 以在插入完成时触发。您可以将合并的关系路由到 ExecuteSQL。

• MonitorActivity - 使用 MonitorActivity 处理器监控来自 PutSQL 的输出流，并在配置的时间段后触发非活动警报。您可以将非活动关系路由到 ExecuteSQL 以运行聚合查询。