在我的流程中了解NIFI中的通知和等待过程

Question

我是NIFI流程的新手，在我的当前工作中，我已通知并等待流程。有人可以帮助我了解这一流程

通知的依据是什么。在我的情况下，我们有4个模式文件进程和4个数据文件（分别带有这些文件）。以下详细信息是通知属性。

下面是Wait属性：

***我知道，等待过程正在寻找8 Signal来继续处理下一级别的过程。但是从技术上讲，这将如何使我不确定。

如果有人在此过程中提供详细的技术级别说明，将不胜感激。

Answer 1

@Andy提到的博客很好地解释了如何一起使用等待和通知：https://ijokarumawak.github.io/nifi/2017/02/02/nifi-notify-batch/

但是，如果您想要更深入的技术了解，我发现各个处理器的文档非常有用。

等待的描述

将传入的 FlowFiles 路由到“等待”关系，直到匹配的释放信号从相应的通知处理器存储在分布式缓存中。当识别到匹配的释放信号时，等待的 FlowFile 被路由到“成功”关系，并具有从通知处理器产生释放信号的 FlowFile 复制的属性。然后从高速缓存中删除释放信号条目。如果等待的 FlowFiles 超过过期持续时间，它们将被路由到“过期”。如果您需要等待多个信号，请通过“目标信号计数”属性指定所需的信号数量。这对于将源 FlowFile 拆分为多个片段的处理器（例如 SplitText）特别有用。为了等待所有片段被处理，将“原始”关系连接到等待处理器，并将“分割”关系连接到相应的通知处理器。配置通知和等待处理器以使用“${fragment.identifier}”作为“释放信号标识符”的值，并在等待处理器中指定“${fragment.count}”作为“目标信号计数”的值当使用“等待”关系作为循环时，建议使用优先顺序（例如先进先出）。

通知说明

在分布式缓存中缓存释放信号标识符，可选地与 FlowFile 的属性一起缓存。一旦发现缓存中的该信号，任何保存在相应等待处理器中的流文件都将被释放。