Nifi

[#1]

Hi,

Input is getting from jolt transforms and data is something like :

{
"dv_sys_id" : [ "23ec0223138d73006877", "983f853edb2c77007166f", "6a3d0a23138d73006877b3", "805d5339db8dd050f66" ]
}

output should go in invokehttp processor somthing like:

dv_sys_id: 23ec0223138d73006877, 983f853edb2c77007166f, 6a3d0a23138d73006877b3, 805d5339db8dd050f66

remote url : https://<url>${dv_sys_id}

How can i achieve this requirement, Pls help me out. 

[#2 · Accepted solution]

@sathish3389 ,

One way to do this is to use the ExecuteScript processor with a script like the one below. This script with set the attribute dv_sys_id with the content that you want and will also add that to the content of the flowfile.

from org.apache.commons.io import IOUtils
from java.nio.charset import StandardCharsets
from org.apache.nifi.processor.io import StreamCallback
import json

class PyStreamCallback(StreamCallback):
    def __init__(self):
        self.dv_sys_id = None

    def process(self, inputStream, outputStream):
        text = IOUtils.toString(inputStream, StandardCharsets.UTF_8)
        obj = json.loads(text)
        self.dv_sys_id = 'dv_sys_id=%s' % (','.join(obj['dv_sys_id'],))
        outputStream.write(bytearray(self.dv_sys_id.encode('utf-8','ignore')))

flow_file = session.get()
if flow_file != None:
    callback = PyStreamCallback()
    flow_file = session.write(flow_file, callback)
    flow_file = session.putAttribute(flow_file, 'dv_sys_id', callback.dv_sys_id)
    session.transfer(flow_file, REL_SUCCESS)

Cheers,

André

[#3]

Thanks for your response Andre