Menyalin data dari dan ke Salesforce V2 menggunakan Azure Data Factory atau Azure Synapse Analytics

BERLAKU UNTUK: Azure Data Factory Azure Synapse Analytics

Artikel ini menguraikan cara menggunakan Aktivitas Salin di Azure Data Factory dan alur Azure Synapse untuk menyalin data dari dan ke Salesforce. Artikel tersebut dibuat berdasarkan artikel Gambaran umum Salin Aktivitas yang menyajikan gambaran umum aktivitas salin.

Kemampuan yang didukung

Konektor Salesforce ini didukung untuk kemampuan berikut:

① Runtime integrasi Azure ② Runtime integrasi yang dihost sendiri

Untuk daftar penyimpanan data yang didukung sebagai sumber dan sink, lihat tabel penyimpanan data yang didukung.

Secara khusus, konektor Salesforce ini mendukung:

• Pengembang Salesforce, Profesional, Enterprise, atau edisi Unlimited.
• Menyalin data dari dan ke domain kustom (Domain kustom dapat dikonfigurasi di lingkungan produksi dan kotak pasir).

Anda dapat secara eksplisit mengatur versi API yang digunakan untuk membaca/menulis data melalui apiVersion properti di layanan tertaut. Saat Anda menyalin data ke Salesforce, konektor menggunakan BULK API 2.0.

Prasyarat

• Izin API harus diaktifkan di Salesforce.

• Anda perlu mengonfigurasi Connected Apps di portal Salesforce yang mengacu pada dokumen resmi ini atau panduan langkah demi langkah kami dalam rekomendasi dalam artikel ini.

  Penting

  • Pengguna eksekusi harus memiliki izin API Only.
  • Waktu kedaluwarsa Token Akses dapat diubah melalui kebijakan sesi alih-alih token refresh.

Batas Salesforce Bulk API 2.0

Kami menggunakan Salesforce Bulk API 2.0 untuk mengkueri dan menyerap data. Di API Massal 2.0, batch dibuat untuk Anda secara otomatis. Anda dapat mengirimkan hingga 15.000 batch per periode 24 jam bergulir. Jika batch melebihi batas, Anda mengalami kegagalan.

Dalam API Massal 2.0, hanya pekerjaan penyerapan yang mengonsumsi batch. Pekerjaan kueri tidak. Untuk detailnya, lihat Cara Permintaan Diproses di Panduan Pengembang API 2.0 Massal.

Untuk informasi selengkapnya, lihat bagian "Batas Umum" di batas pengembang Salesforce.

Memulai

Untuk melakukan aktivitas Salin dengan alur, Anda dapat menggunakan salah satu alat atau SDK berikut:

• Alat Penyalinan Data
• Portal Microsoft Azure
• SDK .NET
• SDK Python
• Azure PowerShell
• REST API
• Templat Azure Resource Manager

Membuat layanan tertaut ke Salesforce menggunakan antarmuka pengguna

Gunakan langkah-langkah berikut untuk membuat layanan tertaut ke Salesforce di antarmuka pengguna portal Microsoft Azure.

1. Telusuri ke tab Kelola di ruang kerja Azure Data Factory atau Synapse Anda dan pilih Layanan Tertaut, lalu klik Baru:

   • Azure Data Factory
   • Azure Synapse

   

2. Cari Salesforce dan pilih konektor Salesforce.

   

3. Konfigurasikan detail layanan, uji koneksi, dan buat layanan tertaut baru.

   

Detail konfigurasi konektor

Bagian berikut memberikan detail tentang properti yang digunakan untuk menentukan entitas khusus untuk konektor Salesforce.

Properti layanan tertaut

Properti berikut ini didukung untuk layanan tertaut Salesforce.

Contoh: Info masuk Microsoft Store

