如何通过Python Azure Function绑定删除CosmosDB容器数据项

结论先行 #

目前Azure Cosmos DB的函数绑定原生不支持直接通过输入/输出绑定执行删除操作，你提到的通过Input绑定的sqlQuery传入删除语句的方案不可行，Input绑定仅支持执行SELECT类查询语句，无法触发写操作，不属于可行方案，更谈不上最佳实践。
下面是两种可用的实现方案： #

方案1：使用Cosmos DB Python原生SDK（推荐，生产级最佳实践）

绑定本质是对Cosmos SDK的轻量封装，遇到绑定不支持的操作直接调用原生SDK是最稳妥的方案，实现成本极低：

1. 首先在项目的requirements.txt中添加SDK依赖：

azure-functions
azure-cosmos

2. 无需修改现有触发器配置，直接读取你已配置的Cosmos DB连接字符串环境变量即可调用删除接口，示例代码如下：

import logging
import os
import azure.functions as func
from azure.cosmos import CosmosClient

def main(req: func.HttpRequest) -> func.HttpResponse:
    logging.info('Python HTTP trigger function processed a request.')

    try:
        req_body = req.get_json()
        bc_id_no = req_body.get('bc_id_no')
        trip_id = req_body.get('trip_id')
    except ValueError:
        return func.HttpResponse("Invalid request body", status_code=400)

    if not bc_id_no or not trip_id:
        return func.HttpResponse("bc_id_no or trip_id not available", status_code=400)
    
    # 初始化Cosmos客户端，使用现有连接字符串配置
    conn_str = os.environ["AzureCosmosDBConnectionString"]
    client = CosmosClient.from_connection_string(conn_str)
    db = client.get_database_client("mockDB")
    container = db.get_container_client("mockCollection")

    try:
        # 删除操作需要传入文档id和对应的分区键值
        container.delete_item(item=trip_id, partition_key=bc_id_no)
        return func.HttpResponse("Document deleted successfully", status_code=200)
    except Exception as e:
        logging.error(f"Delete failed: {str(e)}")
        return func.HttpResponse("Delete operation failed", status_code=500)

3. 对应function.json可以移除原有的Cosmos DB输出绑定，仅保留HTTP触发器和输出即可：

{
  "scriptFile": "__init__.py",
  "bindings": [
    {
      "authLevel": "anonymous",
      "type": "httpTrigger",
      "direction": "in",
      "name": "req",
      "methods": ["delete"],
      "route": "delete_rec"
    },
    {
      "type": "http",
      "direction": "out",
      "name": "$return"
    }
  ]
}

方案2：输出绑定曲线实现（仅测试用，不推荐生产环境）

如果一定要通过输出绑定实现，可以利用Cosmos DB的TTL（生存时间）特性：给待删除的文档添加ttl=1的属性，通过输出绑定覆写该文档后，Cosmos DB会在1秒后自动清理该文档。但该方案存在删除延迟，且无法保证立即删除，仅适合非生产场景测试使用。

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