使用 Azure 数据工厂或 Synapse Analytics 向/从 Azure 表存储复制数据

项目
12/29/2023

适用于： Azure 数据工厂 Azure Synapse Analytics

提示

试用 Microsoft Fabric 中的数据工厂，这是一种适用于企业的一站式分析解决方案。 Microsoft Fabric 涵盖从数据移动到数据科学、实时分析、商业智能和报告的所有内容。了解如何免费开始新的试用！

本文概述如何使用 Azure 数据工厂和 Synapse Analytics 管道中的复制活动向/从 Azure 表存储复制数据。本文是根据总体概述复制活动的复制活动概述一文编写的。

注意

建议使用 Azure Az PowerShell 模块与 Azure 交互。请参阅安装 Azure PowerShell 以开始使用。若要了解如何迁移到 Az PowerShell 模块，请参阅将 Azure PowerShell 从 AzureRM 迁移到 Az。

支持的功能

此 Azure 表存储连接器支持以下功能：

支持的功能	IR	托管专用终结点
复制活动（源/接收器）	① ②	✓ 排除存储帐户 V1
Lookup 活动	① ②	✓ 排除存储帐户 V1

① Azure 集成运行时 ② 自承载集成运行时

可将数据从任一支持的源数据存储复制到表存储。也可以将数据从表存储复制到任一支持的接收器数据存储。有关复制活动支持作为源或接收器的数据存储列表，请参阅支持的数据存储表。

具体而言，此 Azure 表连接器支持使用帐户密钥和服务共享访问签名身份验证复制数据。

入门

若要使用管道执行复制活动，可以使用以下工具或 SDK 之一：

使用 UI 创建 Azure 表存储链接服务

使用以下步骤在 Azure 门户 UI 中创建 Azure 表存储链接服务。

浏览到 Azure 数据工厂或 Synapse 工作区中的“管理”选项卡并选择“链接服务”，然后单击“新建”：
- Azure 数据工厂
- Azure Synapse
搜索 Azure 表并选择 Azure 表存储连接器。
配置服务详细信息、测试连接并创建新的链接服务。

连接器配置详细信息

对于特定于 Azure 表存储的实体，以下部分提供有关用于定义这些实体的属性的详细信息。

链接服务属性

使用帐户密钥

可以使用帐户密钥创建 Azure 存储链接服务。帐户密钥会为该服务提供对存储的全局访问权限。支持以下属性。

属性	描述	必需
type	type 属性必须设置为 AzureTableStorage。	是
connectionString	为 connectionString 属性指定连接到存储所需的信息。还可以将帐户密钥放在 Azure 密钥保管库中，并从连接字符串中拉取 `accountKey` 配置。有关更多详细信息，请参阅以下示例和在 Azure 密钥保管库中存储凭据一文。	是
connectVia	用于连接到数据存储的集成运行时。如果数据存储位于专用网络，则可以使用 Azure 集成运行时或自承载集成运行时。如果未指定，则使用默认 Azure Integration Runtime。	否

注意

如果使用的是“AzureStorage”类型链接服务，它仍然按原样受支持，但建议你今后使用此新的“AzureTableStorage”链接服务类型。

示例：

{
    "name": "AzureTableStorageLinkedService",
    "properties": {
        "type": "AzureTableStorage",
        "typeProperties": {
            "connectionString": "DefaultEndpointsProtocol=https;AccountName=<accountname>;AccountKey=<accountkey>;EndpointSuffix=core.chinacloudapi.cn"
        },
        "connectVia": {
            "referenceName": "<name of Integration Runtime>",
            "type": "IntegrationRuntimeReference"
        }
    }
}

示例：在 Azure 密钥保管库中存储帐户密钥

