Warm tip: This article is reproduced from serverfault.com, please click

azure cosmosdb-CreateContainerIfNotExistsAsync挂起,停顿,永不返回

(azure cosmosdb - CreateContainerIfNotExistsAsync hangs, stalls, never returns)

发布于 2020-12-02 09:35:34

我有一个工作的Blazor应用程序,可以读写CosmosDb。尝试添加一些新功能,这些功能在本地可以正常运行,但是部署到Azure后会炸毁。我已将问题追溯到我的计算机中的某个位置CosmosDbService我想补充ILoggerCosmosDbService,并进一步追查了我的问题。但是,在测试DI时,我的代码停滞在CreateDatabaseIfNotExistsAsync(databasename)在先前的代码中没有错误。没有例外,没有超时,没有任何事情只是无声的失败。Azure没有报告任何内容。如果我将所有内容恢复到原始状态,则可以正常工作。显然它在某处,但我没有看到它。所以我的问题是1)为什么现在我的应用程序停止/挂起?2)我是否将ILogger正确注入到我的CosmosDbService中?这是相关的代码。

Startup.cs
....
            services.AddSingleton<ICosmosDbService>((s) =>
            {
                var logger = s.GetRequiredService<ILogger<CosmosDbService>>();
                return InitializeCosmosClientInstanceAsync(Configuration.GetSection("CosmosDb"), logger).GetAwaiter().GetResult();
            });
