azure-cosmos-db-updater.py

import azure.cosmos.cosmos_client as cosmos_client
import azure.cosmos.errors as errors
import azure.cosmos.http_constants as http_constants

import os
import json

url = 'https://remstrava.documents.azure.com:443/'
key = ''
client = cosmos_client.CosmosClient(url, {'masterKey': key})

database_id = 'remstrava'
container_id =  'remstrava'


for item in client.QueryItems("dbs/" + database_id + "/colls/" + container_id,
                              'SELECT * FROM ' + container_id + ' ',
                              {'enableCrossPartitionQuery': True}):

    item["athlete"] = "remster"
    newItem = client.UpsertItem("dbs/" + database_id + "/colls/" + container_id, item)
    print(json.dumps(newItem, indent=True))