使用 Azure Data Factory 或 Synapse Analytics 在 Azure SQL 受控執行個體中複製和轉換資料

適用於：Azure Data Factory Azure Synapse Analytics

本文概述如何使用複製活動從 Azure SQL 受控執行個體複製資料或將資料複製到其中，並使用資料流程在 Azure SQL 受控執行個體中轉換資料。 若要深入了解，請閱讀 Azure Data Factory 和 Synapse Analytics 的介紹文章。

支援的功能

此 Azure SQL 受控執行個體連接器支援下列功能：

① Azure 整合執行階段 ② 自我裝載整合執行階段

針對複製活動，此 Azure SQL Database 連接器支援下列功能：

• 搭配使用 SQL 驗證和 Microsoft Entra 應用程式權杖驗證與服務主體或 Azure 資源受控識別，來複製資料。
• 作為來源時，使用 SQL 查詢或預存程序來擷取資料。 您也可以選擇從 SQL MI 來源平行複製，如需詳細資訊，請參閱從 SQL MI 平行複製一節。
• 作為接收器，如果目的地資料表不存在，則會根據來源架構自動建立；在複製期間會將資料附加至資料表，或叫用具有自訂邏輯的預存程序。

必要條件

若要存取 SQL 受控執行個體公用端點，您可使用受控 Azure 整合執行階段。 確定您啟用了公用端點，而且允許網路安全性群組上的公用端點流量，讓服務可以連線到您的資料庫。 如需詳細資訊，請參閱此指導。

若要從取 SQL 受控執行個體私人端點，請設定可存取資料庫的自我裝載整合執行階段。 如果您將自我裝載整合執行階段佈建在受控執行個體所在的虛擬網路中，請確定您的整合執行階段機器位在與受控執行個體不同的子網路中。 如果您將自我裝載整合執行階段佈建在與受控執行個體不同的虛擬網路中，您可以使用虛擬網路對等互連或虛擬網路對虛擬網路的連線。 如需詳細資訊，請參閱將您的應用程式連線到SQL 受控執行個體。

開始使用

若要透過管線執行複製活動，您可以使用下列其中一個工具或 SDK：

• 資料複製工具
• Azure 入口網站
• .NET SDK
• Python SDK
• Azure PowerShell
• REST API
• Azure Resource Manager 範本

使用 UI 建立 Azure SQL 受控執行個體的連結服務

使用下列步驟，在 Azure 入口網站 UI 中建立 SQL 受控執行個體的連結服務。

1. 前往 Azure Data Factory 或 Synapse 工作區的 [管理] 索引標籤，選取 [連結服務]，然後按一下 [新增]：

   • Azure Data Factory
   • Azure Synapse

   

2. 搜尋 SQL，然後選取 Azure SQL Server 受控執行個體連接器。

   

3. 設定服務詳細資料，測試連線，然後建立新的連結服務。

   

連接器設定詳細資料

下列各節提供屬性的相關詳細資料，這些屬性是用來定義 SQL 受控執行個體連接器專屬的 Azure Data Factory 實體。

連結服務屬性

Azure SQL 受控執行個體連接器建議的版本支援 TLS 1.3。 請參閱本節，從舊版升級 Azure SQL 受控執行個體連接器版本。 如需屬性詳細資料，請參閱對應的章節。

• 建議的版本
• 舊版

建議的版本

當您套用建議的版本時，Azure SQL 受控執行個體連結服務支援這些泛型屬性：

如需其他連線屬性，請參閱下表：

SQL 驗證

若要使用 SQL 驗證，除了上一節所述的泛型屬性外，請指定下列屬性：

範例 1：使用 SQL 驗證

{
    "name": "AzureSqlMILinkedService",
    "properties": {
        "type": "AzureSqlMI",
        "typeProperties": {
            "server": "<name or network address of the SQL server instance>",
            "database": "<database name>",
            "encrypt": "<encrypt>",
            "trustServerCertificate": false,
            "authenticationType": "SQL",
            "userName": "<user name>",
            "password": {
                "type": "SecureString",
                "value": "<password>"
            }
        },
        "connectVia": {
            "referenceName": "<name of Integration Runtime>",
            "type": "IntegrationRuntimeReference"
        }
    }
}

範例 2：使用 SQL 驗證搭配 Azure Key Vault 中的密碼

