I have a single flowfile I generate on a periodic basis using a cron
scheduled GenerateFlowFile. This then flows into an ExecuteScript, where I
have a python script that will create multiple flowfiles from the one.
My ExecuteScript is configured to run on all my cluster nodes. For each
instance of flowfile I am creating, I need to determine which cluster node
it associates with. There’s an expression language function called ip().
Can anyone tell me how to employ ${ip()} in my python to determine the
cluster node the newly created flowFile is associated with?
I’d be using this after I execute
flowfile = session.create()
Thanks in advance for your help.
