How to read only the header from a flowfile

rbalakrishnantc — Thu, 10 Nov 2016 21:19:06 GMT

I have a requirement where I will have to decide the flow based on the record header.

Since the file is huge, I don't want to waste time reading the entire file where only one record is enough.

Is there a way I can achieve this.

Re: How to read only the header from a flowfile

mburgess — Fri, 11 Nov 2016 01:44:24 GMT

You can use ExecuteScript with Groovy and the following script (assuming your input is newline-delimited):

def flowFile = session.get()
if(!flowFile) return	
def header = ''
session.read(flowFile, { inStream -> 
   header = new BufferedReader(new InputStreamReader(inStream)).readLine()
} as InputStreamCallback)
flowFile = session.putAttribute(flowFile, 'header', header)
session.transfer(flowFile, REL_SUCCESS)

This puts the first line in an attribute called 'header', which you can use with RouteOnAttribute to decide where to send the flow. Note that this script doesn't do error handling, but you could put a try/catch around the session.read to session.transfer, the catch could route the flow file to REL_FAILURE.

question Re: How to read only the header from a flowfile in Archives of Support Questions (Read Only)

How to read only the header from a flowfile

Re: How to read only the header from a flowfile