{
    "name": "AzureSqlMILinkedService",
    "properties": {
        "type": "AzureSqlMI",
        "typeProperties": {
            "server": "<name or network address of the SQL server instance>",
            "database": "<database name>",
            "encrypt": "<encrypt>",
            "trustServerCertificate": false,
            "authenticationType": "SQL",
            "userName": "<user name>",
            "password": { 
                "type": "AzureKeyVaultSecret", 
                "store": { 
                    "referenceName": "<Azure Key Vault linked service name>", 
                    "type": "LinkedServiceReference" 
                }, 
                "secretName": "<secretName>" 
            }
        },
        "connectVia": {
            "referenceName": "<name of Integration Runtime>",
            "type": "IntegrationRuntimeReference"
        }
    }
}

範例 3：使用 SQL 驗證搭配 Always Encrypted

{
    "name": "AzureSqlMILinkedService",
    "properties": {
        "type": "AzureSqlMI",
        "typeProperties": {
            "server": "<name or network address of the SQL server instance>",
            "database": "<database name>",
            "encrypt": "<encrypt>",
            "trustServerCertificate": false,
            "authenticationType": "SQL",
            "userName": "<user name>",
            "password": {
                "type": "SecureString",
                "value": "<password>"
            }
        },
        "alwaysEncryptedSettings": {
            "alwaysEncryptedAkvAuthType": "ServicePrincipal",
            "servicePrincipalId": "<service principal id>",
            "servicePrincipalKey": {
                "type": "SecureString",
                "value": "<service principal key>"
            }
        },
        "connectVia": {
            "referenceName": "<name of Integration Runtime>",
            "type": "IntegrationRuntimeReference"
        }
    }
}

服務主體驗證

若要使用服務主體驗證，除了上一節所述的一般屬性外，請指定下列屬性

此外，請依照下列步驟操作：

1. 請遵循步驟來為受控執行個體佈建 Microsoft Entra 管理員。

2. 從 Azure 入口網站建立 Microsoft Entra 應用程式。 請記下應用程式名稱，以及下列可定義連結服務的值：

   • Application ID
   • 應用程式金鑰
   • 租用戶識別碼

3. 為服務主體建立登入。 在 SQL Server Management Studio (SSMS) 中，以系統管理員身分的 SQL Server 帳戶連線到您的受控執行個體。 在 master 資料庫中執行下列 T-SQL：

   CREATE LOGIN [your application name] FROM EXTERNAL PROVIDER
   

4. 針對服務主體，建立自主資料庫使用者。 連線到您想要從中複製資料的資料庫，然後執行下列 T-SQL：

   CREATE USER [your application name] FROM EXTERNAL PROVIDER
   

5. 依照您平常為 SQL 使用者或其他人所進行的操作一樣，將所需的權限授與服務主體。 執行下列程式碼。 如需更多選項，請參閱此文件。

   ALTER ROLE [role name e.g. db_owner] ADD MEMBER [your application name]
   

6. 設定 SQL 受控執行個體連結服務。

範例：使用服務主體驗證

{
    "name": "AzureSqlDbLinkedService",
    "properties": {
        "type": "AzureSqlMI",
        "typeProperties": {
            "server": "<name or network address of the SQL server instance>",
            "database": "<database name>",
            "encrypt": "<encrypt>",
            "trustServerCertificate": false,
            "hostNameInCertificate": "<host name>",
            "authenticationType": "ServicePrincipal",
            "servicePrincipalId": "<service principal id>",
            "servicePrincipalCredential": {
                "type": "SecureString",
                "value": "<application key>"
            },
            "tenant": "<tenant info, e.g. microsoft.onmicrosoft.com>"
        },
        "connectVia": {
            "referenceName": "<name of Integration Runtime>",
            "type": "IntegrationRuntimeReference"
        }
    }
}

系統指派的受控身分識別驗證

資料處理站或 Synapse 工作區可與 Azure 資源的系統指派受控識別相關聯，其代表用於向其他 Azure 服務驗證的服務。 您可以使用此受控識別來進行 SQL 受控執行個體驗證。 指定的服務可以使用此身分識別從您資料庫存取資料，或從您的資料庫複製資料。

若要使用系統指派的受控識別驗證，請指定上一節所述的一般屬性，並依照下列步驟操作。

