RouteOnAttribute

示例1

    使用Route做流程的分支，根據一個叫SO的欄位是否為空決定走不同的流程(左右的UpdateAttribute可以把它們想象成兩個完全不同的處理流程來看)

• HasSO / NonSO：這是我自行定義的兩個Route名稱 (不是屬性名稱)，Value是一個表達式，若它的值=true，則Output會進該Route
• Nifi的表達式語法不怎么好寫，官方的文檔上有些東西并不支持 (不確定是不是Nifi版本緣故)。這里還是可以看得出來就只是判斷一個叫SO的Attribute的值是否為空 --- 還記得有些Processor里面還有叫"Null Value Representation"的屬性吧，若是那里配成"null"那這里也要與之匹配。
• 經過該Processor處理后，SO為空的會走右端邏輯，而不為空的則會走左段邏輯，同時它會加多一個叫"RouteOnAttribute.Route"的Attribute，內容即為Route名稱
  

示例2：

    根據多個欄位是否有值(不為空)，讓它們能夠進入不同的Route，后面再根據Route名稱去動態的取值，它的特點是Nifi流程并沒有出現分支(Connection上是勾了所有的Route)，只是為不同的數據設上了一個變量名稱

• MO / MODELFAMILY / UPN / USN：這是定義的四個Route名稱，判斷條件都很簡單，就只是不為空
• 值得注意的是這4個條件并非是互斥條件，比如有一筆資料它的MO、USN都不為空，那么就會同時進入兩個Route進行輸出，所以Output筆數會是2
• 下面這是進入UPN這個Route后的資料上的Attribute: "RouteOnAttribute.Route"
  
  

• mqttTopic：這是定義的一個MQTT的Topic變量，它的內容是可變動的，會根據Route的不同產生不同的結果
• MO/MODELFAMILY/UPN/USN這4個條件有任一不為空，則會要求推送Topic： xxxx/【Type】/【Value】/yyyy
• 【Type】: 為"mo"、"modelfamily"、"upn"、"usn"這四個值之一
• 【Value】: 為MO/MODELFAMILY/UPN/USN這四個Attribute的取值 (即 ${MO} / ${MODELFAMILY} / ${UPN} / ${USN} 的值)，這里使用了雙層${${"RouteOnAttribute.Route"}}的取值方法來實現動態的取用變量值