Mule 4 - 如何在缓存范围内进行错误处理？

Question

我正在使用缓存范围和对象存储来缓存使用 Salesforce 连接器从 Salesforce 查询返回的数据。

我已添加 On error continue 以捕获任何 Salesforce 连接器异常。

如果 Salesforce 连接器中出现异常（如 Salesforce Connectivity），应用程序会抛出异常并执行 On error continue 块，但是当再次调用它时，应用程序会在缓存范围内挂起并且不给出任何响应/错误信息。此外，On error continue 块在应用程序第一次执行时会执行三次。

在调试模式下运行良好。

代码：

<?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>

Answer 1

'On error continue'表示即使发生错误也结束流程。但是完成流程并不意味着它完成了它的工作——特别是没有获得缓存值。这就是第一次失败的原因。

重新排列您的流程 - 如果缓存值为空 - 一次又一次地运行缓存（例如 https://docs.mulesoft.com/mule-runtime/4.3/until-successful-scope ），只有成功才能使用现有的真实缓存值继续您的常规流程。

Answer 2

问题很可能是没有缓存，因为错误中止了执行。

您可以使用Try scope 来处理缓存范围内的错误，或者使用 flow-ref 调用另一个流，并在另一个流中处理错误。

例子：

<ee:cache doc:name="Cache" cachingStrategy-ref="Caching_Strategy">
    <try>
        <salesforce:query doc:name="Query"  config-ref="Salesforce_Config">
            <salesforce:salesforce-query><![CDATA[Select Id, Name from Account]]></salesforce:salesforce-query>
        </salesforce:query>
        <error-handler>
            <on-error-continue>
                ....
            </on-error-continue>
        </error-handler>
    </try>
</ee:cache>