Class PublisherClient (1.8.0)

Version 1.8.0

• 1.11.1 (latest)
• 1.11.0
• 1.10.0
• 1.9.0
• 1.8.3
• 1.7.0
• 1.6.0
• 1.5.0
• 1.4.3
• 1.3.0
• 1.2.0
• 1.1.4
• 1.0.2
• 0.6.1
• 0.5.0
• 0.4.1
• 0.3.0
• 0.2.0
• 0.1.0

PublisherClient(
    *,
    per_partition_batching_settings: Optional[
        google.cloud.pubsub_v1.types.BatchSettings
    ] = None,
    credentials: Optional[google.auth.credentials.Credentials] = None,
    transport: str = "grpc_asyncio",
    client_options: Optional[google.api_core.client_options.ClientOptions] = None,
    enable_idempotence: bool = True
)

A PublisherClient publishes messages similar to Google Pub/Sub. Any publish failures are unlikely to succeed if retried.

Must be used in a with block or have enter() called before use.

Methods

PublisherClient

PublisherClient(
    *,
    per_partition_batching_settings: Optional[
        google.cloud.pubsub_v1.types.BatchSettings
    ] = None,
    credentials: Optional[google.auth.credentials.Credentials] = None,
    transport: str = "grpc_asyncio",
    client_options: Optional[google.api_core.client_options.ClientOptions] = None,
    enable_idempotence: bool = True
)

Create a new PublisherClient.

__enter__

__enter__()

Return self upon entering the runtime context.

__exit__

__exit__(exc_type, exc_value, traceback)

Raise any exception triggered within the runtime context.

publish

publish(
    topic: Union[google.cloud.pubsublite.types.paths.TopicPath, str],
    data: bytes,
    ordering_key: str = "",
    **attrs: Mapping[str, str]
)

Publish a message.

Exceptions
Type	Description
GoogleApiCallError	On a permanent failure.