Skip to main content
xtrim
xtrim
Gold ⭐️
November 6, 2019
Solved

Generic Execution Flows

Hi,

 

I'm trying to figure out if the following scenarios are possible:
1. I have hundreds of tables that need to use the same flow, but have different intervals, different source hostnames and destinations?
How to build such a flow?  also I can't figure out how to use dynamic hosts/schemas/table names...

We maintain a table with with all this info but how to execute it with NiFi?
2. If I need to load a file on multiple clusters (each table different clusters) in parallel - how can this be achieved?

 

tnx!

xtrim
xtrimAnswer
Gold ⭐️
November 17, 2019

The solution I found is to use an external schedular (like airflow) and to use ListenHttp processor. Then you can send to that listener any data you wish, parse it, and use it as parameters/attributes in the rest of the flow.

View in thread

2 replies

xtrim
xtrimAuthor
Gold ⭐️
November 12, 2019

So I understand it is not possible to send a parameter via rest api to a flow?

Translate
xtrim
xtrimAuthorAnswer
Gold ⭐️
November 17, 2019

The solution I found is to use an external schedular (like airflow) and to use ListenHttp processor. Then you can send to that listener any data you wish, parse it, and use it as parameters/attributes in the rest of the flow.

Translate
Terms & ConditionsAccessibility statement