Apache Nifi 中的 ExecuteSQL 处理器

Question

我在使用 Apache Nifi 时遇到问题。有没有办法在 ExecuteSQL 处理器完成提取表中的所有数据后停止它，而不是重复提取直到我手动停止它？

Answer 1

通常，处理器旨在通过其调度选项卡按某个频率进行调度。图表中间的具有传入关系的处理器通常将其调度保留在 0 秒，这意味着当数据排队时会尽可能快地运行。源处理器通常基于 Timer Driver 或 Cron Driven 调度以某个间隔运行。

话虽如此... ExecuteSQL 支持由传入的流文件触发，因此您可以执行诸如在 ExecuteSQL 前面放置一个 ListenHTTP 处理器之类的操作，并且无论何时要触发它，您都可以调用 http 端点对于ListenHTTP。这样你可以让它继续运行，但它只会在你想要的时候触发。