如何根据特定条件以 CSV 格式打印记录值而不重复数据编织中的某些字段

Question

请考虑CSV中的以下输入示例

Company,FirstName,LastName,Email
Rate,Manule,Reaya,[e-mail]
Rate,sholy,Bonvgy,[e-mail]

输出应如下：

Company,FirstName,LastName,Email
Rate,Manule,Reaya,[e-mail]
,sholy,Bonvgy,[e-mail]

条件是：如果公司名称在输入中的不同记录中重复，则在输出 CSV 中应为空。

请让我知道这是否可以在 Mule 的数据编织组件中处理

下面是更新的代码

<?xml version="1.0" encoding="UTF-8"?>

<mule xmlns:file="http://www.mulesoft.org/schema/mule/file" xmlns:dw="http://www.mulesoft.org/schema/mule/ee/dw" xmlns="http://www.mulesoft.org/schema/mule/core" xmlns:doc="http://www.mulesoft.org/schema/mule/documentation"
    xmlns:spring="http://www.springframework.org/schema/beans" 
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-current.xsd
http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/current/mule.xsd
http://www.mulesoft.org/schema/mule/file http://www.mulesoft.org/schema/mule/file/current/mule-file.xsd
http://www.mulesoft.org/schema/mule/ee/dw http://www.mulesoft.org/schema/mule/ee/dw/current/dw.xsd">

    <configuration doc:name="Configuration">
     <expression-language>
         <global-functions>
            def getCompanyName(Company){
                 if (flowVars.companyList contains Company) {
                    return "";
                 }  else {
                    flowVars.companyList.add(Company);
                    return Company;
                 }
            }
          </global-functions>
     </expression-language>
 </configuration>
    <file:connector name="File" autoDelete="true" streaming="true" validateConnections="true" doc:name="File"/>
    <file:connector name="File1" autoDelete="true" outputAppend="true" streaming="true" validateConnections="true" doc:name="File"/>
    <flow name="csvtocsvrecordemptyFlow">
        <file:inbound-endpoint path="src\test\resources\input" connector-ref="File" responseTimeout="10000" doc:name="File"/>
        <set-variable variableName="companyList" value="[[]]" doc:name="Variable"/>
        <dw:transform-message doc:name="Transform Message">
            <dw:set-payload><![CDATA[%dw 1.0
%output application/csv header=true
---
payload map {
    CompanyName: getCompanyName($.Company),
    name:$.FirstName
}]]></dw:set-payload>
        </dw:transform-message>

        <file:outbound-endpoint path="src\test\resources\output" outputPattern="test.csv" connector-ref="File1" responseTimeout="10000" doc:name="File"/>
    </flow>
</mule>

Answer 1

@Akil Karthik:当我尝试解决方案时，它仍然显示强制二进制到数组错误。我已经在变量声明中提供了MIME类型application/csv。

Answer 2

然而，问题是将使用的公司名称存储在内存中，仅使用DataWeave。我认为这是做不到的。但是如果你结合MEL Global函数和DataWeave，你应该能够实现这一点。

在mule配置中添加一个全局MEL函数，如下所示

<configuration doc:name="Configuration">
     <expression-language>
         <global-functions>
            def getCompanyName(name){
                 if (flowVars.companyList contains name) {
                    return "";
                 }  else {
                    flowVars.companyList.add(name);
                    return name;
                 }
            }
          </global-functions>
     </expression-language>
 </configuration>

在流程中，在数据编织之前初始化一个空数组。

<set-variable value="#[[]]" variableName="companyList" doc:name="Variable" />

然后，在dataweave中，使用MEL函数-

...
companyName: getCompanyName($.name)
...

您可以在 MEL 函数中编写任何自定义逻辑，这些逻辑可以计算名称并向 DataWeave 返回一些值。