1. 請遵循步驟來為受控執行個體佈建 Microsoft Entra 管理員。

2. 為系統指派的受控識別建立登入。 在 SQL Server Management Studio (SSMS) 中，以系統管理員身分的 SQL Server 帳戶連線到您的受控執行個體。 在 master 資料庫中執行下列 T-SQL：

   CREATE LOGIN [your_factory_or_workspace_ name] FROM EXTERNAL PROVIDER
   

3. 為系統指派的受控識別建立自主資料庫使用者。 連線到您想要從中複製資料的資料庫，然後執行下列 T-SQL：

   CREATE USER [your_factory_or_workspace_name] FROM EXTERNAL PROVIDER
   

4. 依照您平常為 SQL 使用者和其他人所進行的操作一樣，將所需的權限授與系統指派的受控識別。 執行下列程式碼。 如需更多選項，請參閱此文件。

   ALTER ROLE [role name e.g. db_owner] ADD MEMBER [your_factory_or_workspace_name]
   

5. 設定 SQL 受控執行個體連結服務。

範例：使用系統指派的受控識別驗證

{
    "name": "AzureSqlDbLinkedService",
    "properties": {
        "type": "AzureSqlMI",
        "typeProperties": {
            "server": "<name or network address of the SQL server instance>",
            "database": "<database name>",
            "encrypt": "<encrypt>",
            "trustServerCertificate": false,
            "authenticationType": "SystemAssignedManagedIdentity"
        },
        "connectVia": {
            "referenceName": "<name of Integration Runtime>",
            "type": "IntegrationRuntimeReference"
        }
    }
}

使用者指派的受控身分識別驗證

資料處理站或 Synapse 工作區可與 系統指派的受控識別相關聯，其代表可向其他 Azure 服務驗證的服務。 您可以使用此受控識別來進行 SQL 受控執行個體驗證。 指定的服務可以使用此身分識別從您資料庫存取資料，或從您的資料庫複製資料。

若要使用使用者指派的受控識別驗證，除了上一節所述的一般屬性外，請指定下列屬性：

此外，請依照下列步驟操作：

1. 請遵循步驟來為受控執行個體佈建 Microsoft Entra 管理員。

2. 為使用者指派的受控識別建立登入。 在 SQL Server Management Studio (SSMS) 中，以系統管理員身分的 SQL Server 帳戶連線到您的受控執行個體。 在 master 資料庫中執行下列 T-SQL：

   CREATE LOGIN [your_factory_or_workspace_ name] FROM EXTERNAL PROVIDER
   

3. 為使用者指派的受控識別建立自主資料庫使用者。 連線到您想要從中複製資料的資料庫，然後執行下列 T-SQL：

   CREATE USER [your_factory_or_workspace_name] FROM EXTERNAL PROVIDER
   

4. 依照您平常為 SQL 使用者和其他人所進行的操作一樣，建立一或多個使用者指派的受控識別，並將所需的權限授與使用者指派的受控識別。 執行下列程式碼。 如需更多選項，請參閱此文件。

   ALTER ROLE [role name e.g. db_owner] ADD MEMBER [your_factory_or_workspace_name]
   

5. 將一或多個使用者指派的受控識別指派給 Data Factory，並為每個使用者指派的受控識別建立認證。

6. 設定 SQL 受控執行個體連結服務。

範例：使用使用者指派的受控識別驗證

{
    "name": "AzureSqlDbLinkedService",
    "properties": {
        "type": "AzureSqlMI",
        "typeProperties": {
            "server": "<name or network address of the SQL server instance>",
            "database": "<database name>",
            "encrypt": "<encrypt>",
            "trustServerCertificate": false,
            "authenticationType": "UserAssignedManagedIdentity",
            "credential": {
                "referenceName": "credential1",
                "type": "CredentialReference"
            }
        },
        "connectVia": {
            "referenceName": "<name of Integration Runtime>",
            "type": "IntegrationRuntimeReference"
        }
    }
}

舊版

當您套用舊版時，Azure SQL 受控執行個體連線服務支援這些泛型屬性：

針對不同的驗證類型，請分別參閱下列各節特定的屬性和必要條件：

• 舊版的 SQL 驗證
• 舊版的服務主體驗證
• 舊版系統指派的受控識別驗證
• 舊版使用者指派的受控識別驗證

