将 SQL 脚本插入 PutSQL-处理器

Question

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

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

我理想的流程是这样的：

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

Answer 1

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

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

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