如何实现Azure表存储中重复PartitionKey+RowKey组合返回412预条件失败异常

核心原理 #

利用Azure表存储的条件实体操作机制，通过指定"仅当目标实体不存在时才执行插入"的前置条件，当PartitionKey+RowKey组合已存在时，服务会自动返回412 Precondition Failed状态码，完全匹配需求。

具体实现方式 #

1. REST API层面 #

直接调用表存储的插入实体API时，在请求头中添加：

If-None-Match: *

• 当PartitionKey+RowKey组合不存在时，API成功插入实体，返回201 Created。
• 当组合已存在时，API返回412 Precondition Failed。

2. .NET SDK（Azure.Data.Tables）实现 #

使用TableClient的AddEntityAsync方法，通过RequestConditions设置IfNoneMatch为ETag.All（对应If-None-Match: *）：

var tableClient = new TableClient(connectionString, "YourTableName");
var entity = new TableEntity("PipelineName", "TimestampRowKey")
{
    // 填充实体属性
};

try
{
    await tableClient.AddEntityAsync(entity, new RequestConditions { IfNoneMatch = ETag.All });
}
catch (RequestFailedException ex)
{
    if (ex.Status == 412)
    {
        // 处理重复插入场景
    }
}

3. Python SDK（azure-data-tables）实现 #

使用TableClient.create_entity方法，指定if_none_match="*"参数：

from azure.data.tables import TableClient
from azure.core.exceptions import HttpResponseError

with TableClient.from_connection_string(connection_string, table_name="YourTableName") as table_client:
    entity = {
        "PartitionKey": "PipelineName",
        "RowKey": "TimestampRowKey",
        # 填充其他属性
    }
    try:
        table_client.create_entity(entity=entity, if_none_match="*")
    except HttpResponseError as ex:
        if ex.status_code == 412:
            # 处理重复插入逻辑

关键注意事项 #

• 必须结合If-None-Match: *条件使用插入操作，若直接调用无参数的插入接口，重复时会返回409 Conflict，不符合需求。
• Azure表存储的分区级锁会保证多节点并发写入时的原子性，不会出现竞态条件导致的重复插入。

内容的提问来源于stack exchange，提问作者NoobProg