{
    "name": "AzureTableStorageLinkedService",
    "properties": {
        "type": "AzureTableStorage",
        "typeProperties": {
            "connectionString": "DefaultEndpointsProtocol=https;AccountName=<accountname>;EndpointSuffix=core.chinacloudapi.cn",
            "accountKey": { 
                "type": "AzureKeyVaultSecret", 
                "store": { 
                    "referenceName": "<Azure Key Vault linked service name>", 
                    "type": "LinkedServiceReference" 
                }, 
                "secretName": "<secretName>" 
            }
        },
        "connectVia": {
            "referenceName": "<name of Integration Runtime>",
            "type": "IntegrationRuntimeReference"
        }
    }
}

使用共享访问签名身份验证

还可以使用共享访问签名创建存储链接服务。共享访问签名会为该服务提供对存储中所有/特定资源的受限/限时访问权限。

共享访问签名对存储帐户中的资源提供委托访问。可以使用共享访问签名授权客户端在指定时间内，以一组指定权限有限访问存储帐户中的对象。无需共享帐户访问密钥。共享访问签名是一个 URI，在其查询参数中包含对存储资源已验证访问所需的所有信息。若要使用共享访问签名访问存储资源，客户端只需将共享访问签名传入到相应的构造函数或方法。有关共享访问签名的详细信息，请参阅共享访问签名：了解共享访问签名模型。

注意

现在支持服务共享访问签名和帐户共享访问签名。有关共享访问签名的详细信息，请参阅使用共享访问签名 (SAS) 授予对 Azure 存储资源的有限访问权限。

提示

若要为存储帐户生成服务共享访问签名，可以执行以下 PowerShell 命令。请替换占位符并授予所需的权限。 $context = New-AzStorageContext -StorageAccountName <accountName> -StorageAccountKey <accountKey> -Endpoint chinacloudapi.cn New-AzStorageContainerSASToken -Name <containerName> -Context $context -Permission rwdl -StartTime <startTime> -ExpiryTime <endTime> -FullUri

若要使用共享访问签名身份验证，需支持以下属性。

properties	描述	必需
type	type 属性必须设置为 AzureTableStorage。	是
sasUri	向表指定共享访问签名 URI 的 SAS URI。将此字段标记为 SecureString 以安全存储它。还可以将 SAS 令牌放在 Azure Key Vault 中，以利用自动轮换以及删除令牌部分。有关更多详细信息，请参阅以下示例和在 Azure 密钥保管库中存储凭据一文。	是
connectVia	用于连接到数据存储的集成运行时。如果数据存储位于专用网络，则可以使用 Azure 集成运行时或自承载集成运行时。如果未指定，则使用默认 Azure Integration Runtime。	否

注意

如果使用的是“AzureStorage”类型链接服务，它仍然按原样受支持，但建议你今后使用此新的“AzureTableStorage”链接服务类型。

示例：

{
    "name": "AzureTableStorageLinkedService",
    "properties": {
        "type": "AzureTableStorage",
        "typeProperties": {
            "sasUri": {
                "type": "SecureString",
                "value": "<SAS URI of the Azure Storage resource e.g. https://<account>.table.core.chinacloudapi.cn/<table>?sv=<storage version>&amp;st=<start time>&amp;se=<expire time>&amp;sr=<resource>&amp;sp=<permissions>&amp;sip=<ip range>&amp;spr=<protocol>&amp;sig=<signature>>"
            }
        },
        "connectVia": {
            "referenceName": "<name of Integration Runtime>",
            "type": "IntegrationRuntimeReference"
        }
    }
}

示例：在 Azure 密钥保管库中存储帐户密钥

{
    "name": "AzureTableStorageLinkedService",
    "properties": {
        "type": "AzureTableStorage",
        "typeProperties": {
            "sasUri": {
                "type": "SecureString",
                "value": "<SAS URI of the Azure Storage resource without token e.g. https://<account>.table.core.chinacloudapi.cn/<table>>"
            },
            "sasToken": { 
                "type": "AzureKeyVaultSecret", 
                "store": { 
                    "referenceName": "<Azure Key Vault linked service name>", 
                    "type": "LinkedServiceReference" 
                }, 
                "secretName": "<secretName>" 
            }
        },
        "connectVia": {
            "referenceName": "<name of Integration Runtime>",
            "type": "IntegrationRuntimeReference"
        }
    }
}

