如何为 Cosmos db 中的每个文档设置字段？

Question

Cosmos存储过程将每个记录的PumperID字段设置为默认值会是什么样子？

我们需要这样做来修复一些数据，因此该过程将访问每个具有PumperID字段的记录（并非所有文档都有此字段），并将其设置为默认值。

Answer 1

对于要循环访问容器中的每个项并更新属性的方案，实现此目的的最佳方法是使用更改源处理器并在 Azure 函数或 VM 中运行操作。请参阅更改源处理器以了解更多信息，并查看要开始的示例。

使用更改源，您将需要启动它以从容器的开头读取。若要执行此操作，请参阅从头开始阅读更改源。

然后在您的委托中，您将从更改提要中读取每个项目，检查它的值，然后调用Replace eItemAsync（）在需要更新时写回。

static async Task HandleChangesAsync(IReadOnlyCollection<MyType> changes, CancellationToken cancellationToken)
{
    Console.WriteLine("Started handling changes...");
    foreach (MyType item in changes)
    {
        if(item.PumperID == null)
        {
            item.PumperID = "some value"
            //call ReplaceItemAsync(), etc.
        }
    }

    Console.WriteLine("Finished handling changes.");
}

Answer 2

假设是一次性数据维护任务，最简单的解决方案可以说是创建一个单一用途的 .NET Core 控制台应用，并使用 SDK 查询需要更改的项目并执行更新。例如，我已使用此方法重命名属性。这适用于任何 Cosmos 数据库，不需要部署任何存储的过程或其他方式。

理想情况下，它被设计为幂等的，因此如果需要多次传递来捕获传入的新数据，它可以多次运行。如果项目计数很大，则可以选择使用 SDK 操作在开始时纵向扩展吞吐量，并在完成时缩减。为了提高性能，请在 Azure 虚拟机或函数上的终结点附近运行它。