我有一個ID的數據集,我有一個每個ID有一行的流文件。我有一個API,將這個ID作為參數,我想將所有行的結果收集回NiFi(下面的示例)。
https://service.com/api/thing/{ID}
在NiFi中,如何為數據集中的所有ID調用此API。如果可能,最好使用一些并行性。
(作為參考,在SSIS中,我可以將這些ID加載到數組中,然后使用ID的參數循環API調用)。
我有一個ID的數據集,我有一個每個ID有一行的流文件。我有一個API,將這個ID作為參數,我想將所有行的結果收集回NiFi(下面的示例)。
https://service.com/api/thing/{ID}
在NiFi中,如何為數據集中的所有ID調用此API。如果可能,最好使用一些并行性。
(作為參考,在SSIS中,我可以將這些ID加載到數組中,然后使用ID的參數循環API調用)。
公眾號:1024技術圈
?? 提供互聯網知識和資訊,分享IT前沿技術,熱門資源,大廠面試題 ??
首先,使用
獲取
SplitText
將每個Id作為flowfile
然后通過
ExtractText
將內容復制到屬性因此
ExtractText
會將message.body.0屬性添加到流文件中,您可以像下面那樣使用它InvokeHttp
。請注意,由于您的端點是https
,您可能需要配置SSL Contect Service
最后,您可以為每個
Processor
設置并行性的并發任務計數