Pubsub，推送到所有云运行容器

from google.cloud import pubsub_v1

# 发布消息
def publish_message(project_id, topic_name, message):
    publisher = pubsub_v1.PublisherClient()
    topic_path = publisher.topic_path(project_id, topic_name)
    future = publisher.publish(topic_path, data=message.encode('utf-8'))
    print(f"Message published: {message}")
    return future.result()

# 订阅消息
def subscribe_to_topic(project_id, subscription_name):
    subscriber = pubsub_v1.SubscriberClient()
    subscription_path = subscriber.subscription_path(project_id, subscription_name)
    
    def callback(message):
        print(f"Received message: {message.data.decode('utf-8')}")
        message.ack()
    
    streaming_pull_future = subscriber.subscribe(subscription_path, callback=callback)
    print(f"Listening for messages on {subscription_path}...")
    
    with subscriber:
        try:
            streaming_pull_future.result()
        except KeyboardInterrupt:
            streaming_pull_future.cancel()

# 示例调用
project_id = 'your-project-id'
topic_name = 'your-topic-name'
subscription_name = 'your-subscription-name'

publish_message(project_id, topic_name, 'Hello, Pub/Sub!')
subscribe_to_topic(project_id, subscription_name)