.NET Core 3.1中Azure Function连接CosmosDB报错求解决方案

针对你在.NET Core 3.1 Azure Function中创建CosmosClient报错的问题，按以下步骤排查解决：

1. 匹配兼容的Cosmos SDK版本 #

.NET Core 3.1不再支持最新的Microsoft.Azure.Cosmos 4.x+版本，这些版本仅适配.NET 6及以上框架。你需要安装3.x系列的稳定版SDK，推荐安装3.31.0（这是支持.NET Core 3.1的最后几个稳定版本之一）。

通过NuGet包管理器执行安装命令：

Install-Package Microsoft.Azure.Cosmos -Version 3.31.0

2. 优化CosmosClient实例创建 #

CosmosClient是线程安全的，无需在每次函数执行时重新创建，重复实例化会导致连接资源浪费甚至报错。将其改为静态单例：

[FunctionName("Function1")]
public static async Task Run([EventHubTrigger("transacciones", Connection = "EventHubConnectionAppSetting")] EventData[] events, ILogger log)
{
    var exceptions = new List<Exception>();
    // 静态单例CosmosClient，仅初始化一次
    static readonly CosmosClient _cosmosClient = new CosmosClient(
        Environment.GetEnvironmentVariable("CosmosDBConnection"),
        new CosmosClientOptions()
        {
            SerializerOptions = new CosmosSerializationOptions()
            {
                IgnoreNullValues = true
            }
        });

    foreach (EventData eventData in events)
    {
        try
        {
            byte[] eventBytes = eventData.Body.ToArray();
            string messageBody = Encoding.UTF8.GetString(eventBytes);
            log.LogInformation($"C# Event Hub trigger function processed a message: {messageBody}");
            
            // 示例：添加写入CosmosDB的逻辑，需替换为你的实体模型
            var container = _cosmosClient.GetContainer("你的数据库名", "你的容器名");
            await container.CreateItemAsync<YourEntityModel>(JsonConvert.DeserializeObject<YourEntityModel>(messageBody));
            
            await Task.Yield();
        }
        catch (Exception e)
        {
            exceptions.Add(e);
        }
    }

    // 批量抛出捕获的异常（可选，根据业务需求调整）
    if (exceptions.Count > 0)
    {
        throw new AggregateException(exceptions);
    }
}

3. 清理冗余依赖 #

卸载任何与Microsoft.Extensions.Configuration相关的过时包，确保项目依赖仅保留.NET Core 3.1兼容的版本。可通过右键项目→管理NuGet包，查看已安装包并移除版本不兼容的项。

4. 验证连接配置 #

• 确认Azure Function应用设置中CosmosDBConnection的值是正确的Cosmos DB账户连接字符串（包含主密钥/只读密钥）。
• 检查Cosmos DB的防火墙设置，是否允许Azure服务访问，或者将函数的出站IP加入允许列表。

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