基于Azure Functions实现输入数据写入Cosmos DB的技术求助

看起来你已经搭好了Azure Functions连接Cosmos DB的基础框架，我帮你把代码补全并梳理清楚关键细节，这样就能完整实现接收HTTP请求并将数据存入Cosmos DB的功能啦：

using Microsoft.AspNetCore.Http;
using Microsoft.Azure.WebJobs;
using Microsoft.Azure.WebJobs.Extensions.Http;
using Microsoft.Extensions.Logging;
using Newtonsoft.Json;
using System.IO;
using System.Threading.Tasks;

// 定义与Cosmos DB容器匹配的实体类
public class ViktigeData
{
    [JsonProperty("id")]
    public string Id { get; set; }
    // 根据你的业务需求添加其他属性
    public string Content { get; set; }
    public string Category { get; set; }
}

public static class DocumentUpdates
{
    [FunctionName("DocumentUpdates")]
    public static async Task Run(
        [HttpTrigger(AuthorizationLevel.Function, "get", "post", Route = null)] HttpRequest req,
        [CosmosDB(
            databaseName: "Fagkveld",
            containerName: "ViktigeData",
            CreateIfNotExists = true,
            ConnectionStringSetting = "CosmosDBConnection")] IAsyncCollector<ViktigeData> cosmosOutput,
        ILogger log)
    {
        log.LogInformation("Received request to create or update Cosmos DB document.");

        // 读取请求体内容
        string requestBody = await new StreamReader(req.Body).ReadToEndAsync();
        var data = JsonConvert.DeserializeObject<ViktigeData>(requestBody);

        if (data == null)
        {
            log.LogError("Invalid request body - could not deserialize to ViktigeData.");
            req.HttpContext.Response.StatusCode = StatusCodes.Status400BadRequest;
            await req.HttpContext.Response.WriteAsync("Invalid request data provided.");
            return;
        }

        // 如果请求未提供Id，自动生成唯一标识
        if (string.IsNullOrEmpty(data.Id))
        {
            data.Id = System.Guid.NewGuid().ToString();
        }

        // 将数据写入Cosmos DB
        await cosmosOutput.AddAsync(data);
        log.LogInformation($"Successfully saved document with Id: {data.Id}");

        req.HttpContext.Response.StatusCode = StatusCodes.Status200OK;
        await req.HttpContext.Response.WriteAsync($"Document saved successfully. Id: {data.Id}");
    }
}

• HTTP触发器配置：
  • AuthorizationLevel.Function：需要使用函数密钥才能访问接口，适合内部或受信任的调用场景
  • 同时支持GET和POST请求，你可以根据实际需求调整（比如只保留POST用于写入数据）
• Cosmos DB输出绑定：
  • 使用IAsyncCollector<T>异步写入，比直接返回实体类更灵活，支持批量操作
  • CreateIfNotExists = true：如果指定的数据库和容器不存在，会自动创建（注意会产生少量初始化开销）
  • ConnectionStringSetting = "CosmosDBConnection"：对应你在local.settings.json或Azure门户配置的Cosmos DB连接字符串名称
• 请求处理与序列化：
  • 用Newtonsoft.Json反序列化请求体（Azure Functions默认包含这个库）
  • 增加了基础参数校验，避免无效数据写入Cosmos DB
  • 自动生成Id（如果请求未提供），确保每个文档有唯一标识
• 日志记录：
  • 通过ILogger记录关键操作日志，方便在Azure门户或本地调试时排查问题

{
  "IsEncrypted": false,
  "Values": {
    "AzureWebJobsStorage": "UseDevelopmentStorage=true",
    "FUNCTIONS_WORKER_RUNTIME": "dotnet",
    "CosmosDBConnection": "你的Cosmos DB连接字符串"
  }
}

如果需要实现更新现有文档的逻辑，只需要在请求中传入已存在的Id，并确保Cosmos DB绑定配置正确的PartitionKey（如果你的容器使用了分区键）即可。

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