使用 .NET core SDK 创建 Cosmos Db 时遇到问题

Question

代码成功创建了容器，现在可以使用了。然而，当尝试创建数据库时，它进入了无限循环。

var name = "cosmosdb_emulator";
var exposedPort = 8083; // Port exposed by the container
var ContainerCosmosServicePort = 8081; // Port used by the Cosmos service within the container

try
{
    var containerService = new Builder()
                .UseContainer()
                .WithName(name)
                .UseImage($"mcr.microsoft.com/cosmosdb/linux/azure-cosmos-emulator")
                .ReuseIfExists()
                .ExposePort(exposedPort, ContainerCosmosServicePort)
               // .WaitForMessageInLog("Cosmos service is successfully listening")
                .Build();                    
           
    containerService.Start();
    Console.WriteLine($"Container {name} started successfully.");

    var _cosmosdbConnectionString = "AccountEndpoint=https://localhost:8083/;AccountKey=C2y6yDjf5/R+ob0N8A7Cgv30VRDJIWEHLM+4QDU5DE2nQ9nDuVTqobD4b8mGGyPMbIZnqyMsEcaGQy67XIw/Jw==";

    CosmosClientOptions options = new()
    {
        HttpClientFactory = () => new HttpClient(new HttpClientHandler()
        {
             ServerCertificateCustomValidationCallback = HttpClientHandler.DangerousAcceptAnyServerCertificateValidator
        })};

        // Initialize Cosmos DB client
        CosmosClient client = new CosmosClient(_cosmosdbConnectionString, clientOptions: options);

        // Check if the database exists; if not, create it
        DatabaseResponse databaseResponse = await client.CreateDatabaseIfNotExistsAsync("abc");
    }
}

Answer 1

这对我有用。

作为参考，请检查此文档。

对于 Docker 容器创建，请遵循此文档。

using System;
using System.Collections.Generic;
using System.Net.Http;
using System.Threading.Tasks;
using Docker.DotNet;
using Docker.DotNet.Models;
using Microsoft.Azure.Cosmos;

namespace CosmosDBConsoleApp
{
    public class Program
    {
        public static async Task Main()
        {

            try
            {
                DockerClient client = new DockerClientConfiguration()
                 .CreateClient();

                await client.Images.CreateImageAsync(
                new ImagesCreateParameters
                {
                    FromImage = "mcr.microsoft.com/cosmosdb/windows/azure-cosmos-emulator",
                    Tag = "latest"

                },
                null,
                new Progress<JSONMessage>()) ;

                Console.WriteLine("Image is pulled");

                var container = await client.Containers.CreateContainerAsync(new CreateContainerParameters()
                {
                    Image = "mcr.microsoft.com/cosmosdb/linux/azure-cosmos-emulator",
                    HostConfig = new HostConfig
                    {
                        PortBindings = new Dictionary<string, IList<PortBinding>>
                            {
                                { "8081", new List<PortBinding> { new PortBinding { HostPort = "8081" } } }
                            },
                            DNS = new[] { "0.0.0.0:8081" }

                   }

                });

                Console.WriteLine("Container created sucessfully");
                await client.Containers.StartContainerAsync(container.ID,
                   new ContainerStartParameters());

                Console.WriteLine("Container started successfully");

                var _cosmosdbConnectionString = "AccountEndpoint=https://localhost:8081/;AccountKey=C2y6yDjf5/R+ob0N8A7Cgv30VRDJIWEHLM+4QDU5DE2nQ9nDuVTqobD4b8mGGyPMbIZnqyMsEcaGQy67XIw/Jw==";
                    CosmosClientOptions options = new()
                    {
                        HttpClientFactory = () => new HttpClient(new HttpClientHandler()
                        {
                            ServerCertificateCustomValidationCallback = HttpClientHandler.DangerousAcceptAnyServerCertificateValidator
                        })
                    };

                    // Initialize Cosmos DB client
                    CosmosClient cosmosclient = new CosmosClient(_cosmosdbConnectionString, clientOptions: options);
                                

                    Console.WriteLine("Cosmos client created");

                Database database = await cosmosclient.CreateDatabaseIfNotExistsAsync(
                    id: "cosmosemulatordb",
                    throughput: 400
                );
                Console.WriteLine("Cosmos Database created sucessfully");
                Container dbcontainer = await database.CreateContainerIfNotExistsAsync(
                    id: "emulatorcontainer",
                    partitionKeyPath: "/id"
                );

                Console.WriteLine("Cosmos Container created sucessfully");

                var item = new
                {
                    id = "68719518371",
                    name = "Kiama classic surfboard"
                };

                await dbcontainer.UpsertItemAsync(item);

                Console.WriteLine("item created sucessfully");
            }
            catch (Exception ex)
            {
                Console.WriteLine($"An error occurred: {ex.Message}");
            }

        }
    }
}

OUTPUT

：

{
    "id": "68719518371",
    "name": "Kiama classic surfboard"
}