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,
enable_idempotence: bool = True
)
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.
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,
enable_idempotence: bool = True
)
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 | |
---|---|
Type | Description |
GoogleApiCallError | On a permanent failure. |