编程网今天将给大家带来《启动 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的相关知识,请关注编程网公众号!