#apache-nifi
#apache-nifi
Вопрос:
У меня есть CREATE TABLE
SQL-скрипт в a PutSQL
-Processor.
До сих пор я не нашел другого способа установить SQL-скрипт, кроме как сделать это вручную. Есть ли возможность автоматически получать и устанавливать SQL-скрипт для процессора во время выполнения?
Мой идеальный процесс выглядел бы так:
- Сообщение об успешном завершении предыдущего процессора
- Получить SQL-файл из определенной ветки GitHub (или из локального файла) и вставить его в PutSQL-processor
- Запустите PutSQL-processor
Ответ №1:
По умолчанию PutSQL считывает содержимое входящего потокового файла в качестве команды SQL для запуска.
Таким образом, вы можете использовать InvokeHTTP для извлечения файла через HTTP, или GetFile для получения локального файла из файловой системы, или ListFTP FetchFTP для получения файла с FTP.
Пока содержимое файла является допустимыми инструкциями SQL, вы можете отправить это прямо в PutSQL, и он запустит SQL.