我有一个工作的Blazor应用程序,可以读写CosmosDb。尝试添加一些新功能,这些功能在本地可以正常运行,但是部署到Azure后会炸毁。我已将问题追溯到我的计算机中的某个位置CosmosDbService
。我想补充ILogger
到CosmosDbService
,并进一步追查了我的问题。但是,在测试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。你的问题和建议激发了新的思路。我给你的答案功劳。
Startup.cs
导致服务在实际程序执行的更晚时间延迟加载: var logger = s.GetRequiredService<ILogger<CosmosDbService>>();
当我将此行恢复为其原始语法时,它在启动过程中成功初始化。
services.AddSingleton<ICosmosDbService>(InitializeCosmosClientInstanceAsync(Configuration.GetSection("CosmosDb")).GetAwaiter().GetResult());
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添加到服务中。
再次感谢你的协助。
如你所见,你无法在服务注册过程中异步初始化服务。在这些情况下,我使用的解决方案不是直接创建服务,而是返回具有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();
}
}