0

我想从 cosmos db 中读取记录并使用 python 更新 cosmos db 中的相同记录。

例子：

{
  "id":"id-1",
   "name":"mohit"
}

我想阅读上面的记录并将其更新为。

{
  "id":"id-1",
   "name":"Mohit Singh"
}

我发现很少有链接，但似乎他们只创建或删除记录但不更新现有记录：

https://github.com/Azure/azure-cosmos-python#modify-container-properties

但无法获取如何更新现有记录。

在我的场景中，我想从 cosmos db 中读取所有记录并更新一些值。

我怎么能在python中做到这一点。

import os
import json
import azure.cosmos.cosmos_client as cosmos_client

    COSMOS_DB_END_POINT = os.getenv("COSMOS_DB_END_POINT")
    COSMOS_DB_MASTER_KEY = os.getenv("COSMOS_DB_MASTER_KEY")
    COSMOS_DB_DATABASE_ID = os.getenv("COSMOS_DB_DATABASE_ID")
    COSMOS_DB_COLLECTION_ID = os.getenv("COSMOS_DB_COLLECTION_ID");

    client = cosmos_client.CosmosClient(COSMOS_DB_END_POINT, {'masterKey': COSMOS_DB_MASTER_KEY})
    document_link = "dbs/" + COSMOS_DB_DATABASE_ID + "/colls/" + COSMOS_DB_COLLECTION_ID

    for item in client.QueryItems(document_link,
                                  'SELECT * FROM ' + COSMOS_DB_COLLECTION_ID,
                                  {'enableCrossPartitionQuery': True}):
        item['created'] += '123'
        print(json.dumps(item, indent=True))
        client.ReplaceItem(document_link, item, options=None)
4

1 回答 1

2

您要使用的方法是ReplaceItem. 您将需要查询容器以获取文档（以便您拥有该文档的自链接），然后调用此方法并传递更新的文档。

于 2020-03-12T11:16:47.033 回答