舊版的 SQL 驗證

若要使用 SQL 驗證，請指定上一節所述的泛型屬性。

舊版的服務主體驗證

若要使用服務主體驗證，除了上一節所述的一般屬性外，請指定下列屬性：

您也需要遵循服務主體驗證中的步驟來授與對應的授權。

舊版的系統指派受控識別驗證

如果要使用系統指派的受控識別驗證，請遵循系統指派的受控識別驗證中建議版本的相同步驟。

舊版使用者指派的受控識別驗證

如果要使用使用者指派的受控識別驗證，請遵循使用者指派的受控識別驗證中建議版本的相同步驟。

資料集屬性

如需可用來定義資料集的區段和屬性完整清單，請參閱資料集文章。 本節提供 SQL 受控執行個體資料集所支援的屬性清單。

為了將資料複製到 SQL 受控執行個體或從中複製資料，支援下列屬性：

範例

{
    "name": "AzureSqlMIDataset",
    "properties":
    {
        "type": "AzureSqlMITable",
        "linkedServiceName": {
            "referenceName": "<SQL Managed Instance linked service name>",
            "type": "LinkedServiceReference"
        },
        "schema": [ < physical schema, optional, retrievable during authoring > ],
        "typeProperties": {
            "schema": "<schema_name>",
            "table": "<table_name>"
        }
    }
}

複製活動屬性

如需可用來定義活動的區段和屬性完整清單，請參閱管線一文。 本節提供 SQL 受控執行個體來源和接收器所支援的屬性清單。

SQL 受控執行個體作為來源

若要從 SQL 受控執行個體複製資料，複製活動來源區段中支援下列屬性：

請注意下列幾點：

• 如果為 SqlMISource 指定 sqlReaderQuery，複製活動就會針對受控執行個體來源執行此查詢來取得資料。 如果預存程序接受參數，您也可以藉由指定 sqlReaderStoredProcedureName 和 storedProcedureParameters 來指定預存程序。
• 在來源中使用預存程序來擷取資料時，請注意，如果您的預存程序設計為在傳入不同的參數值時傳回不同的結構描述，在從 UI 匯入結構描述，或使用自動資料表建立將資料複製到 SQL 資料庫時，您可能遇到失敗，或看到非預期的結果。

範例：使用 SQL 查詢

"activities":[
    {
        "name": "CopyFromAzureSqlMI",
        "type": "Copy",
        "inputs": [
            {
                "referenceName": "<SQL Managed Instance input dataset name>",
                "type": "DatasetReference"
            }
        ],
        "outputs": [
            {
                "referenceName": "<output dataset name>",
                "type": "DatasetReference"
            }
        ],
        "typeProperties": {
            "source": {
                "type": "SqlMISource",
                "sqlReaderQuery": "SELECT * FROM MyTable"
            },
            "sink": {
                "type": "<sink type>"
            }
        }
    }
]

範例：使用預存程序

"activities":[
    {
        "name": "CopyFromAzureSqlMI",
        "type": "Copy",
        "inputs": [
            {
                "referenceName": "<SQL Managed Instance input dataset name>",
                "type": "DatasetReference"
            }
        ],
        "outputs": [
            {
                "referenceName": "<output dataset name>",
                "type": "DatasetReference"
            }
        ],
        "typeProperties": {
            "source": {
                "type": "SqlMISource",
                "sqlReaderStoredProcedureName": "CopyTestSrcStoredProcedureWithParameters",
                "storedProcedureParameters": {
                    "stringData": { "value": "str3" },
                    "identifier": { "value": "$$Text.Format('{0:yyyy}', <datetime parameter>)", "type": "Int"}
                }
            },
            "sink": {
                "type": "<sink type>"
            }
        }
    }
]

預存程序定義

CREATE PROCEDURE CopyTestSrcStoredProcedureWithParameters
(
    @stringData varchar(20),
    @identifier int
)
AS
SET NOCOUNT ON;
BEGIN
    select *
    from dbo.UnitTestSrcTable
    where dbo.UnitTestSrcTable.stringData != stringData
    and dbo.UnitTestSrcTable.identifier != identifier
END
GO

SQL 受控執行個體作為接收器

若要將資料複製到 SQL 受控執行個體，複製活動接收器區段中支援下列屬性：

