Support Questions

Find answers, ask questions, and share your expertise
Announcements
Celebrating as our community reaches 100,000 members! Thank you!

python extension generate multiple flowfiles from bytes input

avatar

Hi,

Im trying to write my own python extension that takes an excel bytes and produce an output flowfile for each sheet represented in html. Im using pandas dataframe for the conversion. I have been looking to the python extension developer guide but I cant find anything that will point me in the right direction:

https://nifi.apache.org/documentation/nifi-2.0.0-M2/html/python-developer-guide.html#record-transfor...

The TransformRecord talks about partitioning flowfile input but it seems like it has to be nifi readable format (json, csv , avro...etc).

In executescript processor you could have easily generated multiple flow files by passing array of flowfiles to the session.transfer method:

https://community.cloudera.com/t5/Support-Questions/Split-one-Nifi-flow-file-into-Multiple-flow-file...

However neither RecordTransformResult  nor FlowFileTransformResult can do that.

Can someone provide me with the code if applicable.

Thanks

 

0 REPLIES 0