单独启动“GenerateFlowFile”处理器后,可以观察到对应的Connection连接队列中有数据,在Connection连接上右键“List Queue”可以查看队列中的FlowFile信息:
队列中的FlowFile属性中还可以查看自定义的属性信息,例如:在“GenerateFlowFile”处理器中设置自定义属性“mykey”,对应的value值设置为“myvalue”:
单独启动“GenerateFlowFile”生产部分数据,查看队列中的FlowFile属性如下:
针对Connectiond连接,可以通过“Configure”配置更多信息:
弹出页面点击“SETTINGS”:
“FlowFile expiration”数据过期:
设置FlowFile expiration 时间可以删除队列中无法及时处理的数据,默认设置为0,数据永远不会过期,当设置了一个过期时间,在Connect连接上可以看到一个小时钟图标。
“Back Press”背压:
NiFi提供了两种背压配置机制,背压机制允许在队列中存在多少数据,当达到这个数据后,源头处理器就不再调度产生数据,防止数据溢出。"Back pressure object threshold"指定队列中的数据达到多少条数触发背压机制。"Back pressure data size threshold"指定队列中数据达到多大时触发背压机制。设置背压机制后,在Connection连接上会显示进度条。
“load balance strategies”负载均衡:
负载均衡策略可选项如下:
设置好负载均衡后可以看到图标:
“Load Balance Compression”负载均衡数据压缩:
当配置好负载均衡策略后,可以设置节点间数据传递是否压缩,可选项如下:
"Select Prioritization"优先级:
可以指定如何对队列中的数据进行优先级排序以便处理优先级高的数据。可以从"Available prioritizers" 拖动到"Selected prioritizers"标签下使用优先级。可以选择多个优先级,数据会依次按照选择的优先级排序,优先级可选如下:
在主菜单“Summary”中的“Connection”中可以查看连接的信息:
可以双击Connection连接线来增加弯曲点,对弯曲点再次双击将删除当前弯曲点。
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。