範例 1：附加資料

"activities":[
    {
        "name": "CopyToAzureSqlMI",
        "type": "Copy",
        "inputs": [
            {
                "referenceName": "<input dataset name>",
                "type": "DatasetReference"
            }
        ],
        "outputs": [
            {
                "referenceName": "<SQL Managed Instance output dataset name>",
                "type": "DatasetReference"
            }
        ],
        "typeProperties": {
            "source": {
                "type": "<source type>"
            },
            "sink": {
                "type": "SqlMISink",
                "tableOption": "autoCreate",
                "writeBatchSize": 100000
            }
        }
    }
]

範例 2：在複製期間叫用預存程序

若要了解更多詳細資料，請參閱叫用 SQL MI 接收器中的預存程序。

"activities":[
    {
        "name": "CopyToAzureSqlMI",
        "type": "Copy",
        "inputs": [
            {
                "referenceName": "<input dataset name>",
                "type": "DatasetReference"
            }
        ],
        "outputs": [
            {
                "referenceName": "<SQL Managed Instance output dataset name>",
                "type": "DatasetReference"
            }
        ],
        "typeProperties": {
            "source": {
                "type": "<source type>"
            },
            "sink": {
                "type": "SqlMISink",
                "sqlWriterStoredProcedureName": "CopyTestStoredProcedureWithParameters",
                "storedProcedureTableTypeParameterName": "MyTable",
                "sqlWriterTableType": "MyTableType",
                "storedProcedureParameters": {
                    "identifier": { "value": "1", "type": "Int" },
                    "stringData": { "value": "str1" }
                }
            }
        }
    }
]

範例 3：Upsert 資料

"activities":[
    {
        "name": "CopyToAzureSqlMI",
        "type": "Copy",
        "inputs": [
            {
                "referenceName": "<input dataset name>",
                "type": "DatasetReference"
            }
        ],
        "outputs": [
            {
                "referenceName": "<SQL Managed Instance output dataset name>",
                "type": "DatasetReference"
            }
        ],
        "typeProperties": {
            "source": {
                "type": "<source type>"
            },
            "sink": {
                "type": "SqlMISink",
                "tableOption": "autoCreate",
                "writeBehavior": "upsert",
                "upsertSettings": {
                    "useTempDB": true,
                    "keys": [
                        "<column name>"
                    ]
                },            
            }
        }
    }
]

從 SQL MI 平行複製

複製活動中的 Azure SQL 受控執行個體連接器提供內建的資料分割，以便平行複製資料。 您可以在複製活動的 [來源] 索引標籤上找到資料分割選項。

當您啟用分割複本時，複製活動會平行查詢 SQL MI 來源，以依分割區來載入資料。 平行程度由複製活動的 parallelCopies 設定所控制。 例如，如果您將 parallelCopies 設定為 4，服務會根據您指定的資料分割選項和設定，同時產生並執行四個查詢，而每個查詢會從 SQL MI 取取出一部分資料。

建議您啟用平行複製與資料分割，特別是從 SQL MI 載入大量資料時。 以下針對各種情節的建議設定。 將資料複製到以檔案為基礎的資料存放區時，建議分成多個檔案來寫入資料夾 (僅指定資料夾名稱)，這樣效能會比寫入單一檔案更好。

使用分割區選項載入資料的最佳做法：

1. 選擇獨特的資料行作為分割資料行 (例如主索引鍵或唯一索引鍵) 以避免資料扭曲。
2. 如果資料表有內建分割區，請使用分割選項「資料表的實體分割區」，以獲得更佳的效能。
3. 如果您使用 Azure Integration Runtime 來複製資料，您可以設定較大的「資料整合單位 (DIU)」(>4) 來利用更多運算資源。 檢查該處適用的案例。
4. 「複製平行處理原則的程度」會控制分割區數目，將此數目設定過大有時會損害效能，建議將此數目設定為 (DIU 或自我裝載 IR 節點數目) * (2 到 4)。

範例：使用實體分割區從大型資料表完整載入

"source": {
    "type": "SqlMISource",
    "partitionOption": "PhysicalPartitionsOfTable"
}

範例：使用動態範圍分割進行查詢

