Hi, This is one option using simple Python script - (I am not python expert, there should be better way to write below code, but this works)   Just use ExecuteScript processor and add below code as script body -  import csv import java.io from org.apache.commons.io import IOUtils from java.nio.charset import StandardCharsets from org.apache.nifi.processor.io import StreamCallback global filename class PyStreamCallback(StreamCallback): def __init__(self): pass def process(self, inputStream, outputStream): text = IOUtils.toString(inputStream, StandardCharsets.UTF_8) lines = text.splitlines() reader = csv.reader(lines) headerList = list(next(reader)) dataList = list(next(reader)) global filename filename = dataList[headerList.index('Name')] + "_" + dataList[headerList.index('Country')] + ".csv" outputStream.write(bytearray(text.encode('utf-8'))) flowFile = session.get() if (flowFile != None): flowFile = session.write(flowFile, PyStreamCallback()) flowFile = session.putAttribute(flowFile, "filename", filename) session.transfer(flowFile, REL_SUCCESS)       Thanks Mahendra ... View more

Hey,   This is the one option using Python script -   Just use ExecuteScript processor and use below script as script body - (I am not Python expert, there should be better way to write below code, but this works)   import csv import java.io from org.apache.commons.io import IOUtils from java.nio.charset import StandardCharsets from org.apache.nifi.processor.io import StreamCallback global filename class PyStreamCallback(StreamCallback): def __init__(self): pass def process(self, inputStream, outputStream): text = IOUtils.toString(inputStream, StandardCharsets.UTF_8) lines = text.splitlines() reader = csv.reader(lines) headerList = list(next(reader)) dataList = list(next(reader)) global filename filename = dataList[headerList.index('Name')] + "_" + dataList[headerList.index('Country')] + ".csv" outputStream.write(bytearray(text.encode('utf-8'))) flowFile = session.get() if (flowFile != None): flowFile = session.write(flowFile, PyStreamCallback()) flowFile = session.putAttribute(flowFile, "filename", filename) session.transfer(flowFile, REL_SUCCESS)   Thanks Mahendra ... View more

I could not succeed in multipart upload with InvokeHTTP processor. So I used a simple java code to upload file using 'multipart/form-data'. Invoked java code from nifi SprintContextProcessor. As my file was large, I wrote the file content to disc before invoking 'SprintContextProcessor' and using java code read the file content and uploaded to the target. You can transfer flow file content directly to the java code (SpringContext processor).   Thanks Mahendra ... View more

Hi @ankita_pise ,  Were you able to achieve this using InvokeHttp processor ? I am also looking for the solution.   Thanks, Mahendra ... View more

Thank you, its working with ${anyDelineatedValue("${your_attribute}", ","):equals("US")} ... View more

Thanks @Shu ! It worked, I was using 'Return type' as auto instead of json in EvaluateJsonPath. Thanks for the reply 🙂 ... View more