Я хочу вставить в Salesforce записи, существующие в файле.txt без разделителя трубы, присутствующего в SFTP

Question

Я использую Mulesoft, чтобы получить все файлы без разделителей с заголовком.txt, имеющие определенные имена в SFTP. Затем я массово загружаю записи, существующие в этих файлах, в объект в Salesforce.

Программа не выдает никаких исключений, подключение к Salesforce прошло успешно, однако записи вообще не добавляются.

Проблемы здесь: 1- Файл.txt, а не.csv. 2- Файл не имеет заголовка. 3- Файл с разделителями трубы.

Пожалуйста, найдите ниже конфигурационный XML:

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

<mule xmlns:tracking="http://www.mulesoft.org/schema/mule/ee/tracking" xmlns:metadata="http://www.mulesoft.org/schema/mule/metadata" xmlns:dw="http://www.mulesoft.org/schema/mule/ee/dw" xmlns:sfdc="http://www.mulesoft.org/schema/mule/sfdc" xmlns:sftp="http://www.mulesoft.org/schema/mule/sftp" 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/sfdc http://www.mulesoft.org/schema/mule/sfdc/current/mule-sfdc.xsd
http://www.mulesoft.org/schema/mule/sftp http://www.mulesoft.org/schema/mule/sftp/current/mule-sftp.xsd
http://www.mulesoft.org/schema/mule/ee/dw http://www.mulesoft.org/schema/mule/ee/dw/current/dw.xsd
http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/current/mule.xsd
http://www.mulesoft.org/schema/mule/ee/tracking http://www.mulesoft.org/schema/mule/ee/tracking/current/mule-tracking-ee.xsd">



    <sfdc:config name="UpsertEmployees" username="xxx" password="xxx" securityToken="xxx" url="https://xxx.salesforce.com/services/Soap/u/37.0" doc:name="SFTP_Employees"/>  
    <sftp:connector name="SFTP_Employees" validateConnections="true" autoDelete="false" doc:name="SFTP_Employees">
        <service-overrides messageReceiver="ChalhoubSftpMessageReceiverEmployees"/>
    </sftp:connector>
      <flow name="Employees">
       <sftp:inbound-endpoint connector-ref="SFTP_Employees" host="xxx" port="22" path="//" user="xxx" password="xxx" responseTimeout="60000" autoDelete="false" doc:name="Get Employees"/>
       <message-chunk-splitter messageSize="1000000" doc:name="Employees Chunk Splitter"/>
       <dw:transform-message doc:name="Employees Transform Message" metadata:id="ec0f3517-05ed-47a4-a0a7-3b7e3d9037c1">
            <dw:input-payload mimeType="application/csv">
                <dw:reader-property name="header" value="false"/>
                <dw:reader-property name="separator" value="|"/>
            </dw:input-payload>
           <dw:set-payload><![CDATA[%dw 1.0
%output application/java
---
payload map {
    Employee_ID__c: $[0],
    Salutation__c: $[1],
    First_Name__c: $[2],
    Middle_Name__c: $[3],
    Last_Name__c: $[4],
    Name: '' when $[2] == null otherwise $[2] ++ ' ' ++ '' when $[3] == null otherwise $[3] ++ ' ' ++ '' when $[4] == null otherwise $[4],
    Address_1__c: $[5],
    Address_2__c: $[6],
    PO_Box__c: $[7],
    Email__c: $[8],
    City__c: $[9],
    Country__c: $[10],
    Residence_Phone__c: $[11],
    Office_Phone__c: $[12],
    Mobile_Phone__c: $[13],
    Location__c: $[14],
    Customer_Group__c: $[15],
    Loyalty_Card__c: $[16],
    Cash_Customer__c: $[17],
    Credit_Customer__c: $[18],
    Insert_Date__c: $[19],
    Username__c: $[20],
    Gen_Posting__c: $[21],
    Cust_Posting__c: $[22],
    Discount_Slab__c: $[23],
    Baan_Customer__c: $[24],
    VAT_Bus_Group__c: $[25],
    Gender__c: $[26],
    Age_Category__c: $[27],
    Customer_Type__c: $[28],
    Nationality_Group__c: $[29],
    Blocked__c: $[30],
    Date_of_Birth__c: $[31],
    Married__c: $[32],
    Working_Company__c: $[33],
    Job_Title__c: $[34]
}]]></dw:set-payload>
        </dw:transform-message>
        <sfdc:upsert-bulk config-ref="UpsertEmployees" type="Employee__c" externalIdFieldName="Employee_ID__c" doc:name="Upsert Employees">
            <sfdc:objects ref="#[payload]"/>
        </sfdc:upsert-bulk>
    </flow>


</mule>

Что может быть причиной отсутствия добавления записей в Salesforce?

Спасибо