"source": {
    "type": "SqlMISource",
    "query": "SELECT * FROM <TableName> WHERE ?DfDynamicRangePartitionCondition AND <your_additional_where_clause>",
    "partitionOption": "DynamicRange",
    "partitionSettings": {
        "partitionColumnName": "<partition_column_name>",
        "partitionUpperBound": "<upper_value_of_partition_column (optional) to decide the partition stride, not as data filter>",
        "partitionLowerBound": "<lower_value_of_partition_column (optional) to decide the partition stride, not as data filter>"
    }
}

用來檢查實體分割區的範例查詢

SELECT DISTINCT s.name AS SchemaName, t.name AS TableName, pf.name AS PartitionFunctionName, c.name AS ColumnName, iif(pf.name is null, 'no', 'yes') AS HasPartition
FROM sys.tables AS t
LEFT JOIN sys.objects AS o ON t.object_id = o.object_id
LEFT JOIN sys.schemas AS s ON o.schema_id = s.schema_id
LEFT JOIN sys.indexes AS i ON t.object_id = i.object_id 
LEFT JOIN sys.index_columns AS ic ON ic.partition_ordinal > 0 AND ic.index_id = i.index_id AND ic.object_id = t.object_id 
LEFT JOIN sys.columns AS c ON c.object_id = ic.object_id AND c.column_id = ic.column_id 
LEFT JOIN sys.partition_schemes ps ON i.data_space_id = ps.data_space_id 
LEFT JOIN sys.partition_functions pf ON pf.function_id = ps.function_id 
WHERE s.name='[your schema]' AND t.name = '[your table name]'

如果資料表具有實體分割區，您會看到 “HasPartition” 顯示為 “yes”，如下所示。

將資料載入 SQL 受控執行個體的最佳做法

將資料複製到 SQL 受控執行個體時，您可能需要不同的寫入行為：

• 附加：我的來源資料只有新的記錄。
• Upsert：我的來源資料同時有插入和更新。
• 覆寫：我想要每次都重新載入整個維度資料表。
• 使用自訂邏輯寫入：在最終插入目的地資料表之前，我還需要額外的處理。

如需設定方式和最佳做法，請參閱個別章節。

附加資料

附加資料是 SQL 受控執行個體接收器連接器的預設行為。 服務會執行大量插入，以有效率地寫入資料表。 您可以在複製活動中據以設定來源和接收器。

Upsert 資料

複製活動現在支援將資料原生載入資料庫暫存資料表，然後在索引鍵存在時更新接收資料表中的資料，若無則插入新的資料。 若要深入了解複製活動中的更新插入設定，請參閱 SQL 受控執行個體作為接收器。

覆寫整個資料表

您可以在複製活動接收器中設定 preCopyScript 屬性。 在此情況下，針對執行的每個複製活動，服務會先執行指令碼。 然後服務會執行複本以插入資料。 例如，若要以最新的資料覆寫整個資料表，可以指定先刪除所有記錄，再從來源大量載入新資料的指令碼。

使用自訂邏輯寫入資料

使用自訂邏輯寫入資料的步驟類似於更新插入資料一節中所述的步驟。 當您需要在最終插入來源資料至目的地資料表之前套用額外的處理時，您可以載入暫存表格，然後叫用預存程序活動，或在複製活動接收器中叫用預存程序來套用資料。

從 SQL 接收器叫用預存程序

當您將資料複製到 SQL 受控執行個體時，也可以在來源資料表的每個批次上設定及叫用具有額外參數的使用者指定預存程序。 預存程序功能使用資料表值參數。

當內建的複製機制無法滿足需求時，您可以使用預存程序。 例如，當您想要在最終插入來源資料至目的地資料表之前，套用額外的處理。 額外處理的一些範例包括：合併資料行、查閱其他的值，以及插入多個資料表中。

下列範例示範如何使用預存程序，對 SQL Server 資料庫中的資料表執行更新插入。 假設輸入資料和接收器 Marketing 資料表各有三個資料行：ProfileID、State 和 Category。 根據 ProfileID 資料行執行更新插入，然後僅套用至名為 "ProductA" 的特定類別。

1. 在資料庫中，使用與 sqlWriterTableType 相同的名稱來定義資料表類型。 資料表類型的結構描述會與輸入資料所傳回的結構描述相同。

   CREATE TYPE [dbo].[MarketingType] AS TABLE(
       [ProfileID] [varchar](256) NOT NULL,
       [State] [varchar](256) NOT NULL,
       [Category] [varchar](256) NOT NULL
   )
   

