通过 C# .NET Framework 托管数据工厂将数据从 Blob 复制到 Azure SQL 时忽略错误行

问：

我将按照本教程从 Blob 中的平面文件加载 Azure SQL 中的数据。

此方法需要 C# .NET Framework 控制台应用来创建/管理 Blob 数据集、Azure SQL 接收器和数据工厂。

唯一的问题是，对于大而混乱的数据文件，我不可避免地会遇到一些包含额外分隔符或格式错误的行。数据太大，无法在上传到 blob 之前在本地清理。

一个正常的解决方案是忽略坏行，即允许容错。

有一个如何使用 JSON 执行此操作的示例：

"typeProperties": {
    "source": {
        "type": "BlobSource"
    },
    "sink": {
        "type": "SqlSink",
    },
    "enableSkipIncompatibleRow": true,
    "redirectIncompatibleRowSettings": {
         "linkedServiceName": {
              "referenceName": "<Azure Storage or Data Lake Store linked service>",
              "type": "LinkedServiceReference"
            },
            "path": "redirectcontainer/erroroutput"
     }
}

但是，我无法确定 C# 中是否有等效的。我尝试从中修改 Azure SQL 接收器的原始连接字符串：

    // Specify the sink Azure SQL Database information
    string azureSqlConnString =
        "Server=tcp:mydb.database.windows.net,1433;" +
        "Database=mydb;" +
        "User ID=myuser;" + 
        "Password=mypassword;" + 
        "Trusted_Connection=False;Encrypt=True;Connection Timeout=30";
    string azureSqlTableName = "dbo.mytable";

    string storageLinkedServiceName = "AzureStorageLinkedService";
    string sqlDbLinkedServiceName = "AzureSqlDbLinkedService";
    string blobDatasetName = "BlobDataset";
    string sqlDatasetName = "SqlDataset";
    string pipelineName = "Adfv2TutorialBlobToSqlCopy";

对此：

    // Specify the sink Azure SQL Database information
    string azureSqlConnString =
        "Server=tcp:mydb.database.windows.net,1433;" +
        "Database=mydb;" +
        "User ID=myuser;" + 
        "Password=mypassword;" + 
        "enableSkipIncompatibleRow= true;" + 
        "Trusted_Connection=False;Encrypt=True;Connection Timeout=30";
    string azureSqlTableName = "dbo.mytable";

    string storageLinkedServiceName = "AzureStorageLinkedService";
    string sqlDbLinkedServiceName = "AzureSqlDbLinkedService";
    string blobDatasetName = "BlobDataset";
    string sqlDatasetName = "SqlDataset";
    string pipelineName = "Adfv2TutorialBlobToSqlCopy";

作为猜测，但它没有用：

“留言”： “错误代码=用户错误无效DbConnectionString，'类型=Microsoft.DataTransfer.Common.Shared.HybridDeliveryException，Message=无效 提供的数据库连接字符串。检查连接字符串 “下沉” side.，Source=Microsoft.DataTransfer.ClientLibrary，''Type=System.ArgumentException，Message=关键字 不支持： 'enableskipincompatiblerow'.，Source=System.Data，'“，

有没有办法做到这一点？

class 的属性表示它获取或设置容错。我得到了接受属性的实现，但它似乎没有以所需的方式改变行为。SkipErrorFileCopyActivityCopyActivitySkipErrorFile = new SkipErrorFile { }