Azure 数据工厂上传到 Salesforce 并引用另一个对象上的字段
Azure Datafactory Upload to Salesforce and reference field on another object
这就是场景 - 我们正在使用 Azure DataFactoryV2 运行 一系列管道,这些管道从本地数据源获取帐户数据,将其转换并上传到 Salesforce。
目前我们想要导入一个帐户并将其关联到另一个帐户。存在标准的 Parent/Child 帐户关系(例如经销商帐户和子帐户),并且使用内部 Salesforce ID。
我们还使用外部 ID 进行更新,并且此 ID 对于每条记录都是唯一的。
根据 SF 文档:Here - 当您手动调用 API 并将其传递给 JSON 文件时,您可以在 JSON:
{
"Name" : "NewAccount",
"account__r" :
{
"Ext_UID__c" : 123
}
}
但是,这在 Azure DataFactoryV2 中似乎无法在代码中指定查找关系,或者如果可以,我不确定该怎么做。
供参考 - 这是管道 JSON 代码:
{
"name": "Import_to_Salesforce",
"properties": {
"activities": [
{
"name": "Load_to_Salesforce",
"type": "Copy",
"policy": {
"timeout": "7.00:00:00",
"retry": 0,
"retryIntervalInSeconds": 30,
"secureOutput": false,
"secureInput": false
},
"userProperties": [
{
"name": "Source",
"value": "[dbo].[Account]"
},
{
"name": "Destination",
"value": "Account"
}
],
"typeProperties": {
"source": {
"type": "SqlSource"
},
"sink": {
"type": "SalesforceSink",
"writeBatchSize": 5000,
"writeBehavior": "upsert",
"externalIdFieldName": "Ext_UID__c",
"ignoreNullValues": false
},
"enableStaging": false,
"enableSkipIncompatibleRow": true,
"dataIntegrationUnits": 0,
"translator": {
"type": "TabularTranslator",
"columnMappings": {
"Name": "Name",
"ParentId": "ParentId",
"BillingStreet": "BillingStreet",
"BillingCity": "BillingCity",
"BillingPostalCode": "BillingPostalCode",
"BillingCountry": "BillingCountry",
"ShippingStreet": "ShippingStreet",
"ShippingCity": "ShippingCity",
"ShippingPostalCode": "ShippingPostalCode",
"ShippingCountry": "ShippingCountry",
"Phone": "Phone",
"AccountNumber": "AccountNumber",
"Brand__c": "Brand__c",
"Account_Status__c": "Account_Status__c",
"Account_Type__c": "Account_Type__c",
"Preferred_Payment_Method__c": "Preferred_Payment_Method__c",
"Last_Account_Login__c": "Last_Account_Login__c",
"Ext_UID__c": "Ext_UID__c",
"Auto_Renew_Status__c": "Auto_Renew_Status__c",
"Account_Balance__c": "Account_Balance__c",
"Outstanding_Amount_30_days__c": "Outstanding_Amount_30_days__c",
"Outstanding_Amount_60_days__c": "Outstanding_Amount_60_days__c",
"Outstanding_Amount_90_days__c": "Outstanding_Amount_90_days__c",
"Account_Priority__c": "Account_Priority__c",
"Reseller__c": "Reseller__c",
"Last_Payment__c": "Last_Payment__c"
}
}
},
"inputs": [
{
"referenceName": "Staging_Source",
"type": "DatasetReference"
}
],
"outputs": [
{
"referenceName": "Destination_Load_to_Salesforce",
"type": "DatasetReference"
}
]
}
]
},
"type": "Microsoft.DataFactory/factories/pipelines"}
如有任何意见,我们将不胜感激。
查找 Activity 在 ADF v2 中可用:
在这里您可以select您要查找的数据集和行。
希望对您有所帮助!
您使用的是哪个 SF 连接器?如果没有有意义的名称,请查看您的 API 用户在 Salesforce 中的登录历史记录。它可能被列为 "Simba Technologies" 或类似的东西?
对于标准关系,您应该可以只键入 Account.Ext_UID__c
Parent.Ext_UID__c
,就像在这个联系人加载中一样:
对于自定义 lookups/master-detail 字段,如果字段 API 名称为 Account__c
,您可以将其映射为 Account__r.Ext_UID__c
.
只需确保父帐户在子帐户引用它们之前存在...也许您在之前的工作中加载了它们,也许最好分两个阶段加载它:
- 没有父级映射的所有帐户的平 insert/upsert
- Reparenting update/upsert 仅映射此记录的分机 ID 和父分机。编号
这就是场景 - 我们正在使用 Azure DataFactoryV2 运行 一系列管道,这些管道从本地数据源获取帐户数据,将其转换并上传到 Salesforce。
目前我们想要导入一个帐户并将其关联到另一个帐户。存在标准的 Parent/Child 帐户关系(例如经销商帐户和子帐户),并且使用内部 Salesforce ID。
我们还使用外部 ID 进行更新,并且此 ID 对于每条记录都是唯一的。
根据 SF 文档:Here - 当您手动调用 API 并将其传递给 JSON 文件时,您可以在 JSON:
{
"Name" : "NewAccount",
"account__r" :
{
"Ext_UID__c" : 123
}
}
但是,这在 Azure DataFactoryV2 中似乎无法在代码中指定查找关系,或者如果可以,我不确定该怎么做。
供参考 - 这是管道 JSON 代码:
{
"name": "Import_to_Salesforce",
"properties": {
"activities": [
{
"name": "Load_to_Salesforce",
"type": "Copy",
"policy": {
"timeout": "7.00:00:00",
"retry": 0,
"retryIntervalInSeconds": 30,
"secureOutput": false,
"secureInput": false
},
"userProperties": [
{
"name": "Source",
"value": "[dbo].[Account]"
},
{
"name": "Destination",
"value": "Account"
}
],
"typeProperties": {
"source": {
"type": "SqlSource"
},
"sink": {
"type": "SalesforceSink",
"writeBatchSize": 5000,
"writeBehavior": "upsert",
"externalIdFieldName": "Ext_UID__c",
"ignoreNullValues": false
},
"enableStaging": false,
"enableSkipIncompatibleRow": true,
"dataIntegrationUnits": 0,
"translator": {
"type": "TabularTranslator",
"columnMappings": {
"Name": "Name",
"ParentId": "ParentId",
"BillingStreet": "BillingStreet",
"BillingCity": "BillingCity",
"BillingPostalCode": "BillingPostalCode",
"BillingCountry": "BillingCountry",
"ShippingStreet": "ShippingStreet",
"ShippingCity": "ShippingCity",
"ShippingPostalCode": "ShippingPostalCode",
"ShippingCountry": "ShippingCountry",
"Phone": "Phone",
"AccountNumber": "AccountNumber",
"Brand__c": "Brand__c",
"Account_Status__c": "Account_Status__c",
"Account_Type__c": "Account_Type__c",
"Preferred_Payment_Method__c": "Preferred_Payment_Method__c",
"Last_Account_Login__c": "Last_Account_Login__c",
"Ext_UID__c": "Ext_UID__c",
"Auto_Renew_Status__c": "Auto_Renew_Status__c",
"Account_Balance__c": "Account_Balance__c",
"Outstanding_Amount_30_days__c": "Outstanding_Amount_30_days__c",
"Outstanding_Amount_60_days__c": "Outstanding_Amount_60_days__c",
"Outstanding_Amount_90_days__c": "Outstanding_Amount_90_days__c",
"Account_Priority__c": "Account_Priority__c",
"Reseller__c": "Reseller__c",
"Last_Payment__c": "Last_Payment__c"
}
}
},
"inputs": [
{
"referenceName": "Staging_Source",
"type": "DatasetReference"
}
],
"outputs": [
{
"referenceName": "Destination_Load_to_Salesforce",
"type": "DatasetReference"
}
]
}
]
},
"type": "Microsoft.DataFactory/factories/pipelines"}
如有任何意见,我们将不胜感激。
查找 Activity 在 ADF v2 中可用:
在这里您可以select您要查找的数据集和行。
希望对您有所帮助!
您使用的是哪个 SF 连接器?如果没有有意义的名称,请查看您的 API 用户在 Salesforce 中的登录历史记录。它可能被列为 "Simba Technologies" 或类似的东西?
对于标准关系,您应该可以只键入 Account.Ext_UID__c
Parent.Ext_UID__c
,就像在这个联系人加载中一样:
对于自定义 lookups/master-detail 字段,如果字段 API 名称为 Account__c
,您可以将其映射为 Account__r.Ext_UID__c
.
只需确保父帐户在子帐户引用它们之前存在...也许您在之前的工作中加载了它们,也许最好分两个阶段加载它:
- 没有父级映射的所有帐户的平 insert/upsert
- Reparenting update/upsert 仅映射此记录的分机 ID 和父分机。编号