2. 在資料庫中，使用與 sqlWriterStoredProcedureName 相同的名稱來定義預存程序。 它會處理來自指定來源的輸入資料，並合併至輸出資料表。 預存程序中資料表類型的參數名稱會與資料集中定義的 tableName 相同。

   CREATE PROCEDURE spOverwriteMarketing @Marketing [dbo].[MarketingType] READONLY, @category varchar(256)
   AS
   BEGIN
   MERGE [dbo].[Marketing] AS target
   USING @Marketing AS source
   ON (target.ProfileID = source.ProfileID and target.Category = @category)
   WHEN MATCHED THEN
       UPDATE SET State = source.State
   WHEN NOT MATCHED THEN
       INSERT (ProfileID, State, Category)
       VALUES (source.ProfileID, source.State, source.Category);
   END
   

3. 在您的管線中，定義複製活動中的 [SQL MI 接收器] 區段，如下所示：

   "sink": {
       "type": "SqlMISink",
       "sqlWriterStoredProcedureName": "spOverwriteMarketing",
       "storedProcedureTableTypeParameterName": "Marketing",
       "sqlWriterTableType": "MarketingType",
       "storedProcedureParameters": {
           "category": {
               "value": "ProductA"
           }
       }
   }
   

對應資料流程屬性

在對應資料流程中轉換資料時，您可以從 Azure SQL 受控執行個體讀取和寫入資料表。 如需詳細資訊，請參閱對應資料流程中的來源轉換和接收轉換。

來源轉換

下表列出 Azure SQL 受控執行個體來源所支援的屬性。 您可以在 [來源選項] 索引標籤中編輯這些屬性。

CREATE PROC CTESP @query nvarchar(max)
AS
BEGIN
EXECUTE sp_executesql @query;
END

Azure SQL 受控執行個體來源指令碼範例

當您使用 Azure SQL 受控執行個體作為來源類型時，相關聯的資料流程指令碼為：

source(allowSchemaDrift: true,
    validateSchema: false,
    isolationLevel: 'READ_UNCOMMITTED',
    query: 'select * from MYTABLE',
    format: 'query') ~> SQLMISource

接收轉換

下表列出Azure SQL 受控執行個體接收器所支援的屬性。 您可以在 [接收器選項] 索引標籤中編輯這些屬性。

Azure SQL 受控執行個體接收器指令碼範例

當您使用 Azure SQL 受控執行個體作為接收器類型時，相關聯的資料流程指令碼為：

IncomingStream sink(allowSchemaDrift: true,
    validateSchema: false,
    deletable:false,
    insertable:true,
    updateable:true,
    upsertable:true,
    keys:['keyColumn'],
    format: 'table',
    skipDuplicateMapInputs: true,
    skipDuplicateMapOutputs: true) ~> SQLMISink

查閱活動屬性

若要了解屬性的詳細資料，請參閱查閱活動。

GetMetadata 活動屬性

若要了解關於屬性的詳細資料，請參閱 GetMetadata 活動

SQL 受控執行個體的資料類型對應

使用複製活動從 SQL 受控執行個體複製資料或將資料複製到其中時，會使用下列從 SQL 受控執行個體資料類型到服務內部使用的過渡期資料類型的對應。 若要了解複製活動如何將來源結構描述和資料類型對應至接收，請參閱結構描述和資料類型對應。

使用 Always Encrypted

當您使用 Always Encrypted 在 SQL 受控執行個體複製/貼上資料時，請遵循下列步驟：

1. 將資料行主要金鑰 (CMK) 儲存在 Azure Key Vault 中。 深入了解如何使用 Azure Key Vault 設定 Always Encrypted

2. 請務必授與資料行主要金鑰 (CMK) 儲存所在金鑰保存庫的存取權。 針對必要權限，請參閱這篇文章。

3. 建立連結服務以連線到您的 SQL 資料庫，並使用受控身分識別或服務主體啟用 'Always Encrypted' 函式。

原生異動資料擷取