{
    "name": "SalesforceLinkedService",
    "properties": {
        "type": "SalesforceV2",
        "typeProperties": {
            "environmentUrl": "<environment URL>",
            "authenticationType": "OAuth2ClientCredentials",
            "clientId": "<client ID>",
            "clientSecret": {
                "type": "SecureString",
                "value": "<client secret>"
            },
            "apiVersion": "<API Version>"
        },
        "connectVia": {
            "referenceName": "<name of Integration Runtime>",
            "type": "IntegrationRuntimeReference"
        }
    }
}

Menyimpan info masuk di Key Vault

{
    "name": "SalesforceLinkedService",
    "properties": {
        "type": "SalesforceV2",
        "typeProperties": {
            "environmentUrl": "<environment URL>",
            "authenticationType": "OAuth2ClientCredentials",
            "clientId": "<client ID>",
            "clientSecret": {
                "type": "AzureKeyVaultSecret",
                "secretName": "<secret name of client secret in AKV>",
                "store":{
                    "referenceName": "<Azure Key Vault linked service>",
                    "type": "LinkedServiceReference"
                }
            },
            "apiVersion": "<API Version>"
        },
        "connectVia": {
            "referenceName": "<name of Integration Runtime>",
            "type": "IntegrationRuntimeReference"
        }
    }
}

Contoh: Menyimpan kredensial di Key Vault, serta environmentUrl dan clientId

Dengan melakukan penyimpanan kredensial di Key Vault, serta environmentUrl dan clientId, Anda dapat lebih lama menggunakan UI untuk mengedit pengaturan. Kotak centang Tentukan konten dinamis dalam format JSON harus dicentang, dan Anda harus mengkonfigurasikan ini secara manual. Keuntungan dari skenario ini adalah Anda dapat memperoleh semua pengaturan konfigurasi dari Key Vault alih-alih membuat parameter apa pun di sini.

{
    "name": "SalesforceLinkedService",
    "properties": {
        "type": "SalesforceV2",
        "typeProperties": {
            "environmentUrl": {
                "type": "AzureKeyVaultSecret",
                "secretName": "<secret name of environment URL in AKV>",
                "store": {
                    "referenceName": "<Azure Key Vault linked service>",
                    "type": "LinkedServiceReference"
                },
            },
            "authenticationType": "OAuth2ClientCredentials",
            "clientId": {
                "type": "AzureKeyVaultSecret",
                "secretName": "<secret name of client ID in AKV>",
                "store": {
                    "referenceName": "<Azure Key Vault linked service>",
                    "type": "LinkedServiceReference"
                },
            },
            "clientSecret": {
                "type": "AzureKeyVaultSecret",
                "secretName": "<secret name of client secret in AKV>",
                "store":{
                    "referenceName": "<Azure Key Vault linked service>",
                    "type": "LinkedServiceReference"
                }
            },
            "apiVersion": "<API Version>"
        },
        "connectVia": {
            "referenceName": "<name of Integration Runtime>",
            "type": "IntegrationRuntimeReference"
        }
    }
}

Properti himpunan data

Untuk daftar lengkap bagian dan properti yang tersedia untuk menentukan himpunan data, lihat artikel Himpunan Data. Bagian ini menyediakan daftar properti yang didukung oleh himpunan data Salesforce.

Untuk menyalin data dari dan ke Salesforce, atur properti jenis himpunan data ke SalesforceV2Object. Properti berikut ini didukung.

Contoh:

{
    "name": "SalesforceDataset",
    "properties": {
        "type": "SalesforceV2Object",
        "typeProperties": {
            "objectApiName": "MyTable__c"
        },
        "schema": [],
        "linkedServiceName": {
            "referenceName": "<Salesforce linked service name>",
            "type": "LinkedServiceReference"
        }
    }
}

Properti aktivitas salin

Untuk daftar lengkap bagian dan properti yang tersedia untuk menentukan aktivitas, lihat artikel Alur. Bagian ini menyediakan daftar properti yang didukung oleh sumber dan sink Salesforce.

