通过Cosmos DB MongoDB接口查询文档返回空列表的问题求助

1. 修正集合访问逻辑 #

你的代码中集合访问存在明显问题：

transaction_collection = db[collection].transactions

这行代码会先获取名为collection参数值的集合，再访问该集合下名为transactions的子集合。如果你的目标集合并非嵌套结构，或者collection参数本身就是目标集合名称，这会导致你访问了一个空的子集合，自然返回空列表。

正确的集合访问方式二选一：

• 若collection参数是目标集合的名称（比如传入"transactions"）：

  transaction_collection = db[collection]
  

• 若目标集合固定为transactions，无需动态参数：

  transaction_collection = db.transactions
  

2. 验证部署环境的配置参数 #

• 检查App Services应用设置中的DB_URI和DB值是否与本地测试完全一致：
  • 确认DB_URI的账户名、密钥、端点无拼写错误
  • 确认DB对应的数据库名称，和插入文档的数据库是同一个
• 可以在部署后的代码中添加日志，输出db.name和transaction_collection.name，确认实际访问的数据库和集合名称是否正确

3. 检查Cosmos DB的一致性级别 #

Cosmos DB MongoDB API默认使用会话一致性，若插入和查询的实例不在同一会话中，可能出现查询延迟看不到数据的情况。可临时将一致性级别改为强一致性测试：

• 在Cosmos DB门户进入账户 → 设置 → 一致性策略，修改为强一致性
• 注意：强一致性会影响性能和成本，测试后可按需调整

4. 确认集合数据存在性 #

• 直接在Cosmos DB门户的数据资源管理器中，查看目标数据库和集合下是否有文档
• 确认插入文档的实例确实写入到了这个集合，而非其他数据库/集合

5. 优化客户端连接方式 #

使用with语句管理MongoClient生命周期，避免提前关闭连接的潜在问题：

def retrieve_transactions(collection):
    uri = environ.get('DB_URI')
    db_name = str(environ.get('DB'))
    with MongoClient(uri) as client:
        db = client[db_name]
        transaction_collection = db[collection]  # 修正后的集合访问
        transaction_list = list(transaction_collection.find({}))
    return transaction_list

6. 查看详细查询日志 #

在Cosmos DB门户的Insights中，查看具体find请求的详情：

• 确认请求的数据库、集合名称是否正确
• 确认查询筛选条件（此处为全量查询{}）是否正确
• 检查返回的文档数量是否为0，确认是无匹配数据还是访问了空集合

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