- class PubSubContainer(image: str = 'google/cloud-sdk:emulators', project: str = 'test-project', port: int = 8432, **kwargs)ΒΆ
PubSub container for testing managed message queues.
Example
The example will spin up a Google Cloud PubSub emulator that you can use for integration tests. The
pubsub
instance provides convenience methodsget_publisher
andget_subscriber
to connect to the emulator without having to set the environment variablePUBSUB_EMULATOR_HOST
.def test_docker_run_pubsub(): config = PubSubContainer('google/cloud-sdk:emulators') with config as pubsub: publisher = pubsub.get_publisher() topic_path = publisher.topic_path(pubsub.project, "my-topic") topic = publisher.create_topic(topic_path)