Mule是一个基于Java的轻量级企业服务总线(ESB)和集成平台,允许开发人员快速,轻松地将应用程序连接在一起,使他们能够交换数据。无论应用程序使用何种不同的技术,Mule都可以轻松集成现有系统,包括JMS,Web服务,JDBC,HTTP等。
有没有简单的方法可以在 mule 4 中将 CSV 转换为 JSON?目前我正在这样做,如下所示。 %dw 2.0 输出应用程序/json --- (有效负载分割(' ')) 映射 using( tmp = $ splitBy(',')) {...
如何使用 groupby 并使用 dataweave 2.0 为该特定 groupby 添加新的键值对
我有一个 JSON 对象有效负载数组,我需要根据多个键进行分组,并为分组中的每个对象添加两个新的键值对。第一个键值对是根据键求和
我想从服务器读取固定宽度的响应。 响应样本 PQRSBNGL1234567890AAHG 这是示例 ffd 文件 形式: 抄写本 价值观: - 名称:“医院” 价值观: - 名称:“基本信息” 维...
这是我上一个问题How to upload multiple files via REST over HTTP using Mule?的扩展。要求每周三上午 10 点必须上传文件。因此...
我们如何使用 Dataweave 检查 Payload 中的日期格式
我们有一个要求,其中源是一个文件,并且它有一个可以包含不同日期格式的日期字段。例如 MM/dd/yyyy 或 MM/dd/yy 或 MM-dd-yyyy 或 MM-dd-yy。我们想要这个日期字段...
我的场景是检查月份和年份(以日期值表示)是否小于当前月份和年份(以当前日期值表示)。 我需要实现的条件是这样的 如果来源月份和年份 <
有人可以帮我解决下一个问题吗: 我需要根据下一个条件从有效负载对象中删除:如果某个特定键为空,我需要删除整个对象,其中包含...
为了实现库的预期用途,我需要从处理日志记录的被调用子流中记录调用流名称。是否可以从子流中检索调用流的名称? 我
我收到一个 JSON 有效负载,其中两列包含值数组。我们想要将数组列拆分为多行。 输入示例: [ { “名字”:“约翰”,...
如何使用dataweave 2.0动态地将字符串列表转换为键值对
我有一个下面的输入,其中有键“Actual_Amount”,它是一个字符串列表。我想根据字符串中值的数量将此键转换为多个键。 输入: [ { &...
有没有办法在 Spring Boot 中进行 JSON 转换,类似于 MuleSoft Dataweave 操作?
我有兴趣进行任何复杂的 JSON 到 JSON(任何)或 JSON 到平面文件的转换,就像在 MuleSoft 中完成的那样(使用像 map、filter、pluck、orderBy、groupBy 等运算符),但是在 spring b.. .
我正在编写一个 GraphQL 查询,我必须使用 $like 但我收到一个语法错误:Unexpected from the GraphQl service 我怎样才能像字符串一样使用 $like 而不会出现此错误? 我试试这个: '有趣...
我正在尝试使用带有两个动态输入的 dataweave 生成如下所示的数组,即 mule 中的totalCount=1000 和 splitNumber=100 。我可以在 Java 脚本中执行相同的操作,但不知道如何实现...
如何在 Mulesoft 中部署 Restful Web API
我们使用Visual studio进行API开发。我们的客户希望我们使用 Mule 软件进行 API 管理。 任何人都可以提供有关如何部署和管理现有休息的步骤或相关文章...
在 Mule 4 中从 AWS S3 上的特定存储桶获取对象
我想从 Mule 4 中的 S3 存储桶读取文件(对象)。 我只能访问此存储桶的读/写文件。因此,当我在 AWS S3 连接器的全局配置中输入访问密钥和秘密并执行...
套接字连接器 - 有没有办法读取数据而不是发送和接收 - Mule 4
任何人都知道如何从 TCP 连接读取数据, 根据我的要求,我需要从 TCP 读取数据并处理该数据并将响应写回 TCP 服务器。 但我没有看到任何接收
如何将传入的具有对象的 JSON 有效负载转换为具有下游系统期望的对象列表的有效负载
输入负载: { "9873452": "74298", "9067329": "32115" "1234556": "98765" } 预期输出有效负载 { “提供商”:&...
大家好,我正在尝试根据 data weave 2.0 中的数组更新和创建字段 例如这是我的输入 { “身体”:{ “字段1”:“a”, “……
Mule - 尝试通过 HTTPS 发送消息时“无法找到请求目标的有效证书路径”
我有一个 Mule 流程(Mule CE 3.4.0、Studio 3.5.0),它正在处理一些 XML 并使用 HTTPS 端点将其发布到 Web 服务,如下所示: 我有一个 Mule 流程(Mule CE 3.4.0、Studio 3.5.0),它正在处理一些 XML 并使用 HTTPS 端点将其发布到 Web 服务,如下所示: <flow> <!-- Process XML --> <https:outbound-endpoint address="https://admin:password@localhost:8081/hello" exchange-pattern="request-response" contentType="text/xml" method="POST" doc:name="HTTP"/> <!-- Evaluate response --> </flow> 在生产中,这将访问由不同平台公开的 Web 服务,但为了在本地进行测试,我创建了一个完全独立的 Mule 应用程序(单独的工作区、项目文件等),它公开了一个 HTTPS 端点来使用消息: <spring:beans> <security:authentication-manager alias="MyManager"> <security:authentication-provider> <security:user-service id="UserService"> <security:user name="admin" password="password" authorities="ROLE_ADMIN"/> </security:user-service> </security:authentication-provider> </security:authentication-manager> </spring:beans> <spring-security:security-manager> <spring-security:delegate-security-provider name="InMemory" delegate-ref="MyManager"/> </spring-security:security-manager> <https:connector name="httpsConnector"> <https:tls-key-store path="test.jks" keyPassword="test1234" storePassword="test1234"/> </https:connector> <flow name="httpTestFlow" doc:name="httpTestFlow"> <https:inbound-endpoint exchange-pattern="one-way" host="localhost" port="8081" doc:name="HTTP" connector-ref="httpsConnector"> <spring-security:http-security-filter realm="mule-realm" securityProviders="InMemory"/> </https:inbound-endpoint> <object-to-string-transformer doc:name="Object to String"/> <logger level="INFO" message="The XML message received is: #[payload]" doc:name="Logger"/> </flow> 当我尝试运行此程序时,我的 Mule 应用程序(发送 XML 的应用程序)中出现以下错误: ******************************************************************************** Message : Failed to route event via endpoint: DefaultOutboundEndpoint{endpointUri=https://admin:<password>@localhost/hello, connector=HttpsConnector { name=connector.https.mule.default lifecycle=start this=7cc4f42c numberOfConcurrentTransactedReceivers=4 createMultipleTransactedReceivers=true connected=true supportedProtocols=[https] serviceOverrides=<none> } , name='endpoint.https.localhost.8081.hello', mep=REQUEST_RESPONSE, properties={http.method=POST, Content-Type=text/xml}, transactionConfig=Transaction{factory=null, action=INDIFFERENT, timeout=0}, deleteUnacceptedMessages=false, initialState=started, responseTimeout=10000, endpointEncoding=UTF-8, disableTransportTransformer=false}. Message payload is of type: PostMethod Code : MULE_ERROR--2 -------------------------------------------------------------------------------- Exception stack is: 1. unable to find valid certification path to requested target (sun.security.provider.certpath.SunCertPathBuilderException) sun.security.provider.certpath.SunCertPathBuilder:196 (null) 2. PKIX path building failed: sun.security.provider.certpath.SunCertPathBuilderException: unable to find valid certification path to requested target (sun.security.validator.ValidatorException) sun.security.validator.PKIXValidator:385 (null) 3. sun.security.validator.ValidatorException: PKIX path building failed: sun.security.provider.certpath.SunCertPathBuilderException: unable to find valid certification path to requested target (javax.net.ssl.SSLHandshakeException) sun.security.ssl.Alerts:192 (http://java.sun.com/j2ee/sdk_1.3/techdocs/api/javax/net/ssl/SSLHandshakeException.html) 4. Failed to route event via endpoint: DefaultOutboundEndpoint{endpointUri=https://admin:<password>@localhost/hello, connector=HttpsConnector { name=connector.https.mule.default lifecycle=start this=7cc4f42c numberOfConcurrentTransactedReceivers=4 createMultipleTransactedReceivers=true connected=true supportedProtocols=[https] serviceOverrides=<none> } , name='endpoint.https.localhost.8081.hello', mep=REQUEST_RESPONSE, properties={http.method=POST, Content-Type=text/xml}, transactionConfig=Transaction{factory=null, action=INDIFFERENT, timeout=0}, deleteUnacceptedMessages=false, initialState=started, responseTimeout=10000, endpointEncoding=UTF-8, disableTransportTransformer=false}. Message payload is of type: PostMethod (org.mule.api.transport.DispatchException) org.mule.transport.http.HttpClientMessageDispatcher:155 (http://www.mulesoft.org/docs/site/current3/apidocs/org/mule/api/transport/DispatchException.html) -------------------------------------------------------------------------------- Root Exception stack trace: sun.security.provider.certpath.SunCertPathBuilderException: unable to find valid certification path to requested target at sun.security.provider.certpath.SunCertPathBuilder.engineBuild(SunCertPathBuilder.java:196) at java.security.cert.CertPathBuilder.build(CertPathBuilder.java:268) at sun.security.validator.PKIXValidator.doBuild(PKIXValidator.java:380) + 3 more (set debug level logging or '-Dmule.verbose.exceptions=true' for everything) ******************************************************************************** 我的其他应用程序收到消息时出现此错误: ERROR 2014-06-05 15:58:05,380 [[test-webservice].http.request.dispatch.8081.01] org.mule.exception.DefaultSystemExceptionStrategy: Caught exception in Exception Strategy: Received fatal alert: certificate_unknown javax.net.ssl.SSLHandshakeException: Received fatal alert: certificate_unknown at com.sun.net.ssl.internal.ssl.Alerts.getSSLException(Alerts.java:174) at com.sun.net.ssl.internal.ssl.Alerts.getSSLException(Alerts.java:136) at com.sun.net.ssl.internal.ssl.SSLSocketImpl.recvAlert(SSLSocketImpl.java:1822) at com.sun.net.ssl.internal.ssl.SSLSocketImpl.readRecord(SSLSocketImpl.java:1004) at com.sun.net.ssl.internal.ssl.SSLSocketImpl.performInitialHandshake(SSLSocketImpl.java:1188) at com.sun.net.ssl.internal.ssl.SSLSocketImpl.readDataRecord(SSLSocketImpl.java:818) at com.sun.net.ssl.internal.ssl.AppInputStream.read(AppInputStream.java:75) at com.sun.net.ssl.internal.ssl.AppInputStream.read(AppInputStream.java:50) at org.apache.commons.httpclient.HttpParser.readRawLine(HttpParser.java:78) at org.apache.commons.httpclient.HttpParser.readLine(HttpParser.java:106) at org.mule.transport.http.HttpServerConnection.readLine(HttpServerConnection.java:243) at org.mule.transport.http.HttpServerConnection.getRequestLine(HttpServerConnection.java:509) at org.mule.transport.http.HttpRequestDispatcherWork.run(HttpRequestDispatcherWork.java:70) at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918) at java.lang.Thread.run(Thread.java:695) 任何人都可以确定这里可能出了什么问题,或者建议一种在本地测试我的出站端点的替代方法吗?预先感谢。 您确定您的单独应用程序实际上正在运行吗?看起来好像不是:也许它只是无法启动? 任何人都可以解决这个问题吗?请 消息:资源“https://transaction-sapi1.us-e2.cloudhub.io:443/api/members/transactions”上的 HTTP POST 失败:PKIX 路径构建失败:sun.security.provider.certpath.SunCertPathBuilderException:无法找到请求目标的有效认证路径。 元素:(无) 元素 DSL :(无) 错误类型:HTTP:CONNECTIVITY FlowStack:(无) (为所有内容设置调试级别日志记录或“-Dmule.verbose.exceptions=true”)
我正在使用 Mule 4 来制作流程,在错误处理上我希望它将消息转换为使用现有有效负载的内容。 我的代码是 交易通知:{ 《测试》:“巴...