Блог

Я хочу выполнить 5 CREATE TABLE операторов SQL в определенном порядке с помощью Apache Nifi. После успешного создания первой таблицы я хочу, чтобы второй процессор создал следующую таблицу и так далее.

Я смог выполнить CREATE инструкции с помощью a PutSQL -processor, но у меня возникли проблемы с запуском его как задания CRON, потому PutSQL что требуется восходящее соединение, которого у меня нет для первого из моих 5 PutSQL -процессоров. Остальные 4 выполняются после завершения предыдущего, что отлично работает.

Есть ли какой-то трюк, чтобы первому PutSQL процессору не требовалось восходящее соединение, или есть «фиктивный» процессор, который я могу использовать для отправки CRON / timed success-message моему первому 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, вы можете использовать GenerateFlowFile в расписании CRON для запуска одного файла потока в определенное время для запуска PutSQL.