google_cloud_pubsub_publish_message_quickstart.py

1import os
2from google.cloud import pubsub_v1
3
4# TODO(developer)
5# project_id = "your-project-id"
6# topic_id = "your-topic-id"
7
8publisher = pubsub_v1.PublisherClient()
9# The `topic_path` method creates a fully qualified identifier
10# in the form `projects/{project_id}/topics/{topic_id}`
11topic_path = publisher.topic_path(project_id, topic_id)
12
13data = "Hello, World!"
14# Data must be a bytestring
15data = data.encode("utf-8")
16
17# When you publish a message, the client returns a future.
18future = publisher.publish(topic_path, data)
19print(future.result())
20
21print(f"Published messages to {topic_path}.")