mule - Mule 4 - 如何在缓存范围内进行错误处理?
问题描述
我正在使用缓存范围和对象存储来缓存使用 Salesforce 连接器从 Salesforce 查询返回的数据。
我已添加On error continue
以捕获任何 Salesforce 连接器异常。
如果 Salesforce 连接器中存在异常(如Salesforce Connectivity
),应用程序会抛出异常并执行On error continue
块,但是当再次调用它时,应用程序会在缓存范围内挂起并且不给出任何响应/错误消息。此外,On error continue
当应用程序第一次执行时,block 会执行三次。
它在调试模式下运行良好。
代码:
<?xml version="1.0" encoding="UTF-8"?>
<mule xmlns:os="http://www.mulesoft.org/schema/mule/os" xmlns:ee="http://www.mulesoft.org/schema/mule/ee/core"
xmlns:salesforce="http://www.mulesoft.org/schema/mule/salesforce"
xmlns:http="http://www.mulesoft.org/schema/mule/http" xmlns="http://www.mulesoft.org/schema/mule/core" xmlns:doc="http://www.mulesoft.org/schema/mule/documentation" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/current/mule.xsd
http://www.mulesoft.org/schema/mule/http http://www.mulesoft.org/schema/mule/http/current/mule-http.xsd
http://www.mulesoft.org/schema/mule/salesforce http://www.mulesoft.org/schema/mule/salesforce/current/mule-salesforce.xsd
http://www.mulesoft.org/schema/mule/ee/core http://www.mulesoft.org/schema/mule/ee/core/current/mule-ee.xsd
http://www.mulesoft.org/schema/mule/os http://www.mulesoft.org/schema/mule/os/current/mule-os.xsd">
<http:listener-config name="HTTP_Listener_config" doc:name="HTTP Listener config" doc:id="6a5b02b3-836d-43b5-9dbe-41719d20258f" >
<http:listener-connection host="0.0.0.0" port="8081" />
</http:listener-config>
<salesforce:sfdc-config name="Salesforce_Config" doc:name="Salesforce Config" doc:id="3facafa3-5d07-4717-901a-487f0cdeabb2" >
<salesforce:basic-connection username="..." password="..." securityToken="..." url="https://login.salesforce.com/services/Soap/u/48.0" />
</salesforce:sfdc-config>
<ee:object-store-caching-strategy name="Caching_Strategy" doc:name="Caching Strategy" doc:id="4ebcc02a-3c51-445b-bee5-0c95e4ce6e01" keyGenerationExpression="#['1']" >
<os:private-object-store persistent="false" maxEntries="1" entryTtl="1" />
</ee:object-store-caching-strategy>
<flow name="test-errorFlow" doc:id="49520788-7379-45cb-9276-cdb6b268398c" >
<http:listener doc:name="Listener" doc:id="ce5faf93-3153-4f93-8313-90d465f920c6" config-ref="HTTP_Listener_config" path="/test" allowedMethods="GET">
<http:response statusCode="#[vars.httpStatus]" />
<http:error-response statusCode="#[vars.httpStatus]" >
<http:body ><![CDATA[#[error]]]></http:body>
</http:error-response>
</http:listener>
<ee:cache doc:name="Cache" doc:id="ae4e7d76-0f98-4202-9a51-59373ea3ee1c" cachingStrategy-ref="Caching_Strategy">
<salesforce:query doc:name="Query" doc:id="1498398a-7b1f-4a27-aff8-3991d4e9cbca" config-ref="Salesforce_Config">
<salesforce:salesforce-query><![CDATA[Select Id, Name from Account]]></salesforce:salesforce-query>
</salesforce:query>
</ee:cache>
<ee:transform doc:name="Transform Message" doc:id="f864be76-86a9-4726-b1f1-586ffeabb0db" >
<ee:message >
<ee:set-payload ><![CDATA[%dw 2.0
output application/json
---
payload]]></ee:set-payload>
</ee:message>
</ee:transform>
<error-handler >
<on-error-continue enableNotifications="true" logException="true" doc:name="On Error Continue" doc:id="038cd795-2174-4d9a-b759-2921dd12a64e" type="ANY">
<logger level="INFO" doc:name="Logger" doc:id="186587c2-0beb-416a-b589-7239a2cba7dd" message="#[error]"/>
</on-error-continue>
</error-handler>
</flow>
</mule>
解决方案
'On error continue' 表示即使发生错误也结束流程。但是完成流程并不意味着它完成了它的工作——特别是没有获得缓存值。这就是第一个失败的原因。
重新安排您的流程 - 如果缓存值为空 - 一次又一次地运行缓存(例如https://docs.mulesoft.com/mule-runtime/4.3/until-successful-scope),只有成功才能继续您的常规流程与现有的真实缓存值。
推荐阅读
- java - Java 指定从 1 到 100 的命令行参数
- php - 从php中的数组中检索一个单词
- sql - SQL查询一批地址
- sql - 平均库存天数
- jquery - Jquery:ID 匹配正则表达式或过滤器的所有输入?
- docker - Nginx over TLS 与 docker compose
- jsp - 访问 .jsp 文件中的 java 映射
- powerapps - 在 Power Apps 中的按钮选项卡上按下时,如何仅显示共享点列表中的某些列值?
- javascript - Time Series Insights Gen 2 - 如何使用 tsiClient,,server.GetEvents 调用 Get Events
- javascript - 如何在 SearchKit 中强制更改查询?