我是 NIFI 流程的新手,在我当前的工作中,我有通知和等待流程。有人可以帮助我理解这个流程吗
On what basis the Notify work. in my case we have 4 schema files process and 4 data files with respective those.
the below details are notify properties..
Below are the Wait properties:
***据我了解,等待进程寻找8个信号以继续处理下一级进程。但从技术上讲,这将如何运作还不确定。
如果有人提供有关此过程的详细技术级别解释,我们将不胜感激。
@Andy提到的博客对如何一起使用等待和通知给出了很好的解释:https://ijokarumawak.github.io/nifi/2017/02/02/nifi-notify-batch/ https://ijokarumawak.github.io/nifi/2017/02/02/nifi-notify-batch/
但是,如果您想要更深入的技术了解,我发现各个处理器的文档非常有用。
等待的描述 https://nifi.apache.org/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.6.0/org.apache.nifi.processors.standard.Wait/index.html
将传入的 FlowFiles 路由到“等待”关系,直到匹配的释放信号从相应的通知处理器存储在分布式缓存中。当识别到匹配的释放信号时,等待的 FlowFile 被路由到“成功”关系,并具有从通知处理器产生释放信号的 FlowFile 复制的属性。然后从高速缓存中删除释放信号条目。如果等待的 FlowFiles 超过过期持续时间,它们将被路由到“过期”。如果您需要等待多个信号,请通过“目标信号计数”属性指定所需的信号数量。这对于将源 FlowFile 拆分为多个片段的处理器(例如 SplitText)特别有用。为了等待所有片段被处理,将“原始”关系连接到等待处理器,并将“分割”关系连接到相应的通知处理器。配置通知和等待处理器以使用“${fragment.identifier}”作为“释放信号标识符”的值,并在等待处理器中指定“${fragment.count}”作为“目标信号计数”的值当使用“等待”关系作为循环时,建议使用优先顺序(例如先进先出)。
通知说明 https://nifi.apache.org/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.6.0/org.apache.nifi.processors.standard.Notify/index.html
在分布式缓存中缓存释放信号标识符,可选地与 FlowFile 的属性一起缓存。一旦发现缓存中的该信号,任何保存在相应等待处理器中的流文件都将被释放。
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)