Hi, Thank you very much for the tutorial. I am new to Nifi and trying out some use cases. I followed your steps to write a Jython script where I read from an xml file(rss) and then convert it into a string and write to outputStream and routed to putFile. The problem I am facing is that the data is getting queued in the connection to ExecuteScript and not getting into the processor. I am posting the code I wrote here in the ExecuteScript Script body. Did I need to point it to a module directory? import xml.etree.ElementTree as ET
import java.io
from org.apache.commons.io import IOUtils
from java.nio.charset import StandardCharsets
from org.apache.nifi.processor.io import StreamCallback
class xmlParser(StreamCallback):
def __init__(self):
pass
def process(self,inputStream,outputStream):
text= IOUtils.ToString(inputStream,StandardCharsets.UTF_8)
xmlRoot = ET.fromstring(text);
extracted_list=[]
for elmnts in xmlRoot.fromall('item'):
title= elmnts.find("title").text
description = elmnts.find("description").text
extracted_list.append(title)
extracted_list.append(description)
str_extract = ''.join(extracted_list)
outputStream.write(bytearray(str_extract.encode('utf-8')))
flowFile = session.get()
if(flowFile!=None):
flowFile = session.write(flowFile,xmlParser())
flowFile = session.putAtrribute(flowFile, 'filename', 'rss_feed.xml')
session.transfer(flowFile, REL_SUCCESS)
session.commit()
If you can help me with this, it would be great.
... View more
