2016-08-12 352 views
1

如何在開發Apache NiFi cusom處理器時向當前流文件添加屬性。
我想要做的是添加一個新的屬性(或至少更新當前屬性)到計算值的當前流程文件。
或者我可以使用已經構建好的處理器嗎?根據NiFi中的內容更新屬性

回答

4

根據您希望使用的數據源,NiFi支持多種創建和更新屬性的方法。一些通用處理器包括:

UpdateAttribute - 使用靜態值和NiFi的表達式語言更新流文件的屬性。

enter image description here

你可以用一個處理器添加儘可能多的性能。我建議您通過Apache NiFi Expression Language Guide進行掃描,以瞭解您可以使用它做什麼。

ExtractText - 通過對流文件內容應用正則表達式來設置屬性值。

ExecuteScript - ExecuteScript運行自定義腳本代碼,可以使用它來更新不管您希望的屬性。

還有更多針對特定內容格式,例如:

+0

是否有辦法增加的部分流文件的內容作爲值的屬性? –

+0

是的!我已經擴大了答案,包括從flowfile內容獲取屬性的方法。 – James

相關問題