Salesforce sebagai jenis sumber

Untuk menyalin data dari Salesforce, atur jenis sumber dalam aktivitas salin ke SalesforceV2Source. Properti berikut ini didukung di bagian sumber aktivitas salin.

Contoh:

"activities":[
    {
        "name": "CopyFromSalesforce",
        "type": "Copy",
        "inputs": [
            {
                "referenceName": "<Salesforce input dataset name>",
                "type": "DatasetReference"
            }
        ],
        "outputs": [
            {
                "referenceName": "<output dataset name>",
                "type": "DatasetReference"
            }
        ],
        "typeProperties": {
            "source": {
                "type": "SalesforceV2Source",
                "query": "SELECT Col_Currency__c, Col_Date__c, Col_Email__c FROM AllDataType__c",
                "includeDeletedObjects": false
            },
            "sink": {
                "type": "<sink type>"
            }
        }
    }
]

Salesforce sebagai jenis sink

Untuk menyalin data ke Salesforce, atur jenis sink dalam aktivitas salin ke SalesforceV2Sink. Properti berikut ini didukung di bagian sink aktivitas salin.

Contoh: Sink Salesforce dalam aktivitas salin

"activities":[
    {
        "name": "CopyToSalesforce",
        "type": "Copy",
        "inputs": [
            {
                "referenceName": "<input dataset name>",
                "type": "DatasetReference"
            }
        ],
        "outputs": [
            {
                "referenceName": "<Salesforce output dataset name>",
                "type": "DatasetReference"
            }
        ],
        "typeProperties": {
            "source": {
                "type": "<source type>"
            },
            "sink": {
                "type": "SalesforceV2Sink",
                "writeBehavior": "Upsert",
                "externalIdFieldName": "CustomerId__c",
                "writeBatchSize": 10000,
                "ignoreNullValues": true
            }
        }
    }
]

Pemetaan jenis data untuk Salesforce

Saat Anda menyalin data dari Salesforce, pemetaan berikut digunakan dari jenis data Salesforce ke jenis data sementara dalam layanan secara internal. Untuk mempelajari bagaimana aktivitas salin memetakan skema sumber dan jenis data ke sink, lihat Pemetaan skema dan jenis data.

Properti aktivitas pencarian

Untuk mempelajari detail tentang properti, lihat Aktivitas pencarian.

Meningkatkan konektor Salesforce

Berikut adalah langkah-langkah yang membantu Anda meningkatkan konektor Salesforce Anda:

1. Konfigurasikan aplikasi yang terhubung di portal Salesforce dengan merujuk ke Prasyarat.

2. Buat layanan tertaut Salesforce baru dan konfigurasikan dengan merujuk ke Properti layanan tertaut. Anda juga perlu memperbarui himpunan data yang ada secara manual yang mengandalkan layanan tertaut lama, mengedit setiap himpunan data untuk menggunakan layanan tertaut baru sebagai gantinya.

3. Jika Anda menggunakan kueri SQL di sumber aktivitas salin atau aktivitas pencarian yang merujuk ke layanan tertaut V1, Anda perlu mengonversinya ke kueri SOQL. Pelajari selengkapnya tentang kueri SOQL dari Salesforce sebagai jenis sumber dan Salesforce Object Query Language (SOQL).

4. readBehavior diganti dengan includeDeletedObjects di sumber aktivitas salin atau aktivitas pencarian. Untuk konfigurasi terperinci, lihat Salesforce sebagai jenis sumber.

Perbedaan antara Salesforce V2 dan V1

Konektor Salesforce V2 menawarkan fungsionalitas baru dan kompatibel dengan sebagian besar fitur konektor Salesforce V1. Tabel berikut ini memperlihatkan perbedaan fitur antara V2 dan V1.

Konten terkait

Untuk daftar penyimpanan data yang didukung sebagai sumber dan sink oleh aktivitas salin, lihat Penyimpanan data yang didukung.