Mule是一个基于Java的轻量级企业服务总线(ESB)和集成平台,允许开发人员快速,轻松地将应用程序连接在一起,使他们能够交换数据。无论应用程序使用何种不同的技术,Mule都可以轻松集成现有系统,包括JMS,Web服务,JDBC,HTTP等。
我正在尝试使用 GET-Product 操作通过 mule 中的 Magneto 连接器从 Magneto 获取产品信息,但我收到此错误:产品不存在,尽管通过 SOAP UI 进行了测试并工作正常...
Mule 4 debug如何在studio中维护调试语句的历史记录
在 Mule 4 Anypoint Studio 中,当我调试应用程序时,很多时候我需要以 json 格式查看有效负载,因此在调试视图中我会转到此处: 评估 Dataweave 表达式 这里每...
我想更新输入csv文件的A列基础B列的条件。我们如何在dataweave中实现这一点?
“身份证”、“姓名”、“工资”、“地点”、“日期” 123,"甘尼什",10000,"浦那","02/22/2020" 234、“桑克特”、20000、“孟买&
下载 API 规范时出现 MuleSoft DependencyResolutionException
我们在从 AnyPoint Platform 下载 RAML 到 Studio 时遇到了一个棘手的问题。我在这里附上错误日志。我们目前的所有 API 都没有发生这种情况。我可以
我有巨大的嵌套 JSON,它正在作为 API 的 n 输入提供。输入 JSON 如下所示: [{ “ID”:“123456”, "帐号": "876545", ”
如何使用Dataweave将下面的json(可以有多个嵌套对象)转换为所需的输出?
输入: { “拖”: { “杂项”:{ “程序”:{ “ID”: { “类型”:“名称”,...
我在 mule 4 中从 http 请求者调用其余 api 时遇到问题,其中其余 api 期望标头中的 Key 为大写格式,如 Key 和我仅在 hea 中以大写格式定义...
如何在 mule 4 中使用 google-play-scraper python 脚本
我的要求是使用python脚本在mule4中使用google play scraper脚本。 我正在关注此门户 https://pypi.org/project/google-play-scraper/ 来获取 python 脚本。 Jython 引擎...
Salesforce create-job-bulk-api-v2 UpdateOnly 的更新插入操作
我在Mule 4中使用salesforce create-job-bulk-api-v2和Upsert操作,并按照本文档https://developer.salesforce.com/docs/atlas.en-us.250.0.api_rest。元/api_rest/
Mule 4 Anypoint mq 订阅者 - 断路器以任何方式在日志中打印以指示断路器已激活且消息不会被处理?
这个后续问题是针对之前提出的问题: 现在,由于之前问题的答案,断路器正在工作。 现在作为后续 - 有没有一种方法可以让我们在日志中打印......
Mule 4 Anypoint mq 订阅者 - 断路器不工作
我正在尝试实现断路器模式。使用骡子 4.4。 我正在使用来自 Anypoint MQ 队列的消息,然后尝试调用下游 api 这是代码: 我正在尝试实现断路器模式。使用 Mule 4.4。 我正在使用来自 Anypoint MQ 队列的消息,然后尝试调用下游 api 这是代码: <flow name="create-emp-flow"> <anypoint-mq:subscriber doc:name="Subscriber - Create user" config-ref="Anypoint_MQ_Configuration" destination="emp.create.queue}" acknowledgementMode="AUTO"> <redelivery-policy maxRedeliveryCount="1"/> <anypoint-mq:circuit-breaker tripTimeout="150000" onErrorTypes="HTTP:INTERNAL_SERVER_ERROR,MULE:UNKNOWN" errorsThreshold="3"/> </anypoint-mq:subscriber> <http:request method="GET" doc:name="HACK - Mock CALL return a ISE500" config-ref="MOCK_Request_Configuration" path="/emp" > <http:response-validator > <http:success-status-code-validator values="200" /> </http:response-validator> </http:request> <error-handler > <on-error-continue enableNotifications="true" logException="true" doc:name="On Error Continue" type="MULE:REDELIVERY_EXHAUSTED"> <anypoint-mq:publish doc:name="Publish to DLQ" config-ref="Anypoint_MQ_Configuration" destination="emp.dlq" /> </on-error-continue> <on-error-propagate enableNotifications="true" logException="true" doc:name="On Error Propagate" > <logger .../> </on-error-propagate> </error-handler> </flow> 所以顺序是: #1 从队列中消费消息 ( maxRedeliveryCount=1 ) #2 然后调用 HTTP 端点 - 这里我故意返回 500 ISE 错误 注意 - 订阅者配置有 Circuit breaker 和 maxThreshhold = 3 以及触发断路器的错误类型为 HTTP:INTERNAL_SERVER_ERROR,MULE:UNKNOWN #3 现在,由于 HTTP 调用返回 ISE,Mule 中的异常显示为 HTTP:INTERNAL_SERVER_ERROR,这就是我想要生成的 现在,由于我已经配置了重新投递,消息会再次重试,并且在失败时再次重试,我们达到了条件MULE:REDELIVERY_EXHAUSTED,因此消息被发布到DLQ 到目前为止一切都很好。现在,我向队列发布多条消息,并观察到与上述相同的行为 现在我希望断路器在第三条消息被消耗、重试并发布到 DLQ 后启动。第 3 条消息预计在 2.5 分钟过去后才会消耗后续消息 然而,订阅者似乎很高兴地消费消息,没有任何断路器启动的迹象。 注意 - 我想使用 <redelivery-policy maxRedeliveryCount="1"/> 并且不依赖于 Anypointmq 队列上配置的最大交付量(默认为 10) 所以不确定为什么断路器没有启动? 来自 连接器文档 如果 Mule 流完成执行时出现错误,订阅者源会检查该错误是否是指示外部服务错误的 onErrorType 之一,并计算连续发生的次数,直到达到 errorThreshold。 因此,错误应该是连续的,才能将电路转换为“开路”状态。您的实现问题在于您有 on-error-continue 表示 REDELIVERY_EXHAUSTED 错误,这意味着订阅者会将轮询的执行视为成功而不是错误。因此它将停止电路进入开路状态并且错误计数器将重置 为了使其与 redelivery-policy 一起使用,您需要进行以下更改 将 on-error-continue 更改为 on-error-propogate 将订阅者配置为使用手动确认模式而不是自动 在 on-error-propogate 错误处理程序中添加 ACK,以从 MQ 中删除消息在流程末尾添加 ACK 以从 MQ 中删除消息 默认添加NACKREDELIVERY_EXHAUSTED以保留下一次轮询的消息 这将使源不会将on-error-propogate视为成功,并且电路应在连续 3 个错误后打开(即REDELIVERY_EXHAUSTED)
我有一个 Java 对象作为输入负载: { “名字”=“迈克尔”, “姓”=“阿尔法”, “邮件”=“[email protected]”, “性别”=“男” } 我想更改性别值,保留消息的其余部分: %dw 2.0 哦...
我有一个 Mule 4 应用程序的输入负载: { “P_CUST_ACCOUNTS”:[ { “ACCOUNT_NUMBER”:62972, “ADDR_CHG_FLAG”:“N” }, { &
我有一个 MuleSoft 应用程序的输入有效负载,如下所示...... { “P_CUST_ACCOUNTS”:[ { “ACCOUNT_NUMBER”:62972, “ADDR_CHG_FLAG”:“N” },...
我正在将 API 日志从 MuleSoft CloudHub 发送到 Datadog。我可以通过对应用程序的 log4j2.xml 进行必要的更改来发送日志。我们有几个 MuleSoft
我们正在将 Mule 3 api 迁移到 Mule 4,并观察到一些在 Mule 3 中无法理解的行为...... 我们有来自 HTTP 端点的传入负载 { 员工编号: 10, empAg...
Hazelcast 实例未激活! (com.hazelcast.core.HazelcastInstanceNotActiveException)。消息负载的类型为:HashMap
我用MuleSoft 3.5.1在java中实现了一个服务应用程序,它在集群服务器中工作,有时我会收到错误“Hazelcast实例未激活!”以及所有服务...
上传自定义策略的实现后,当尝试部署时,我在日志中看到两个错误,这是第一个错误: 错误 2024-06-17 18:53:05,449 [agw-policy-set-deployment...
如何配置 mule 独立,以便它从 MULE_HOME/lib/user 获取属性文件?
在哪里可以配置 mule 独立版本 4.6.2,以便部署的应用程序将从 MULE_HOME/lib/user 文件夹而不是项目文件夹 src/main/resources 获取属性文件 在全局元素中...