apache-nifi - 将 SQL 脚本插入 PutSQL 处理器

Question

我在-Processor中有一个CREATE TABLESQL 脚本。PutSQL

到目前为止，除了手动设置 SQL 脚本之外，我还没有确定其他方法。是否有一个选项可以在运行时自动获取和设置处理器的 SQL 脚本？

我理想的过程是这样的：

1. 前一个处理器的成功消息
2. 从特定的 GitHub 分支（或本地文件）获取 SQL 文件并将其插入到 PutSQL 处理器中
3. 运行 PutSQL 处理器

Answer 1

默认情况下，PutSQL 读取传入 FlowFile 的内容作为要运行的 SQL 命令。

因此，您可以使用 InvokeHTTP 通过 HTTP 拉取文件，或使用 GetFile 从文件系统获取本地文件，或使用 ListFTP+FetchFTP 从 FTP 获取文件。

只要文件的内容是有效的 SQL 语句，您就可以将其直接发送到 PutSQL，它将运行 SQL。