英文:
Order of entry in a Nifi PG when multiple in-coming connections to same port with OldestFirstPrioritizer
问题
我有一个PG,只允许其中有一个流文件。没有集群nifi。
它会接收多个传入连接(在我的情况下是4个),都连接到同一个输入端口。
到目前为止,我流程中的所有连接都是FIFO优先级队列的形式。
现在我在考虑是否应该在这个单一流文件PG的所有传入连接上使用OldestFlowFileFirst优先级队列。如果我这样做,如果所有4个连接都有一个流文件,我想知道哪个会优先处理。
这些优先级队列只适用于它们各自的连接,并且只对该队列中的流文件进行优先级处理,还是OldestFlowFileFirst优先级队列会在所有4个队列中优先处理。
问候
我想我可以测试一下,但希望有人已经知道答案。
英文:
So I have a PG that allows only a single flow file in it. No cluster nifi.
It gets multiple incoming connections (4 in my case) to a same input port.
Till now all the connections in my flow were of the form FIFO prioritizer.
Now I am wondering if I should be using OldestFlowFileFirst prioritizer on all the incoming connections on this single flow file PG. If I do this and all 4 connections get a flow file, I was wondering which will win.
Are the prioritizers only valid for their respective connections and only prioritizing flowfiles in that queue or over all of the 4 queues the OldestFlowFileFirst prioritizer will take precedence.
Regards
I suppose I could test but was hoping someone knew the answer already
答案1
得分: 0
在这种情况下,您应该使用一个漏斗[1]将这四个队列合并为一个单一队列。然后,应将该单一队列的优先级分配并连接到子流程组内的输入端口。
[1] https://nifi.apache.org/docs/nifi-docs/html/user-guide.html
英文:
In this case, you should use a funnel [1] to combine the four queues into a single queue. The single queue should then have the prioritized assigned and connected to the Input Port within the child Process Group.
[1] https://nifi.apache.org/docs/nifi-docs/html/user-guide.html
通过集体智慧和协作来改善编程学习和解决问题的方式。致力于成为全球开发者共同参与的知识库,让每个人都能够通过互相帮助和分享经验来进步。
评论