0

使用 upsert 选项通过 CDK 创建从 S3 存储桶到 salesforce 的应用程序流。

使用从 S3 到 Salesforce 的现有连接 -

new appflow.CfnConnectorProfile(this, 'Connector',{
  "connectionMode": "Public",
  "connectorProfileName":"connection_name",
  "connectorType":"Salesforce"
})

目的地流代码 -

new appflow.CfnFlow(this, 'Flow', {
destinationFlowConfigList: [
    {
      "connectorProfileName": "connection_name",
      "connectorType": "Salesforce",
      "destinationConnectorProperties": {
        "salesforce": {
          "errorHandlingConfig": {
            "bucketName": "bucket-name",
            "bucketPrefix": "subfolder",
          },
          "idFieldNames": [
            "ID"
          ],
          "object": "object_name",
          "writeOperationType": "UPSERT"
        }
      }
    }
  ],
..... other props ....
}

tasks: [
    {
      "taskType":"Filter",
      "sourceFields": [
        "ID",
        "Some other fields",
        ...
        ],
      "connectorOperator": {
        "salesforce": "PROJECTION"
      }
    },
    {
      "taskType":"Map",
      "sourceFields": [
          "ID"
        ],
      "taskProperties": [
          {
            "key":"SOURCE_DATA_TYPE",
            "value":"Text"
          },
          {
            "key":"DESTINATION_DATA_TYPE",
            "value":"Text"
        }
        ],
      "destinationField": "ID",
      "connectorOperator": {
        "salesforce":"PROJECTION"
      }
    },
   {
   .... some other mapping fields.....
   }

但问题是——"Invalid request provided: AWS::AppFlow::FlowCreate Flow request failed: [ID does not exist in the destination conne ctor]

根据错误,如何解决现有连接器导致的问题ID does not exist in the destination connector

PS:ID在流程代码中定义。但它仍然说没有找到ID。

4

0 回答 0