我有一个用例,我必须从两个不同的数据库中分别提取10k条记录,并进行一些数据扩充,然后将这20k条记录分批推送到第三个数据库中。
我遵循的方法:
但是这样做时,我经常在转换消息组件中遇到MULE JVM错误。
m子中是否有任何博客或任何设计模式可以更好地解决此问题?
我通常在“ ETL”世界中看到2种模式:
特别是在谈论Mule,这取决于您如何从流中获取信息,无论它们是否在内存中全部充满。例如,如果您执行groupBy之类的操作或对其进行搜索以迫使其返回,则可能是整个流都进入了Memory。