You are viewing a plain text version of this content. The canonical link for it is here.

Posted to users@nifi.apache.org by KhajaAsmath Mohammed <md...@gmail.com> on 2021/04/23 21:16:08 UTC

ExecuteSQL - Ignore zero records file

Hi,

I have a requirement where I need to ignore the flow files that have zero
records from executesql processor.

Process only the files which have results from executesql.  any suggestions
please?

Thanks,
Khaja

Re: ExecuteSQL - Ignore zero records file

Posted by KhajaAsmath Mohammed <md...@gmail.com>.

Thanks Chris.

On Fri, Apr 23, 2021 at 4:21 PM Chris Sampson <ch...@naimuri.com>
wrote:

> You could use a RouteOnAttribute[1] processor to look for FlowFiles with
> an executesql.row.count attribute with a value of 0, then remove them
> from the flow.
>
> [1]
> https://nifi.apache.org/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.13.2/org.apache.nifi.processors.standard.RouteOnAttribute/index.html
>
>
> ---
> *Chris Sampson*
> IT Consultant
> chris.sampson@naimuri.com
> <https://www.naimuri.com/>
>
>
> On Fri, 23 Apr 2021 at 22:16, KhajaAsmath Mohammed <
> mdkhajaasmath@gmail.com> wrote:
>
>> Hi,
>>
>> I have a requirement where I need to ignore the flow files that have zero
>> records from executesql processor.
>>
>> Process only the files which have results from executesql.  any
>> suggestions please?
>>
>> Thanks,
>> Khaja
>>
>

Re: ExecuteSQL - Ignore zero records file

Posted by Chris Sampson <ch...@naimuri.com>.

You could use a RouteOnAttribute[1] processor to look for FlowFiles with an
executesql.row.count attribute with a value of 0, then remove them from the
flow.

[1]
https://nifi.apache.org/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.13.2/org.apache.nifi.processors.standard.RouteOnAttribute/index.html

---
*Chris Sampson*
IT Consultant
chris.sampson@naimuri.com
<https://www.naimuri.com/>

On Fri, 23 Apr 2021 at 22:16, KhajaAsmath Mohammed <md...@gmail.com>
wrote:

> Hi,
>
> I have a requirement where I need to ignore the flow files that have zero
> records from executesql processor.
>
> Process only the files which have results from executesql.  any
> suggestions please?
>
> Thanks,
> Khaja
>