启动 clickhouse 容器的 testcontainers 使用方法

golang学习网今天将给大家带来《启动 clickhouse 容器的 testcontainers 使用方法》，感兴趣的朋友请继续看下去吧！以下内容将会涉及到等等知识点，如果你是正在学习Golang或者已经是大佬级别了，都非常欢迎也希望大家都能给我建议评论哈~希望能帮助到大家！

我想使用 testcontainers 进行集成测试。我需要针对 clickhouse 存储进行测试。

docker 镜像是 yandex/clichouse-server

到目前为止我的代码（主要从 testcontainers 网站上的官方 redis 示例导入）：

ctx := context.Background()
    req := testcontainers.ContainerRequest{
        Image: "yandex/clickhouse-server",
        ExposedPorts: []string{"9000/tcp"},
    }
    chContainer, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{
        ContainerRequest: req,
        Started:          true,
    })
    require.NoError(t, err, "unexpected error while creating clickhouse container")

    endpoint, err := chContainer.Endpoint(ctx, "")
    require.NoError(t, err)

这会在获取端点时引发错误 port not found，并且我不确定从那里去哪里。

正确答案

您是否尝试过在 testcontainers go 中使用等待 api？ https://github.com/testcontainers/testcontainers-go/tree/main/wait

有了它们，您将能够等待多件事（甚至是同时等待）：

• 日志条目
• 准备好端口
• sql 查询
• http 请求
• 在容器中运行程序后的退出代码

您可以在存储库中找到有用的示例。即日志条目的示例：

ctx := context.background()
    req := containerrequest{
        image:        "docker.io/mysql:latest",
        exposedports: []string{"3306/tcp", "33060/tcp"},
        env: map[string]string{
            "mysql_root_password": "password",
            "mysql_database":      "database",
        },
        waitingfor: wait.forlog("test context timeout").withstartuptimeout(1 * time.second),
    }
    _, err := genericcontainer(ctx, genericcontainerrequest{
        providertype:     providertype,
        containerrequest: req,
        started:          true,
    })

编辑：一个更详细的示例，包括使用 http 请求的等待策略：

const (
        dbname       = "crazy"
        fakeuser     = "jondoe"
        fakepassword = "bond girl"
    )

    ctx := context.background()

    req := containerrequest{
        image: "clickhouse/clickhouse-server",
        env: map[string]string{
            "clickhouse_db":       dbname,
            "clickhouse_user":     fakeuser,
            "clickhouse_password": fakepassword,
        },
        exposedports: []string{
            "8123/tcp",
            "9000/tcp",
        },
        waitingfor: wait.forall(
            wait.forhttp("/ping").withport("8123/tcp").withstatuscodematcher(
                func(status int) bool {
                    return status == http.statusok
                },
            ),
        ),
    }

    clickhousecontainer, err := genericcontainer(ctx, genericcontainerrequest{
        containerrequest: req,
        started:          true,
    })
    if err != nil {
        t.fatal(err)
    }

    defer clickhousecontainer.terminate(ctx)

仅供参考，从 v0.23.0 开始，有一个用于 testcontainers-go 的 clickhouse 模块：https://golang.testcontainers.org/modules/clickhouse/

您可以通过非常简单的方式使用它：

添加依赖项：

go get github.com/testcontainers/testcontainers-go/modules/clickhouse

导入：

import "github.com/testcontainers/testcontainers-go/modules/clickhouse"

代码：

ctx := context.Background()

user := "clickhouse"
password := "password"
dbname := "testdb"

clickHouseContainer, err := clickhouse.RunContainer(ctx,
    testcontainers.WithImage("clickhouse/clickhouse-server:23.3.8.21-alpine"),
    clickhouse.WithUsername(user),
    clickhouse.WithPassword(password),
    clickhouse.WithDatabase(dbname),
    clickhouse.WithInitScripts(filepath.Join("testdata", "init-db.sh")),
    clickhouse.WithConfigFile(filepath.Join("testdata", "config.xml")),
)
if err != nil {
    panic(err)
}
defer func() {
    if err := clickHouseContainer.Terminate(ctx); err != nil {
        panic(err)
    }
}()

本篇关于《启动 clickhouse 容器的 testcontainers 使用方法》的介绍就到此结束啦，但是学无止境，想要了解学习更多关于Golang的相关知识，请关注golang学习网公众号！