BigQuery仿真器是否有Testcontainers支持?
创始人
2024-12-12 13:31:00
0

在maven中添加Testcontainers依赖项,并使用以下代码创建和启动BigQuery仿真器容器(使用Java语言):

public class BigQueryContainer extends Testcontainers {

    private static final String IMAGE_NAME = "gcr.io/google.com/cloudsdktool/cloud-sdk:latest";
    private static final String EMULATOR_CMD = "/bin/sh -c 'gcloud beta emulators bigtable start --host-port=0.0.0.0:8080 && gcloud beta emulators bigtable env-init'";

    private static GenericContainer container;

    public static void startBigQuery() {
        if (container == null) {
            container = new GenericContainer<>(IMAGE_NAME)
                    .withCommand(EMULATOR_CMD)
                    .withExposedPorts(8080)
                    .withEnv("BIGTABLE_EMULATOR_HOST", "localhost:8080")
                    .waitingFor(Wait.forLogMessage(".*started.*\\n", 1))
                    .withLogConsumer(new Slf4jLogConsumer(LoggerFactory.getLogger(BigQueryContainer.class)));
            container.start();
            System.setProperty("BIGTABLE_EMULATOR_HOST", container.getHost() + ":" + container.getFirstMappedPort());
        }
    }

    public static void stopBigQuery() {
        if (container != null) {
            container.stop();
            container = null;
        }
    }
}

在测试中,你可以使用以下代码启动和停止BigQuery仿真器容器:

@BeforeAll
public static void startBigQuery() {
    BigQueryContainer.startBigQuery();
}

@AfterAll
public static void stopBigQuery() {
    BigQueryContainer.stopBigQuery();
}

这将为你提供一个运行BigQuery仿真器的容器,并允许你在测试中使用Testcontainers。

注意:这个示例假定你已经在本地安装了Google Cloud SDK。

以上代码示例来源于此处。

相关内容

热门资讯

Android Recycle... 要在Android RecyclerView中实现滑动卡片效果,可以按照以下步骤进行操作:首先,在项...
安装apache-beam==... 出现此错误可能是因为用户的Python版本太低,而apache-beam==2.34.0需要更高的P...
Android - 无法确定任... 这个错误通常发生在Android项目中,表示编译Debug版本的Java代码时出现了依赖关系问题。下...
Android - NDK 预... 在Android NDK的构建过程中,LOCAL_SRC_FILES只能包含一个项目。如果需要在ND...
Akka生成Actor问题 在Akka框架中,可以使用ActorSystem对象生成Actor。但是,当我们在Actor类中尝试...
Agora-RTC-React... 出现这个错误原因是因为在 React 组件中使用,import AgoraRTC from “ago...
Alertmanager在pr... 首先,在Prometheus配置文件中,确保Alertmanager URL已正确配置。例如:ale...
Aksnginxdomainb... 在AKS集群中,可以使用Nginx代理服务器实现根据域名进行路由。以下是具体步骤:部署Nginx i...
AddSingleton在.N... 在C#中创建Singleton对象通常是通过私有构造函数和静态属性来实现,例如:public cla...
Alertmanager中的基... Alertmanager中可以使用repeat_interval选项指定在一个告警重复发送前必须等待...