question Re: How can we read a flowfile content with a python script ? in Support Questions

How can we read a flowfile content with a python script ?

Ghilani — Fri, 16 Dec 2022 13:17:29 GMT

the example is the next:

GenerateFlowFile content:

I want to clean the ETX character with a python script (Nifi wasn't able to clean it with replaceText), so I decided to pass the list to a python script to clean it, but am not sure how to read the Flowfile content.

The list (my_list) should be passed as Flowfile to the python script.

Re: How can we read a flowfile content with a python script ?

joseomjr — Sun, 25 Jun 2023 19:24:11 GMT

Have you tried these examples?

https://community.cloudera.com/t5/Community-Articles/ExecuteScript-Cookbook-part-1/ta-p/248922

Re: How can we read a flowfile content with a python script ?

steven-matison — Mon, 26 Jun 2023 16:18:36 GMT

@Ghilani You should know these 3 articles intimately if you want to use Execute Script

https://community.cloudera.com/t5/Community-Articles/ExecuteScript-Cookbook-part-1/ta-p/248922

https://community.cloudera.com/t5/Community-Articles/ExecuteScript-Cookbook-part-2/ta-p/249018

https://community.cloudera.com/t5/Community-Articles/ExecuteScript-Cookbook-part-3/ta-p/249148

That said, it's sometimes helpful for me to see a working example and modify from there. As such, here is a github with a sample flow definition file (01_Fraud_Detection_Demo_Params_ExecuteScript.json) and script file(Fraud Demo ExecuteScript.py) that should work out of the box:

https://github.com/cldr-steven-matison/Fraud-Prevention-With-Cloudera-SSB/tree/main/Templates

Pay attention to imports and, then line 160 is what you want to get the flowfile. My flow ignores the content, but you should be able to find references in the Part 1 cookbook for anything you want to do w/ flowfile content.