Order of entry in a Nifi PG when multiple in-coming connections to same port with OldestFirstPrioritizer

huangapple go评论55阅读模式
英文:

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

huangapple
  • 本文由 发表于 2023年5月26日 16:50:43
  • 转载请务必保留本文链接:https://go.coder-hub.com/76339174.html
匿名

发表评论

匿名网友

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen:

确定