问题标签 [mule4]

需要您的帮助才能在 Mule 4 - Dataweave 2.0 中将日期格式从 ORACLE-DB 转换为 SFDC。

这是从 Oracel-DB16-DEC-19 02.24.19.385439000 PM或16-DEC-19 02.24.19.385439000 AM. 这需要转换成 SFDC 格式2019-12-16。

等待您的回复。非常感谢...！！！

我正在尝试从 json 数据中找到日期的最大值。但我得到以下错误

设置变量组件中编写的逻辑是

在调试模式下运行时，发现问题出在 maxby 语句中。

请建议。如何解决此问题

我正在尝试在 mule 中调用 java 函数。我将有效负载转换为 Object 并将其传递给函数。创建的 Java 对象的名称是req。方法 validate 接受类型为 Example 的 Java 对象

示例类如下所示：

XML 配置如下所示：

我收到以下错误：

我不知道为什么它没有将java对象作为一个整体传递。

我正在尝试使用 mule maven 插件创建构建，它必须执行 MUnit 测试用例。我使用了一个配置属性，它已配置为 app-{mule.env}.yaml 在运行应用程序时它工作正常，因为我传递了参数 mule.env=dev 但在使用 mule maven 插件创建 maven 构建时导致失败下面是POM结构

MUnit 特定配置：

完成 POM

当我尝试使用 Maven 构建时，它会出现以下错误

应用程序-dev.yaml

该应用程序及其测试用例在 Anypoint Studio 中正常工作，但在 Maven 构建中唯一失败。

值：如果（LineItem.LineProcessInfo.LineRefNumberField3 ！= null）（LineItem.LineProcessInfo.LineRefNumberField3）否则“”

对于 LineRefNumberField3 长度应为 5，如果小于 5，则向左填充零，我需要得到 00022，请建议如何实现。

我的代码看起来像这样

因此，在上面的代码中，我循环每个行项以获取字段，但是在每个行项中，我必须为每个注释循环，并且对于每个注释，我需要将它放在不同的行中。例如，输出应如下所示，如您在示例中所见，如果行项目 2 有 3 个评论部分，我有 3 行 3 个评论。

我在 XMl 上方映射到 CSV 管道分隔格式，需要有关如何循环和打印 CommentText 值的帮助。

我的代码看起来像这样

在上面的代码中，我需要检查条件if NoteType = MB and NoteCode =05，我必须遍历每个注释文本并在 DistributionOrder 下获取值， [00000_ 1_2_3_4_5_6_7]我需要将每个值（例如 1、2、3...7）放在每一行中。

社区！

我正在尝试将我的 Mulesoft 应用程序连接到 Heroku 托管的 Kafka 服务器。Anypoint Studio 7 (Mule 4) 有一个 Kafka 连接器，它有几个连接选项（Basic、Kerberos、Kerberos SSL 和 SSL）：

根据 Heroku 的文档，它“支持” SSL，但没有提到这是必需的。任何人都可以确认吗？

我看到的 Heroku 文档 [ https://devcenter.heroku.com/articles/kafka-on-heroku]

当我在 Heroku 上设置应用程序时，添加 Kafka AddOn，创建主题，我通过运行命令获取引导服务器heroku config:get KAFKA_URL 如果我尝试进行基本测试，则会收到以下错误：

错误状态org.mule.runtime.api.connection.ConnectionException: invalid connection! org.mule.runtime.api.connection.ConnectionException: invalid connection! Caused by: org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.

我正在尝试构建的是一个具有 2 个流的 PoC……一个产生到主题的消息，另一个流从中消费。

任何有关如何设置连接器和 Heroku 环境的帮助都将受到欢迎

更新：

我发现当你在 Heroku 创建应用程序并包含 KAFKA 插件时，你会得到以下变量：

KAFKA_URL：组成集群的 Kafka 代理的 SSL URL 的逗号分隔列表。例子：

kafka+ssl://ec2-3-*****-100.compute-1.amazonaws.com:9096,kafka+ssl://ec2-3-******-127.compute-1 .amazonaws.com:9096

KAFKA_TRUSTED_CERT：代理的 SSL 证书（PEM 格式），用于检查您是否连接到正确的服务器。例子：

-----BEGIN CERTIFICATE----- MIIDfzCCAmegAwIBAgIBADANBgkqhkiG9w0BAQsFADAyMTAwLgYDVQQDDCdjYS1l ZjQwOWUzNy00NjhhLTRiMGEtOGVkOC0wZWYxMmRhYjkyZWEwHhcNMTkxMjEyMTUx NzU5WhcNMjkxMjEyMTUxNzU5WjAyMTAwLgYDVQQDDCdjYS1lZjQwOWUzNy00Njhh

KAFKA_CLIENT_CERT：根据代理对客户端进行身份验证所需的客户端证书（PEM 格式）。例子：

-----BEGIN CERTIFICATE----- MIIDQzCCAiugAwIBAgIBADANBgkqhkiG9w0BAQsFADAyMTAwLgYDVQQDDCdjYS1l ZjQwOWUzNy00NjhhLTRiMGEtOGVkOC0wZWYxMmRhYjkyZWEwHhcNMjAwMTE1MTU1 MjU2WhcNMzAwMTE1MTU1MjU2WjAZMRcwFQYDVQQDDA51NnZtYWVzM2cwZnMyZjCC

KAFKA_CLIENT_CERT_KEY：根据代理对客户端进行身份验证所需的客户端证书密钥（PEM 格式）。Kafka 集群需要使用提供的客户端证书进行身份验证。任何不使用客户端证书的请求都将被拒绝。例子：

-----开始 RSA 私钥----- MIIEpAIBAAKCAQEAmmu+j9DulVnqwIOt02++6Ehw9Mg7KaocdIQjODVtVipC5AyK iaHsdNVh9bgJQAJSfstIV/6O1mCLmjUS/YmyIEEgmBvATFxcldPGBGcpPVSV2R3Q

我假设我需要将它们“转换”为连接器 SSL 配置的 KeyStore 和 TrustStore .. 任何人都可以确认吗？因为对于我从文档中看到的内容，需要 SSL

另一个更新：

我下载了上面描述的证书并使用“密钥资源管理器”工具创建了一个 keystore.jks 并将 KAFKA_CLIENT_CERT 和 KAFKA_CLIENT_CERT_KEY 导入其中，然后我创建了一个 truststore.jsk 并在那里导入了文件 KAFKA_TRUSTED_CERT。在这两种情况下，我都设置了基本密码……看起来不错，但出现错误：

可能与以下原因有关：

java.security.cert.CertificateException：找不到与 ec2-3-220-121-33.compute-1.amazonaws.com 匹配的名称

在阅读 Excel 表时，我需要显示所有列值，即使它们是空的。

但是，除非最后一个单元格有值，否则骡子不会考虑空单元格。

我的要求是我需要映射所有列值，即使它们是空的。

Dateweave 脚本如下所示：

HTTP 侦听器设置为：

下面的图片可能会更好地展示：

我的代码看起来像这样

forcolumn_6条件是 ifNoteType = MB和NoteCode =05I 必须遍历每个注释文本和下面DistributionOrder [00000_8769_741_82_093_965_987_456]，并且有 8[0 到 7] 个值用下划线分隔。我需要检查从 1 到 7 的值是否即将到来，然后如果值不为空，则将增量 01 分配给 07。如果其中一个值是空的，则跳过该数字分配下一个数字（例如，如果第 5 个值是空的然后跳过 05 并分配 06)。