arcane-pubsub 1.5.1

Override pubsub client

Arcane PubSub

This package is base on google-cloud-pubsub.

Get Started

pip install arcane-pubsub

Example Usage

from arcane import pubsub

# Import your configs
from configure import Config

client = pubsub.Client(Config.KEY)

client.push_to_topic('project', 'topic', {"parameter": "value"})

Publish with a new schema

result = pubsub_client.publish_with_schema(
    project='my-project',
    topic_name='my-topic-with-schema',
    message=message,
    await_response=True,
)

Note: publish_with_schema caches the topic schema. If you call it in a loop to publish many messages to the same schema topic, it will fetch the schema once and reuse it for the next messages. This avoids excessive SchemaServiceClient.get_schema(...) calls and prevents quota errors when publishing at high volume.