Hi Matt! These tutorials have been incredibly useful for learning how to write ExecuteScript processors; jython in particular for me. One thing I'd love to hear from you on though: How do we read the contents of a flowfile, then create attributes with this information? I've created flowFile IO scripts no problem, and I've manipulated attributes without a problem, but I'm not sure how to make something that crosses the barrier, so to speak. I'll clarify with a short snippet of code below. Any help is greatly appreciated! from org.apache.commons.io import IOUtils
from java.nio.charset import StandardCharsets
from org.apache.nifi.processor.io import StreamCallback
import A FEW IMPORTANT THINGS
class PyStreamCallback(StreamCallback):
def __init__(self):
# init stuff, or just pass
pass
def process(self, inputStream, outputStream):
inputText = IOUtils.toString(inputStream, StandardCharsets.ISO_8859_1)
# Process inputText
thingIWantToPutInAnAttribute = inputText[0:10]
payload = ''' Processing inputText... '''
# to my knowledge I'm unable to write to a flowFile attribute from within this class.
# I could make it a class variable with self.thing = thingIWantToPutInAnAttribute
# but then I'm unaware how I can access it outside the class.
# Write to file
outputStream.write(bytearray(payload.encode('ascii','ignore')))
flowFile = session.get(100)
if (flowFile!=None):
flowFile = session.write(flowFile,PyStreamCallback())
# How do I get thingIWantToPutInAnAttribute here?
session.transfer(flowFile, REL_SUCCESS)
... View more
