Re: How to get files after a condition has been met

[Matthew Hawkins]

The wait/notify pattern might work here too.

https://pierrevillard.com/2018/06/27/nifi-workflow-monitoring-wait-notify-pattern-with-split-and-merge/

Wait the getfile and notify when the validatejson is stopped?


On Tue, 6 Feb 2024, 22:55 Mike Thomsen,  wrote:

> I think the easiest way to do the conditional fetch would be to use
> ConsumeKafka (or something equivalent for this use case like ListenHttp)
> and FetchFile.
>
> On Mon, Feb 5, 2024 at 4:23 PM Dan S  wrote:
>
> > I have a requirement to load Json Schemas into the
> > StandardJsonSchemaRegistry from the file system for use in validating
> JSON
> > with the ValidateJson processor. I am trying to use the NIFI Rest API to
> > update the StandardJsonSchemaRegistry. I am able to stop the ValidateJson
> > processor and disable the StandardJsonSchemaRegistry using the NIFI Rest
> > API. I do not know though how I can indicate either to GetFile or
> ListFile
> > (to allow for retrieval of the JSON schemas) that ValidateJson has been
> > stopped and StandardJsonSchemaRegistry has been disabled since both of
> > these processors do not allow for an incoming relationship. How can I do
> > this and if this is not possible how can I accomplish this?
> >
>

Re: How to get files after a condition has been met

[Mike Thomsen]

I think the easiest way to do the conditional fetch would be to use
ConsumeKafka (or something equivalent for this use case like ListenHttp)
and FetchFile.

On Mon, Feb 5, 2024 at 4:23 PM Dan S  wrote:

> I have a requirement to load Json Schemas into the
> StandardJsonSchemaRegistry from the file system for use in validating JSON
> with the ValidateJson processor. I am trying to use the NIFI Rest API to
> update the StandardJsonSchemaRegistry. I am able to stop the ValidateJson
> processor and disable the StandardJsonSchemaRegistry using the NIFI Rest
> API. I do not know though how I can indicate either to GetFile or ListFile
> (to allow for retrieval of the JSON schemas) that ValidateJson has been
> stopped and StandardJsonSchemaRegistry has been disabled since both of
> these processors do not allow for an incoming relationship. How can I do
> this and if this is not possible how can I accomplish this?
>

How to get files after a condition has been met

[Dan S]

I have a requirement to load Json Schemas into the
StandardJsonSchemaRegistry from the file system for use in validating JSON
with the ValidateJson processor. I am trying to use the NIFI Rest API to
update the StandardJsonSchemaRegistry. I am able to stop the ValidateJson
processor and disable the StandardJsonSchemaRegistry using the NIFI Rest
API. I do not know though how I can indicate either to GetFile or ListFile
(to allow for retrieval of the JSON schemas) that ValidateJson has been
stopped and StandardJsonSchemaRegistry has been disabled since both of
these processors do not allow for an incoming relationship. How can I do
this and if this is not possible how can I accomplish this?