如何在Azure Table中兼容不同格式的数据输入？

问题背景 #

已创建Azure Table和Azure Queue，现有C#队列触发函数可读取Queue消息并插入Table，但仅支持固定字段顺序（ID:Name:Age:Vaccinated）的输入，无法处理字段顺序打乱的消息（如Name:Age:ID:Vaccinated）。

现有代码问题分析 #

原代码通过固定位置截取字符串获取字段值，完全依赖消息的字段顺序，一旦顺序变动就会解析错误。

修改后的解决方案 #

核心思路是将消息解析为键值对字典，忽略字段顺序，通过字段名精准取值。

修改后的队列触发函数代码 #

[FunctionName("Function1")]
public void Run([QueueTrigger("myqueue-items", Connection = "AzureWebJobsStorage")] string myQueueItem, ILogger log)
{
    try
    {
        log.LogInformation($"C# Queue trigger function processed: {myQueueItem}");

        // 将消息按分隔符拆分，解析为键值对字典
        var fieldDict = new Dictionary<string, string>(StringComparer.OrdinalIgnoreCase);
        var fields = myQueueItem.Split(':');
        for (int i = 0; i < fields.Length; i += 2)
        {
            if (i + 1 < fields.Length)
            {
                fieldDict[fields[i].Trim()] = fields[i + 1].Trim();
            }
        }

        // 从字典中获取对应字段值，处理默认情况
        string id = fieldDict.TryGetValue("ID", out var idVal) ? idVal : throw new ArgumentException("缺少ID字段");
        string name = fieldDict.TryGetValue("Name", out var nameVal) ? nameVal : throw new ArgumentException("缺少Name字段");
        if (!fieldDict.TryGetValue("Age", out var ageVal) || !int.TryParse(ageVal, out int age))
        {
            throw new ArgumentException("Age字段无效或缺失");
        }
        bool isVac = fieldDict.TryGetValue("Vaccinated", out var vacVal) && vacVal.Equals("TRUE", StringComparison.OrdinalIgnoreCase);

        AddToTable(id, name, age, isVac);
        log.LogInformation("消息解析并插入Table成功");
    }
    catch (Exception ex)
    {
        log.LogError(ex, "处理Queue消息时出错");
    }
}

保留原有的Table插入方法 #

private void AddToTable(string ID, string name, int age, bool isVac)
{
    string connectionString = ""; // 替换为你的Azure存储连接字符串
    TableClient tableClient = new TableClient(connectionString, "Vac");
    tableClient.CreateIfNotExists();

    var entity = new Person()
    {
        PartitionKey = "South Africa",
        RowKey = ID,
        Name = name,
        Age = age,
        Vacinated = isVac
    };
    tableClient.AddEntity(entity);
}

关键修改说明 #

• 键值对解析：将消息按:拆分后，每两个元素组成一组键值对存入字典，支持大小写不敏感匹配字段名
• 容错处理：对缺失字段、格式错误（如Age非数字）的情况抛出明确异常，便于排查问题
• 顺序无关：无论消息中字段顺序如何，只要字段名正确就能精准获取对应值

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