Parallel For-Each 与 Scatter Gather in mule
Parallel For-Each vs Scatter Gather in mule
我有多个记录:
{
"item_id":1",
key1: "data1"
}
{
item_id:2
key1: "data1"
}
{
item_id:2
key1: "data1"
}
{
item_id:1
key1: "data1"
}
我不想处理它们sequentially.There可以超过200条记录。我应该使用 for-each parallel 还是 scatter-gather 来处理它们。根据我的要求，哪种方法最好。
我不需要累积响应，但是如果在处理时出现异常 （根据 if 条件为每条记录打一个 api） 任何一条记录，处理其他记录必须保持不受影响。
为什么不使用 VM 模块，将集合分解成单独的记录并将它们推送到 VM 队列？然后让另一个流程使用 VM 侦听器拾取单个记录（并行）并处理它们。
详情如下：https://docs.mulesoft.com/mule-runtime/4.2/reliability-patterns
分散-聚集适用于您拥有静态数量路由的情况。想象一条发送到人力资源系统的路由，另一条发送到会计系统的路由。
要处理可变数量的记录，您应该使用并行 for-each。
使用 foreach async 或 parallel 或 jms 模式。 Scater-gather 为所有线程接收一个有效负载，您将无法循环
我有多个记录:
{
"item_id":1",
key1: "data1"
}
{
item_id:2
key1: "data1"
}
{
item_id:2
key1: "data1"
}
{
item_id:1
key1: "data1"
}
我不想处理它们sequentially.There可以超过200条记录。我应该使用 for-each parallel 还是 scatter-gather 来处理它们。根据我的要求，哪种方法最好。 我不需要累积响应，但是如果在处理时出现异常 （根据 if 条件为每条记录打一个 api） 任何一条记录，处理其他记录必须保持不受影响。
为什么不使用 VM 模块，将集合分解成单独的记录并将它们推送到 VM 队列？然后让另一个流程使用 VM 侦听器拾取单个记录（并行）并处理它们。 详情如下：https://docs.mulesoft.com/mule-runtime/4.2/reliability-patterns
分散-聚集适用于您拥有静态数量路由的情况。想象一条发送到人力资源系统的路由，另一条发送到会计系统的路由。
要处理可变数量的记录，您应该使用并行 for-each。
使用 foreach async 或 parallel 或 jms 模式。 Scater-gather 为所有线程接收一个有效负载，您将无法循环