Blazor Server应用中Cosmos DB缓存与数据库同步问题求助

问题背景 #

你当前的Blazor前端CRUD按钮仅修改了内存上下文（缓存），未同步到Cosmos DB；尝试并行更新缓存与数据库失败，需要基于Microsoft.Azure.DocumentDB.Core库实现先更新缓存、再提交数据库的串行方案，且不迁移至新的Microsoft.Azure.Cosmos库。

核心实现思路 #

放弃直接使用上下文内置的NewCommand/EditCommand/DeleteCommand，自定义按钮点击事件逻辑，严格遵循内存缓存变更 → Cosmos DB提交 → 异常回滚缓存的串行流程，确保数据一致性。

1. 修改前端按钮绑定 #

将按钮的Clicked事件从上下文内置命令切换到自定义方法：

<ButtonRowTemplate>
    <Button Color="Color.Success" Clicked="HandleNew">New</Button>
    <Button Color="Color.Primary" Clicked="HandleEdit">Edit</Button>
    <Button Color="Color.Danger" Clicked="HandleDelete">Delete</Button>
    <Button Color="Color.Link" Clicked="context.ClearFilterCommand.Clicked">Clear Filter</Button>
</ButtonRowTemplate>

2. 后端串行逻辑实现 #

以下是组件的C#代码示例（假设你使用通用表格组件，且已注入Cosmos容器实例）：

// 注入Cosmos容器（根据你的依赖注入方式调整）
private readonly Container _cosmosContainer;
// 表格上下文（根据你使用的组件库类型调整泛型）
[Parameter] public GridContext<YourEntityModel> GridContext { get; set; }

// 编辑操作逻辑
private async Task HandleEdit()
{
    var selectedItem = GridContext.SelectedItem;
    if (selectedItem == null) return;

    // 1. 弹出编辑表单，获取用户更新后的实体
    var updatedItem = await ShowEditModal(selectedItem);
    if (updatedItem == null) return;

    // 2. 更新内存缓存（上下文）
    var itemIndex = GridContext.Items.ToList().FindIndex(x => x.Id == updatedItem.Id);
    if (itemIndex != -1)
    {
        GridContext.Items[itemIndex] = updatedItem;
        GridContext.Refresh(); // 刷新UI显示最新状态
    }

    try
    {
        // 3. 串行提交到Cosmos DB
        var partitionKey = new PartitionKey(updatedItem.someID);
        var response = await _cosmosContainer.ReplaceItemAsync<YourEntityModel>(updatedItem, updatedItem.Id, partitionKey);

        // 验证更新结果，失败则回滚缓存
        if (response.StatusCode != System.Net.HttpStatusCode.OK)
        {
            GridContext.Items[itemIndex] = selectedItem;
            GridContext.Refresh();
            await ShowNotification("数据更新失败，请重试");
        }
    }
    catch (DocumentClientException ex)
    {
        // 捕获Cosmos异常，回滚缓存
        GridContext.Items[itemIndex] = selectedItem;
        GridContext.Refresh();
        await ShowNotification($"更新出错：{ex.Message}");
    }
}

// 新增操作逻辑
private async Task HandleNew()
{
    var newItem = await ShowNewModal();
    if (newItem == null) return;

    // 1. 添加到内存缓存
    GridContext.Items.Add(newItem);
    GridContext.Refresh();

    try
    {
        // 2. 提交到Cosmos DB
        var partitionKey = new PartitionKey(newItem.someID);
        var response = await _cosmosContainer.CreateItemAsync<YourEntityModel>(newItem, partitionKey);

        if (response.StatusCode != System.Net.HttpStatusCode.Created)
        {
            GridContext.Items.Remove(newItem);
            GridContext.Refresh();
            await ShowNotification("数据创建失败，请重试");
        }
    }
    catch (DocumentClientException ex)
    {
        GridContext.Items.Remove(newItem);
        GridContext.Refresh();
        await ShowNotification($"创建出错：{ex.Message}");
    }
}

// 删除操作逻辑
private async Task HandleDelete()
{
    var selectedItem = GridContext.SelectedItem;
    if (selectedItem == null) return;

    // 确认删除操作
    var confirmDelete = await ShowConfirmDialog("确定要删除这条记录吗？");
    if (!confirmDelete) return;

    // 1. 从内存缓存移除
    GridContext.Items.Remove(selectedItem);
    GridContext.Refresh();

    try
    {
        // 2. 从Cosmos DB删除
        var partitionKey = new PartitionKey(selectedItem.someID);
        var response = await _cosmosContainer.DeleteItemAsync<YourEntityModel>(selectedItem.Id, partitionKey);

        if (response.StatusCode != System.Net.HttpStatusCode.NoContent)
        {
            GridContext.Items.Add(selectedItem);
            GridContext.Refresh();
            await ShowNotification("数据删除失败，请重试");
        }
    }
    catch (DocumentClientException ex)
    {
        GridContext.Items.Add(selectedItem);
        GridContext.Refresh();
        await ShowNotification($"删除出错：{ex.Message}");
    }
}

// 以下为辅助方法示例（根据你的UI组件库实现）
private async Task<YourEntityModel> ShowEditModal(YourEntityModel item)
{
    var modal = ModalService.Show<EditEntityComponent>("编辑数据", new ModalParameters { { "Entity", item } });
    var result = await modal.Result;
    return result.Cancelled ? null : (YourEntityModel)result.Data;
}

private async Task<YourEntityModel> ShowNewModal()
{
    var modal = ModalService.Show<CreateEntityComponent>("新建数据");
    var result = await modal.Result;
    return result.Cancelled ? null : (YourEntityModel)result.Data;
}

private async Task<bool> ShowConfirmDialog(string message)
{
    var dialog = DialogService.ShowConfirm(message, "确认操作");
    var result = await dialog.Result;
    return !result.Cancelled;
}

private async Task ShowNotification(string message)
{
    NotificationService.Show(message);
}

关键注意事项 #

• 串行执行优先级：先更新内存缓存，用户能立即看到UI变化；数据库操作失败时必须回滚缓存，避免内存与数据库数据不一致。
• 异常捕获：必须处理DocumentClientException，覆盖网络错误、权限不足、并发冲突等场景。
• 上下文刷新：每次修改缓存后调用Refresh()方法，确保UI同步更新。

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