RouteOnAttribute

示例1

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

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

示例2：

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

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

• mqttTopic：這是定義的一個MQTT的Topic變量，它的內(nèi)容是可變動的，會根據(jù)Route的不同產(chǎn)生不同的結(jié)果
• 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"}}的取值方法來實(shí)現(xiàn)動態(tài)的取用變量值