Cosmos SDK3容器可以是单例吗？

Question

我想减少Azure Cosmos DB SQL-API上的负载，它是从具有依赖注入的.NET Core Web API调用的。

在App Insights中，我注意到对Web API的每次调用都会导致对Cosmos的GetDatabase和GetCollection调用，当Cosmos负载较重时，这些调用可能需要5秒才能运行。

我已经将CosmosClient作为单例（例如这里的建议 - https://docs.microsoft.com/en-us/azure/cosmos-db/performance-tips-dotnet-sdk-v3-sql）

但是，我找不到任何关于数据库或容器对象是否也可以是单例的建议，因此它们是为对Web API的每个请求创建的。

我检查数据库和集合的存在（例如，遵循此处的建议 - https://docs.microsoft.com/en-us/dotnet/api/microsoft.azure.cosmos.cosmosclient.getdatabase?view=azure-dotnet#remarks 和 https://docs.microsoft.com/en-us/dotnet/api/microsoft.azure.cosmos.cosmosclient.getcontainer?view=azure-dotnet#remarks）

这意味着对于Web API的每个请求，将运行以下代码

var databaseResponse = await this.cosmosClient.CreateDatabaseIfNotExistsAsync(
    this.databaseConfiguration.DatabaseName,
    throughput: this.databaseConfiguration.DatabaseLevelThroughput);
var database = databaseResponse.Database;
var containerResponse = await database.CreateContainerIfNotExistsAsync(containerId, partitionKey);
var container = containerResponse.Container;

我能否将< code>Database和< code>Container设为单例，并将其添加到要像< code>CosmosClient一样注入的DI中，以便减少在App Insights中看到的GetDatabase和GetCollection的调用次数？

Answer 1

CreateDatabase aseIfNotExistsAsync应该只调用一次，因为它只是DB配置的设置步骤。

最好创建一个 DbService 来持久保存容器对象。并将 DbService 注入到每个服务中，而不是 DB 客户端

Answer 2

您不需要每次都调用＜code＞CreateIfNotExistsAsync是一个轻量级代理类。

除非您希望数据库和容器在某个时候被动态删除。

Answer 3

根据最新的Microsoft留档，您创建了一个CosmosClient Service单例，它拥有您将使用的容器。也会影响容器单例。

首先，制定接口合同：

public interface ICosmosDbService
{
    // identify the database CRUD operations you need
}

其次，根据合同定义您的服务：

public class CosmosDbService : ICosmosDbService
{
    private Container _container;

    public CosmosDbService(CosmosClient dbClient, string databaseName, string containerName)
    {
        this._container = dbClient.GetContainer(databaseName, containerName);
    }
    
    // your database CRUD operations go here using the Container field(s)
}

第三，在Startup类中创建一个方法来返回CosmosClient：

private static async Task<CosmosDbService> InitializeCosmosClientAsync(IConfigurationSection cosmosConfig)
{
    var databaseName = cosmosConfig.GetSection("DatabaseName").Value;
    var containerName = cosmosConfig.GetSection("ContainerName").Value;
    var account = cosmosConfig.GetSection("Account").Value;
    var key = cosmosConfig.GetSection("Key").Value;
    var client = new Microsoft.Azure.Cosmos.CosmosClient(account, key);
    var database = await client.CreateDatabaseIfNotExistsAsync(databaseName);
    await database.Database.CreateContainerIfNotExistsAsync(containerName, "/id");
    return new CosmosDbService(client, databaseName, containerName);
}

最后，将您的CosmosClient添加到ServiceCollection：

public void ConfigureServices(IServiceCollection services)
{
    var cosmosConfig = this.Configuration.GetSection("CosmosDb");
    var cosmosClient = InitializeCosmosClientAsync(cosmosConfig).GetAwaiter().GetResult();
    services.AddSingleton<ICosmosDbService>(cosmosClient);
}

现在，你的 CosmosClient 只创建了一次（包含所有容器），每次通过依赖关系注入获取它时，它都会被重用。