Azure Functions中CosmosClient的CreateAndInitializeAsync应置于何处？

针对你遇到的问题，这里有几个实用的放置CreateAndInitializeAsync的方案，既能避免首次请求延迟，又不会阻塞函数启动：

1. 静态异步延迟初始化（推荐） #

利用静态构造函数结合延迟异步初始化，确保预热操作只执行一次，且不会阻塞函数的启动流程。示例代码如下：

public class CosmosDbFunction
{
    private static readonly Lazy<Task<CosmosClient>> _lazyCosmosClient = new Lazy<Task<CosmosClient>>(InitializeCosmosClientAsync);
    private CosmosClient _cosmosClient;

    public CosmosDbFunction()
    {
        // 首次执行时触发预热，等待初始化完成
        _cosmosClient = _lazyCosmosClient.Value.GetAwaiter().GetResult();
    }

    private static async Task<CosmosClient> InitializeCosmosClientAsync()
    {
        var client = new CosmosClient(Environment.GetEnvironmentVariable("CosmosDbConnectionString"));
        // 指定需要预热的数据库和容器
        await client.CreateAndInitializeAsync(
            databasesAndContainers: new[]
            {
                ("YourDatabaseId", "YourContainerId")
            });
        return client;
    }

    [FunctionName("YourFunctionTrigger")]
    public async Task Run([TimerTrigger("0 */5 * * * *")] TimerInfo myTimer, ILogger log)
    {
        // 直接使用已预热的客户端执行操作
        var container = _cosmosClient.GetContainer("YourDatabaseId", "YourContainerId");
        // 业务逻辑...
    }
}

Lazy<Task<CosmosClient>>保证初始化只触发一次，异步初始化不会阻塞DI或函数启动流程，首次构造函数执行时完成预热。

2. 首次请求触发+锁控制 #

如果不想在构造函数中处理，可以在函数入口处添加初始化检查，用锁确保多并发请求下只执行一次预热：

public class CosmosDbFunction
{
    private static CosmosClient _cosmosClient;
    private static readonly object _lockObj = new object();
    private readonly ILogger _logger;

    public CosmosDbFunction(ILogger<CosmosDbFunction> logger)
    {
        _logger = logger;
    }

    [FunctionName("YourFunctionTrigger")]
    public async Task Run([HttpTrigger(AuthorizationLevel.Function, "get")] HttpRequest req)
    {
        await EnsureCosmosClientInitializedAsync();
        
        // 使用预热后的客户端执行操作
        var container = _cosmosClient.GetContainer("YourDatabaseId", "YourContainerId");
        // 业务逻辑...
    }

    private async Task EnsureCosmosClientInitializedAsync()
    {
        if (_cosmosClient != null) return;
        
        lock (_lockObj)
        {
            if (_cosmosClient != null) return;
            
            // 锁内用异步操作避免阻塞
            _cosmosClient = await Task.Run(async () =>
            {
                var client = new CosmosClient(Environment.GetEnvironmentVariable("CosmosDbConnectionString"));
                await client.CreateAndInitializeAsync(new[] { ("YourDatabaseId", "YourContainerId") });
                _logger.LogInformation("Cosmos Client预热完成");
                return client;
            });
        }
    }
}

这种方式由首次请求触发预热，不会占用函数启动资源，但首次请求会稍慢，后续请求无延迟。

3. Premium/Dedicated计划专属：预热触发器 #

如果你的函数运行在Premium或Dedicated计划下，可以用Azure Functions的预热触发器专门处理初始化：

public class WarmupFunction
{
    [FunctionName("Warmup")]
    public async Task Run([WarmupTrigger()] WarmupContext context, ILogger log)
    {
        var client = new CosmosClient(Environment.GetEnvironmentVariable("CosmosDbConnectionString"));
        await client.CreateAndInitializeAsync(new[] { ("YourDatabaseId", "YourContainerId") });
        log.LogInformation("Cosmos Client通过预热触发器完成初始化");
        
        // 可在此缓存其他需要预热的资源
    }
}

注意：预热触发器仅支持Premium和Dedicated计划，Consumption计划无法使用。

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