Azure .NET 5隔离函数如何通过绑定实现Table存储更新

核心结论 #

可以通过Azure Functions的Table Output绑定同时实现数据插入和更新（Upsert）操作，你遇到的报错由两个配置问题导致：

• 自定义的MyTableData实体类缺少ETag属性：Azure Table存储执行更新类操作时依赖ETag做并发校验，要实现强制覆盖的Upsert能力，需要将ETag赋值为*
• 你当前示例代码返回的RowKey为每次动态生成的GUID，永远不会和已有行的RowKey匹配，自然无法触发更新逻辑，要更新指定行必须返回与目标行完全一致的PartitionKey+RowKey组合

修正后的代码示例 #

using System;
using Microsoft.Azure.Functions.Worker;
using Microsoft.Extensions.Logging;

namespace SampleApp
{
    public static class TableFunction
    {
        [Function("TableFunction")]
        [TableOutput("OutputTable", Connection = "AzureWebJobsStorage")]
        public static MyTableData Run([QueueTrigger("table-items")] string input,
            [TableInput("MyTable", "MyPartition", "{queueTrigger}")] MyTableData tableInput,
            FunctionContext context)
        {
            var logger = context.GetLogger("TableFunction");

            logger.LogInformation($"PK={tableInput.PartitionKey}, RK={tableInput.RowKey}, Text={tableInput.Text}");

            // 要更新现有行，保持PartitionKey和RowKey与目标行一致
            return new MyTableData()
            {
                PartitionKey = tableInput.PartitionKey,
                RowKey = tableInput.RowKey,
                // ETag设为*代表不校验并发，直接执行Upsert
                ETag = "*",
                Text = $"更新后的内容，更新时间 {DateTime.Now}"
            };
        }
    }

    public class MyTableData
    {
        public string PartitionKey { get; set; }

        public string RowKey { get; set; }

        public string Text { get; set; }
        
        // 新增ETag属性，是Upsert操作的必填字段
        public string ETag { get; set; }
    }
}

额外说明 #

如果需要做并发控制，不要直接给ETag赋值*，可以直接复用Table Input绑定查询出来的实体的ETag值，这样只有当目标行没有被其他进程修改的时候才会执行更新，避免数据覆盖冲突。

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