Class AsyncPublisherClient (1.4.1) 

AsyncPublisherClient(
    *,
    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
)

An AsyncPublisherClient publishes messages similar to Google Pub/Sub, but must be used in an async context. Any publish failures are unlikely to succeed if retried.

Must be used in an async with block or have aenter() awaited before use.

Inheritance

builtins.object > abc.ABC > contextlib.AbstractAsyncContextManager > builtins.object > typing.Generic > google.cloud.pubsublite.cloudpubsub.publisher_client_interface.AsyncPublisherClientInterface > builtins.object > google.cloud.pubsublite.internal.constructable_from_service_account.ConstructableFromServiceAccount > AsyncPublisherClient

Methods

AsyncPublisherClient

AsyncPublisherClient(
    *,
    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
)

Create a new AsyncPublisherClient.

__aenter__

__aenter__()

Return self upon entering the runtime context.

__aexit__

__aexit__(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
TypeDescription
GoogleApiCallErrorOn a permanent failure.