Apache NiFi - общие потоки выполнения?

Question

Я пытаюсь выяснить, возможны ли следующие сценарии:

1. У меня есть сотни таблиц, которые должны использовать один и тот же поток, но с разными интервалами, разными именами исходных хостов и мест назначения? Как построить такой поток? также я не могу понять, как использовать динамические имена хостов / схем / таблиц ...

Мы поддерживаем таблицу со всей этой информацией, но как выполнить ее с NiFi?

Если мне нужно загрузить файл в несколько кластеров (каждая таблица в разных кластерах) параллельно - как этого достичь?

tnx!

Answer 1

Решение, которое я нашел, состоит в том, чтобы использовать внешний график (например, воздушный поток) и использовать процессор ListenHttp. Затем вы можете отправить этому слушателю любые данные, которые хотите проанализировать, и использовать их в качестве параметров / атрибутов в остальной части потока.