sql - Apache Nifi 中的 ExecuteSQL 处理器

Question

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

Answer 1

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

话虽这么说... ExecuteSQL 支持由传入的流文件触发，因此您可以做一些事情，例如在 ExecuteSQL 前面放置一个 ListenHTTP 处理器，并且每当您想触发它时，您都可以调用 ListenHTTP 的 http 端点。这样你就可以让它继续运行，但它只会在你想要的时候被触发。