在创建共享访问签名 URI 时，请注意以下几点：

根据链接服务（读取、写入、读/写）的用法，设置针对对象的适当读/写权限。
根据需要设置“到期时间”。确保存储对象的访问权限不会在管道的活动期限内过期。
应该根据需要在正确的表级别创建 URI。

数据集属性

有关可用于定义数据集的各部分和属性的完整列表，请参阅数据集一文。本部分提供 Azure 表数据集支持的属性列表。

要向/从 Azure 表复制数据，请将数据集的 type 属性设置为 AzureTable。支持以下属性。

属性	描述	必需
type	数据集的 type 属性必须设置为 AzureTable。	是
tableName	链接服务引用的表存储数据库实例中表的名称。	是

示例：

{
    "name": "AzureTableDataset",
    "properties":
    {
        "type": "AzureTable",
        "typeProperties": {
            "tableName": "MyTable"
        },
        "schema": [],
        "linkedServiceName": {
            "referenceName": "<Azure Table storage linked service name>",
            "type": "LinkedServiceReference"
        }
    }
}

由服务进行的架构推理

对于无架构的数据存储（如 Azure 表），服务将使用下列方式之一推断架构：

如果在复制活动中指定列映射，服务会使用源端列列表来检索数据。在这种情况下，如果行不包含列的值，则会为其提供 null 值。
如果未在复制活动中指定列映射，服务会使用数据中的第一行来推断架构。在这种情况下，如果第一行不包含完整架构（例如某些列具有 null 值），则复制操作的结果中会丢失部分列。

复制活动属性

有关可用于定义活动的各部分和属性的完整列表，请参阅管道一文。本部分提供 Azure 表源和接收器支持的属性列表。

将 Azure 表用作源类型

要从 Azure 表复制数据，请将复制活动中的源类型设置为“AzureTableSource”。复制活动的 source 节支持以下属性。

属性	描述	必需
type	复制活动源的 type 属性必须设置为 AzureTableSource。	是
azureTableSourceQuery	使用自定义表存储查询读取数据。源查询是 Azure 表存储支持的 `$filter` 查询选项中的直接映射，可从此文档了解更多语法，并查看以下 azureTableSourceQuery 示例部分中的示例。	否
azureTableSourceIgnoreTableNotFound	指示是否允许存在忽略表异常。允许的值为 True 和 False（默认值）。	否

azureTableSourceQuery 示例

注意

Azure 表服务会强制 Azure 表查询操作在 30 秒后超时。通过针对查询的设计一文了解如何优化查询。

如果要根据日期/时间类型列筛选数据，请参阅以下示例：

"azureTableSourceQuery": "LastModifiedTime gt datetime'2017-10-01T00:00:00' and LastModifiedTime le datetime'2017-10-02T00:00:00'"

如果要根据字符串类型列筛选数据，请参阅以下示例：

"azureTableSourceQuery": "LastModifiedTime ge '201710010000_0000' and LastModifiedTime le '201710010000_9999'"

如果使用的是管道参数，请按照上面的示例将日期时间值强制转换为适当格式。

将 Azure 表用作接收器类型

若要将数据复制到 Azure 表，请将复制活动中的接收器类型设置为“AzureTableSink”。复制活动 sink 节支持以下属性。

