GCP Cloud Pub/SubGCP Pub/Sub

from google.cloud import pubsub_v1
import json

project_id = "my-project"
topic_id = "order-events"
subscription_id = "order-processor"

# 발행
publisher = pubsub_v1.PublisherClient()
topic_path = publisher.topic_path(project_id, topic_id)

message = {
    "orderId": "ORD-001",
    "customerId": "CUST-123",
    "amount": 99.99,
}
future = publisher.publish(
    topic_path,
    data=json.dumps(message).encode('utf-8'),
    eventType="ORDER_PLACED",
    region="ap-northeast1",
)
print(f"메시지 ID: {future.result()}")

# Pull 구독
subscriber = pubsub_v1.SubscriberClient()
subscription_path = subscriber.subscription_path(project_id, subscription_id)

def callback(message: pubsub_v1.types.PubsubMessage):
    order = json.loads(message.data.decode('utf-8'))
    try:
        process_order(order)
        message.ack()
    except Exception as e:
        message.nack()

streaming_pull_future = subscriber.subscribe(subscription_path, callback=callback)
streaming_pull_future.result(timeout=300)

gcloud pubsub subscriptions create order-push-sub   --topic=order-events   --push-endpoint=https://my-service.run.app/pubsub/push   --push-auth-service-account=pubsub-invoker@my-project.iam.gserviceaccount.com   --ack-deadline=60

gcloud pubsub subscriptions create bq-sub   --topic=order-events   --bigquery-table=my-project:dataset.orders   --use-topic-schema   --write-metadata