通过 CRON 按顺序执行 SQL CREATE 语句

Executing SQL CREATE statements via CRON in order

我想用 Apache Nifi 按特定顺序执行 5 SQL CREATE TABLE 语句。成功创建第一个 table 后,我希望第二个处理器创建下一个 table 等等。

我已经能够使用 PutSQL 处理器执行 CREATE 语句,但我无法将其作为 CRON 作业 运行 获取,因为 PutSQL 需要一个上游连接,我的 5 个 PutSQL 处理器中的 first 没有。其他 4 个 运行 在上一个完成后效果很好。

是否有技巧使第一个 PutSQL 处理器不需要上游连接,或者是否有一个“虚拟”处理器可以用来发送 CRON/timed 成功- 消息给我的第一个 PutSQL-处理器然后开始工作?

您可以使用传入关系可选的 ExecuteSQL。

https://nifi.apache.org/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.12.1/org.apache.nifi.processors.standard.ExecuteSQL/index.html

如果你想使用PutSQL,你可以在CRON计划上使用GenerateFlowFile在特定时间踢出单个流文件以触发PutSQL。