Cosmos DB单脚本执行容器删除重建时分区键未更新问题排查

在Azure Cosmos DB笔记本环境执行容器批量重建操作时，出现了流程割裂的异常：

• 单独执行旧容器删除脚本、单独执行新容器创建脚本时，操作全量正常，删除可完整清理所有旧容器，创建的容器分区键符合预期
• 把两段脚本放到同一执行流程中连续运行时，删除操作可以正常返回，但后续创建的同名容器始终沿用旧分区键（比如ContA仍保留原有/part1分区，而非脚本指定的/part4）

当前场景的配置基准：

• 现存旧容器：ContA(/part1)、ContB(/part2)、ContC(/part3)
• 目标重建配置：三个容器全部使用/part4作为统一分区键
• 初始实现逻辑：先遍历删除所有现存容器，再依次创建三个带新分区键的同名容器

出现这个问题的核心原因是Azure Cosmos DB的容器删除是异步元数据操作，不存在同步强一致的“删除完成”节点：

1. 调用delete_container接口返回200成功，仅代表服务端接收了删除请求，不代表容器元数据已经在所有元数据副本中完成清理。元数据删除流程通常需要几秒到十几秒的传播延迟，才能让全局的容器列表感知到该容器已不存在。
2. 如果在元数据还没完全清理完成的窗口期，发起同名容器的创建请求，服务端会命中仍在删除流程中的旧容器元数据上下文，直接沿用旧容器的残留配置（包括旧分区键、旧吞吐量参数）完成创建，不会应用新请求里传入的分区键参数。这种情况本质是服务端将待删除的旧容器“重启复用”，而非创建一个全新的空容器。

这也解释了为什么单独运行两段脚本时没有问题：手动间隔运行时，有足够的时间让元数据完全同步，创建请求发起时已经没有旧容器的元数据残留，就会正常按照新参数创建容器。

不要依赖删除接口的返回值判断操作完成，要主动做删除后的元数据校验，确认容器完全从元数据层面消失后，再执行创建操作：

• 删除所有容器后，循环拉取当前数据库的容器列表，校验目标容器ID已经从列表中完全消失，再进入创建环节
• 校验通过后，预留1-2秒的等待时间，适配多副本元数据的最终一致性传播延迟
• 给校验逻辑加超时阈值，避免无限等待异常场景
• 用循环批量创建的逻辑替代逐行写死的创建代码，减少重复代码量

参考修复后的代码实现：

from azure.cosmos.partition_key import PartitionKey
import time

database = cosmos_client.get_database_client("MyCosmosDB")
# 定义固定的操作参数
TARGET_CONTAINERS = ["ContA", "ContB", "ContC"]
TARGET_PK = PartitionKey(path='/part4')
WAIT_TIMEOUT = 60  # 最长等待60秒完成元数据同步
WAIT_INTERVAL = 2  # 每2秒做一次状态校验

# 步骤1：执行全量旧容器删除
existing_containers = list(database.list_containers())
if existing_containers:
    for container in existing_containers:
        print(f"Deleting the {container['id']} container...")
        try:
            database.delete_container(container['id'])
        except errors.CosmosHttpResponseError as e:
            raise
else:
    print("No containers exist in this database")

# 步骤2：循环校验所有目标容器是否完全从元数据列表移除
start_mark = time.time()
while True:
    current_container_ids = {c['id'] for c in database.list_containers()}
    remaining = [cid for cid in TARGET_CONTAINERS if cid in current_container_ids]
    # 所有目标容器都已移除则跳出循环
    if not remaining:
        print("All target containers are fully removed from metadata")
        break
    # 超时则抛出异常终止流程
    if time.time() - start_mark > WAIT_TIMEOUT:
        raise TimeoutError(f"Timeout waiting for container removal, remaining containers: {remaining}")
    print(f"Waiting for metadata sync, still detecting: {remaining}")
    time.sleep(WAIT_INTERVAL)

# 预留多副本元数据同步的时间窗口
time.sleep(2)

# 步骤3：批量创建新容器
for cid in TARGET_CONTAINERS:
    print(f"Creating {cid} container...")
    database.create_container(id=cid, partition_key=TARGET_PK)

注意事项 #

• 不要用固定时长的sleep替代元数据校验逻辑。不同环境下的Cosmos DB删除操作延迟差异较大，固定等待要么会拉长流程时长，要么还是会赶在元数据同步完成前发起创建请求，复现原有问题
• 如果使用较旧版本的Azure Cosmos DB Python SDK，需要确认SDK不会对容器列表接口做本地缓存，避免因缓存的旧列表导致校验判断失准

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