I have create a ProcessGroup to update NifiFlow variables that receives the new values via MQTT using a json structure. Previously I have defined the variables in the scope of the NifiFlow with default values. To update the variables I use a EvaluateJsonPath configured as follow to process the json received. Later, I try to use those variables into a ExecuterScript but the are not accessible or I don't known how to access to them. This is the script (javascript): var flowFile = session.get()
if (flowFile != null) {
var categories = flowFile.getAttribute('root.sensors.categories').split(',')
var typesPerCategory = flowFile.getAttribute('root.sensors.types').split(';')
var sensorType = flowFile.getAttribute('sensor.type')
for (var i = categories.length; (--i) >= 0;) {
var types = typesPerCategory[i].split(',')
for (var j = types.lenght; (--j) >= 0;) {
if (types[j].equals(sensorType)) {
var topics = session.getAttribute(flowFile, 'root.sensors.topics').split(',')
flowFile = session.putAttribute(flowFile, 'topic', topics[i])
session.transfer(flowFile, REL_SUCCESS)
}
}
}
session.transfer(flowFile, REL_FAILURE)
}
... View more
