Hi Asmath,

Could you please explain a little bit more. Are you writing the status of
the extraction in another database and read that database from your script.

Thanks,
Vibhath


On Wed, May 19, 2021 at 5:07 PM KhajaAsmath Mohammed <
[email protected]> wrote:

> Hi Vibhath,
>
> After a lot of research, I did this way.
>
> Let’s say, you have 50 tables that needs to be processed. I will have
> status as loading, success or fail foe each file processing. If anyone of
> the flow file is failed, then process is considered as failed . I will keep
> checking the status using db query for these tables and Mark as complete
> based on db query status
>
> Thanks,
> Asmath
>
> > On May 19, 2021, at 6:32 AM, Vibhath Ileperuma <
> [email protected]> wrote:
> >
> > 
> > Hi all,
> >
> > I'm developing a NIFI flow to extract data in a database and write into
> files.This flow starts with a ListenHttp processor. A python script sends a
> list of table names required to be extracted to the port ListenHttp
> processor is listening to. NIFI flow has been developed to iterate through
> that list and extract the data in given tables.
> >
> > I would like to know whether there is a way to get a notification to the
> python script once all the tables are extracted.
> > If it is not possible, is it possible to log a message informing all the
> tables have been extracted.
> >
> > Thank You.
> > Best Regards,
> > Vibhath.
>

Reply via email to