@SAMSAL, hey I know I accepted the solution and it did work for when I had 1 user details to fetch and store it's values to the processor's attributes. I wanted to ask if it is possible to store multiple values to a single attribute of a processor since I now have many users' details to store. Is this possible otherwise I would have to change the logic? Thanks. ... View more

Yes, I ended up changing my ExecuteScript in a way that all column's values are now attributes of my flowFile. Next, I have added PutSql processor and inserting data using ${attributename}.  Thanks @SAMSAL for responding.  ... View more

Thanks @SAMSAL for responding. I will explain what I am trying to accomplish. The ExecuteStreamCommand gives me below results: and I want to use displayName and mail key's values from this result and store it into the database. My current workflow is based on the flow that I will store these two key's value as a attribute and use it in the subsequent processors. However, using AttributestoJson aint also working for me. Can you suggest any other better appraoach to ingest these two values in my database? I have other columns' value to ingest that as well so may be ExecuteSQLCommand processor would be a better choice to use.   ... View more

Can you help me with a similar issue? My code: import json import collections import java.io import ast   from org.apache.commons.io import IOUtils from java.nio.charset import StandardCharsets from org.apache.nifi.processor.io import StreamCallback class ModJSON(StreamCallback) :   def __init__(self):          pass   def process(self, inputStream, outputStream):     text = IOUtils.toString(inputStream, StandardCharsets.UTF_8)     obj = ast.literal_eval(text)     mail = obj['mail']     outputStream.write(bytearray(json.dumps(obj['mail'], indent=4).encode('utf-8')))     outputStream.write(bytearray(json.dumps(obj['id'], indent=4).encode('utf-8')))       flowFile = session.get() if (flowFile != None):   flowFile = session.write(flowFile, ModJSON())   flowFile = session.putAttribute(flowFile, "filename", flowFile.getAttribute('filename').split('.')[0]+'_translated.json')   flowFile = session.putAttribute(flowFile, "mail", mail) session.transfer(flowFile, REL_SUCCESS) session.commit()     I want to get "mail" value and create a new attribute for it. However, mail variable is not accessible when I insert it into the putattribute command. Any feedback? ... View more

Thanks for the reply. I did it in the same way you have mentioned (I am importing Selenium module and from this module, Service, WebDriverWait and EC components are imported) but late in the code execution, my scripts gives an error "global name Service is not defined". Any idea whats causing the issue? ... View more

@joseomjr I am trying to replicate your suggested method, please answer did you include the import command after sys.path.append command?  ... View more

Thanks. It was an issue with the connection string. It was pointing to another database while my processor was inserting into another database.  ... View more