如何提高mulesoft存储过程插入执行速度?
问题描述:
我创建了一个存储过程来插入90,000条记录,并在mule anypointstudio中调用它。但是,执行那些在perl中执行相同代码并在15分钟内插入的记录需要8个多小时。如何提高mulesoft存储过程插入执行速度?
Iam使用批处理来处理存储过程失败记录。我试着改变允许的最大线程数,但没有找到任何改进。
你能帮我在做错了吗?
这里是骡代码我使用:
<batch:job name="Import_users_data" max-failed-records="-1">
<batch:threading-profile maxThreadsActive="1000" poolExhaustedAction="RUN"/>
<batch:input>
<db:stored-procedure config-ref="MyLearn_SQLSERVER_DB_Configuration" doc:name="Database">
<db:parameterized-query><![CDATA[{call spFetch_users_data}]]></db:parameterized-query>
</db:stored-procedure>
<set-payload value="#[payload.get('resultSet1')]" doc:name="Set Payload"/>
</batch:input>
<batch:process-records>
<batch:step name="users_batch_step">
<db:stored-procedure config-ref="SQLSERVER_DB_Configuration" doc:name="Database" streaming="true">
<db:parameterized-query><![CDATA[{call spIns_data_in_users_table(:in_users_id, :in_first_name, :in_last_name)}]]></db:parameterized-query>
<db:in-param name="in_users_id" type="INTEGER" value="#[payload.USERS_ID]"/>
<db:in-param name="in_first_name" type="VARCHAR" value="#[payload.FIRST_NAME]"/>
<db:in-param name="in_last_name" type="VARCHAR" value="#[payload.LAST_NAME]"/>
</db:stored-procedure>
</batch:step>
</batch:process-records>
<batch:on-complete>
<logger message="Successfully imported users data.......#['Successfull Records: '+payload.successfulRecords+'Failed Records: '+payload.failedRecords]" level="INFO" doc:name="Logger"/>
<flow-ref name="Export_data" doc:name="Export_data"/>
</batch:on-complete>
</batch:job>
答
@shabrinath,尝试Batch Block Size
值增加到大于100为Batch Scope
的默认值。
我使用任何一个工作室5.4.0批处理块大小不可用。无法更新,因为我没有权限。 Anypointstudio 5.4.0有其他方法吗? – shabarinath
不幸的是,它可以从Mule 3.8和Anypoint Studio 6以上版本获得。您可以将Anypoint Studio升级到6以使用此选项。 –