Azure Data Factory 可支援適用於 SQL Server、Azure SQL DB 和 Azure SQL MI 的原生異動資料擷取功能。 ADF 對應資料流程可以自動偵測及擷取異動的資料，包括在 SQL 存放區中的資料列插入、更新和刪除。 若使用者沒有任何對應資料流程的程式碼經驗，可以將資料庫當作目的地存放區來附加，輕鬆地達成從 SQL 存放區複寫資料的情境。 此外，使用者也可以在兩者之間撰寫任何的資料轉換邏輯，以從 SQL 存放區達到累加式 ETL 的情境。

請確定管線和活動名稱保持不變，如此 ADF 便可以為您記錄檢查點，以便自動取得上次執行的變更資料。 如果您變更管線名稱或活動名稱，檢查點便會重設，這會導致您在下次執行時得從頭開始，或是取得從現在開始的變更。 如果您想要變更管線名稱或活動名稱，但仍想讓檢查點自動從上次的執行中取得變更的資料時，請在資料流程活動中使用您自己的檢查點索引鍵來達到此目的。

偵錯管線時，此功能的運作方式相同。 請注意，當您在偵錯執行期間重新整理瀏覽器時，將會重設檢查點。 在您對偵錯執行的管線結果感到滿意之後，您可以繼續發佈並觸發管線。 當您第一次觸發已發佈的管線時，會自動從頭重新開始，或是取得從現在開始的變更。

在監視區段中，您隨時有機會重新執行管線。 重新執行時，一律會從所選管線執行的前一個檢查點擷取變更的資料。

範例 1：

當您直接將「參照到啟用 SQL CDC 資料集的來源轉換」與「參照到對應資料流程中資料庫的接收轉換」鏈結起來時，SQL 來源上的變更會自動套用至目標資料庫，如此一來，您就可以輕鬆地達成在資料庫之間複寫資料的情境。 您可以在接收轉換中使用更新方法，以選取要在目標資料庫上允許插入、允許更新，還是要允許刪除。 對應資料流程中的範例指令碼如下所示。

source(output(
		id as integer,
		name as string
	),
	allowSchemaDrift: true,
	validateSchema: false,
	enableNativeCdc: true,
	netChanges: true,
	skipInitialLoad: false,
	isolationLevel: 'READ_UNCOMMITTED',
	format: 'table') ~> source1
source1 sink(allowSchemaDrift: true,
	validateSchema: false,
	deletable:true,
	insertable:true,
	updateable:true,
	upsertable:true,
	keys:['id'],
	format: 'table',
	skipDuplicateMapInputs: true,
	skipDuplicateMapOutputs: true,
	errorHandlingOption: 'stopOnFirstError') ~> sink1

範例 2：

如果您想要啟用 ETL 情境，而不是透過 SQL CDC 在資料庫之間進行資料複寫，可以在對應資料流程中使用運算式，包括 isInsert(1)、isUpdate(1)，以及 isDelete(1) 來區分不同作業類型的資料列。 以下是用來對應資料流程的其中一個範例指令碼，若衍生出來的資料行值為 1 表示插入的資料列，2 表示更新的資料列，3 表示下游轉換已刪除的資料列，以處理差異資料。

source(output(
		id as integer,
		name as string
	),
	allowSchemaDrift: true,
	validateSchema: false,
	enableNativeCdc: true,
	netChanges: true,
	skipInitialLoad: false,
	isolationLevel: 'READ_UNCOMMITTED',
	format: 'table') ~> source1
source1 derive(operationType = iif(isInsert(1), 1, iif(isUpdate(1), 2, 3))) ~> derivedColumn1
derivedColumn1 sink(allowSchemaDrift: true,
	validateSchema: false,
	skipDuplicateMapInputs: true,
	skipDuplicateMapOutputs: true) ~> sink1

已知的限制：

• 只有來自 SQL CDC 的淨變更會由 ADF 透過 cdc.fn_cdc_get_net_changes_ 來載入。

升級 Azure SQL 受控執行個體版本

若要升級 Azure SQL 受控執行個體版本，請在 [編輯連結服務] 頁面中，選取 [版本] 底下的 [建議]，並參考建議版本的連結服務屬性來設定連結服務。

建議的版本與舊版之間的差異

下表顯示使用建議的和舊版的 Azure SQL 受控執行個體之間的差異。

相關內容

如需複製活動支援作為來源和接收器的資料存放區清單，請參閱支援的資料存放區。