'''
        private static async Task<CosmosDbService> InitializeCosmosClientInstanceAsync(IConfigurationSection configurationSection, ILogger logger)
        {
            string databaseName = configurationSection.GetSection("DatabaseName").Value;
            string containerRatings = configurationSection.GetSection("ContainerRatings").Value;
            string containerUsers = configurationSection.GetSection("ContainerUsers").Value;
            string containerLocations = configurationSection.GetSection("ContainerLocations").Value;

            string account = configurationSection.GetSection("Account").Value;
            string key = configurationSection.GetSection("Key").Value;
            CosmosClientBuilder clientBuilder = new CosmosClientBuilder(account, key);
            CosmosClient client = clientBuilder
                                .WithConnectionModeDirect()
                                .WithSerializerOptions(new CosmosSerializationOptions { PropertyNamingPolicy = CosmosPropertyNamingPolicy.Default })
                                .Build();
            //CosmosDbService cosmosDbService = new CosmosDbService(client, databaseName, containerRatings, containerUsers, containerLocations);
            CosmosDbService cosmosDbService = new CosmosDbService()
            {
                ContainerRatings = client.GetContainer(databaseName, containerRatings),
                ContainerRateLocationSmall = client.GetContainer(databaseName, containerLocations),
                ContainerRateUser = client.GetContainer(databaseName, containerUsers),
                CosmosClient = client,
                DatabaseName = databaseName
                , _logger = logger
            };

            DatabaseResponse database = await client.CreateDatabaseIfNotExistsAsync(databaseName);
            await database.Database.CreateContainerIfNotExistsAsync(containerRatings, "/What");
            await database.Database.CreateContainerIfNotExistsAsync(containerUsers, "/UserName");
            await database.Database.CreateContainerIfNotExistsAsync(containerLocations, "/id");
            return cosmosDbService;
        }
...
CosmosDBService.cs
...
    public class CosmosDbService : ICosmosDbService
    {
        public CosmosClient CosmosClient { get; set; }
        public string DatabaseName { get; set; }
        public Container ContainerRatings { get; set; }
        public Container ContainerRateUser { get; set; }
        public Container ContainerRateLocationSmall { get; set; }

        public ILogger _logger { get; set; }
        //public CosmosDbService() { }
...

提前致谢。

-更新2020-12-06-

谢谢Quango。你的问题和建议激发了新的思路。我给你的答案功劳。

  1. 我注意到新行Startup.cs导致服务在实际程序执行的更晚时间延迟加载:
                var logger = s.GetRequiredService<ILogger<CosmosDbService>>();

当我将此行恢复为其原始语法时,它在启动过程中成功初始化。

            services.AddSingleton<ICosmosDbService>(InitializeCosmosClientInstanceAsync(Configuration.GetSection("CosmosDb")).GetAwaiter().GetResult());
  1. 将ILogger注入我的CosmosDBService。在记录(https://docs.microsoft.com/zh-cn/aspnet/core/fundamentals/logging/?view=aspnetcore-5.0上进行重新RTFM似乎我需要使用Factory来代替。所以我将实例化为:
            LoggerFactory loggerFactory = new LoggerFactory();
            //CosmosDbService cosmosDbService = new CosmosDbService(client, databaseName, containerR8ings, containerUsers, containerLocations);
            CosmosDbService cosmosDbService = new CosmosDbService()
            {
                ContainerR8ings = dbClient.GetContainer(databaseName, containerR8ings),
                ContainerR8User = dbClient.GetContainer(databaseName, containerUsers),
                ContainerR8LocationSmall = dbClient.GetContainer(databaseName, containerLocations),
                _logger = loggerFactory.CreateLogger("CosmosDbService")               
            };

并对应于CosmosDBService,方法是删除显式构造函数并使用隐式构造函数。然后,我可以将Logger添加到服务中。

  1. 最终,这使我能够跟踪正在寻找的原始错误。

再次感谢你的协助。

Questioner
BDNTS
Viewed
0
Quango 2020-12-04 17:41:35

如你所见,你无法在服务注册过程中异步初始化服务。在这些情况下,我使用的解决方案不是直接创建服务,而是返回具有async Task<T> CreateAsync执行此操作方法的工厂或提供程序服务你将此提供程序注册为服务,然后注入该提供程序并调用CreateAsync代码。这是一个例子:

using Microsoft.Azure.Cosmos;
using Microsoft.Azure.Cosmos.Fluent;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.Logging;
using System;
using System.Threading.Tasks;

namespace TestWebsite.Services
{
    public class CosmosDbProvider
    {
        /// <summary>
        /// Ctor: values provided by DI
        /// </summary>
        /// <param name="configuration"></param>
        /// <param name="logger"></param>
        public CosmosDbProvider(IConfiguration configuration, ILogger logger)
        {
            config = configuration;
            log = logger;
        }

        IConfiguration config;
        ILogger log;

        ICosmosDbService cachedService;

        public async Task<ICosmosDbService> CreateAsync()
        {
            // use a cached instance for all requests (similar to Lazy<T> but async)
            if (cachedService == null)
            {
                cachedService = await InitializeCosmosClientInstanceAsync();
            }
            return cachedService;
        }

        private async Task<CosmosDbService> InitializeCosmosClientInstanceAsync()
        {
            try
            {
                log.LogInformation("InitializeCosmosClientInstanceAsync started");

                // I'd recommend GetValue<T> for reading single values over GetSection
                string databaseName = config.GetValue<string>("DatabaseName");
                string containerRatings = config.GetValue<string>("ContainerRatings");
                string containerUsers = config.GetValue<string>("ContainerUsers");
                string containerLocations = config.GetValue<string>("ContainerLocations");

                string account = config.GetValue<string>("Account");
                string key = config.GetValue<string>("Key");

                log.LogDebug($"databaseName: {databaseName}");
                log.LogDebug($"containerRatings: {containerRatings}");
                log.LogDebug($"containerUsers: {containerUsers}");
                log.LogDebug($"containerLocations: {containerLocations}");
                // might not want to log sensitive info..
                // log.LogDebug($"account: {account}");
                // log.LogDebug($"key: {key}");

                log.LogDebug("Creating CosmosClientBuilder");
                CosmosClientBuilder clientBuilder = new CosmosClientBuilder(account, key);
                
                log.LogDebug("Creating CosmosClient");
                CosmosClient client = clientBuilder
                                    .WithConnectionModeDirect()
                                    .WithSerializerOptions(new CosmosSerializationOptions { PropertyNamingPolicy = CosmosPropertyNamingPolicy.Default })
                                    .Build();

                log.LogDebug("Creating CosmosDbService");
                CosmosDbService cosmosDbService = new CosmosDbService()
                {
                    ContainerRatings = client.GetContainer(databaseName, containerRatings),
                    ContainerRateLocationSmall = client.GetContainer(databaseName, containerLocations),
                    ContainerRateUser = client.GetContainer(databaseName, containerUsers),
                    CosmosClient = client,
                    DatabaseName = databaseName,
                    _logger = log
                };

                log.LogDebug($"CreateDatabase for '{databaseName}'");
                DatabaseResponse database = await client.CreateDatabaseIfNotExistsAsync(databaseName);
                
                log.LogDebug($"CreateContainer for '{containerRatings}'");
                await database.Database.CreateContainerIfNotExistsAsync(containerRatings, "/What");
                
                log.LogDebug($"CreateContainer for '{containerUsers}'");
                await database.Database.CreateContainerIfNotExistsAsync(containerUsers, "/UserName");

                log.LogDebug($"CreateContainer for '{containerLocations}'");
                await database.Database.CreateContainerIfNotExistsAsync(containerLocations, "/id");

                log.LogInformation("InitializeCosmosClientInstanceAsync completed");
                return cosmosDbService;

            }
            catch (Exception e)
            {
                log.LogError(e, "Failed when initializing CosmosDB");
                throw;
            }

        }
    }
}

我更改了配置代码以使用GetValue<T>-我认为它更简单,并添加了一堆日志记录语句。通常LogDebug在生产环境中这样,你需要更改为调试级别(或者你可以根据需要更改为LogInformation)以帮助诊断问题。

Startup.cs我们添加:

services.AddSingleton<CosmosDbProvider>();

要获取CosmosDB实例,请使用DI注入提供程序。然后,在控制器的Razor和Blazor页面中,你可以进行async呼叫:例如,示例Blazor页面Cosmos.razor

@page "/cosmos"
@inject TestWebsite.Services.CosmosDbProvider cosmosProvider;

<h3>Cosmos</h3>

@if(_db !=null)
{
    <p>Your database is called @_db.DatabaseName</p>
}

@code {

    TestWebsite.Services.ICosmosDbService _db;

    protected override async Task OnInitializedAsync()
    {
        // create/get CosmosDbService
        _db = await cosmosProvider.CreateAsync();
    }
}