属性	描述	必需
type	复制活动接收器的 type 属性必须设置为 AzureTableSink。	是
azureTableDefaultPartitionKeyValue	接收器可以使用的默认分区键值。	否
azureTablePartitionKeyName	指定列名称，使用列值作为分区键。如果未指定，则使用“AzureTableDefaultPartitionKeyValue”作为分区键。	否
azureTableRowKeyName	指定列名称，使用列值作为行键。如果未指定，对每一行使用 GUID。	否
azureTableInsertType	将数据插入 Azure 表的模式。此属性控制输出表中具有匹配的分区键和行键的现有行是否替换或合并其值。允许的值为 merge（默认值）和 replace。此设置在行级别而不是表级别进行应用。并且两个选项都不会删除输入中不存在的输出表中的行。若要了解合并和替换设置的工作原理，请参阅插入或合并实体和插入或替换实体。	否
writeBatchSize	writeBatchSize 或 writeBatchTimeout 命中时，将数据插入 Azure 表。允许的值为 integer（行数）。	否（默认值为 10,000）
writeBatchTimeout	writeBatchSize 或 writeBatchTimeout 命中时，将数据插入 Azure 表。允许的值为 timespan。例如“00:20:00”（20 分钟）。	否（默认值为 90 秒，即存储客户端的默认超时）
maxConcurrentConnections	活动运行期间与数据存储建立的并发连接的上限。仅在要限制并发连接时指定一个值。	无

示例：

"activities":[
    {
        "name": "CopyToAzureTable",
        "type": "Copy",
        "inputs": [
            {
                "referenceName": "<input dataset name>",
                "type": "DatasetReference"
            }
        ],
        "outputs": [
            {
                "referenceName": "<Azure Table output dataset name>",
                "type": "DatasetReference"
            }
        ],
        "typeProperties": {
            "source": {
                "type": "<source type>"
            },
            "sink": {
                "type": "AzureTableSink",
                "azureTablePartitionKeyName": "<column name>",
                "azureTableRowKeyName": "<column name>"
            }
        }
    }
]

azureTablePartitionKeyName

使用 "translator" 属性将源列映射到目标列后，才能将目标列用作 azureTablePartitionKeyName。

在以下示例中，源列 DivisionID 映射到目标列 DivisionID：

"translator": {
    "type": "TabularTranslator",
    "columnMappings": "DivisionID: DivisionID, FirstName: FirstName, LastName: LastName"
}

“DivisionID”指定为分区键。

"sink": {
    "type": "AzureTableSink",
    "azureTablePartitionKeyName": "DivisionID"
}

Azure 表的数据类型映射

从/向 Azure 表复制数据时，以下映射用于从 Azure 表数据类型映射到在服务内部使用的临时数据类型。若要了解复制活动如何将源架构和数据类型映射到接收器，请参阅架构和数据类型映射。

将数据移入和移出 Azure 表时，Azure 表定义的以下映射将从 Azure 表 OData 类型转换为 .NET 类型，反之亦然。

Azure 表数据类型	临时服务数据类型	详细信息
Edm.Binary	byte[]	一个字节数组，最大 64 KB。
Edm.Boolean	bool	一个布尔值。
Edm.DateTime	DateTime	一个 64 位值，用协调世界时 (UTC) 表示。支持的 DateTime 范围从 UTC 公元 (C.E.) 1601 年 1 月 1 日开始。该范围到 9999 年 12 月 31 日结束。
Edm.Double	double	64 位浮点值。
Edm.Guid	Guid	128 位全局唯一标识符。
Edm.Int32	Int32	32 位整数。
Edm.Int64	Int64	64 位整数。
Edm.String	字符串	UTF-16 编码值。字符串值最大可以为 64 KB。

“查找”活动属性

若要了解有关属性的详细信息，请查看 Lookup 活动。

有关复制活动支持作为源和接收器的数据存储的列表，请参阅受支持的数据存储。

使用 Azure 数据工厂或 Synapse Analytics 向/从 Azure 表存储复制数据

支持的功能

入门

使用 UI 创建 Azure 表存储链接服务

连接器配置详细信息

链接服务属性

使用帐户密钥

使用共享访问签名身份验证

数据集属性

由服务进行的架构推理

复制活动属性

将 Azure 表用作源类型

azureTableSourceQuery 示例

将 Azure 表用作接收器类型

azureTablePartitionKeyName

Azure 表的数据类型映射

“查找”活动属性

相关内容

其他资源