pubsub.publisher_client¶
Attributes¶
Classes¶
Functions¶
|
Module Contents¶
- pubsub.publisher_client.SCOPES = ['https://www.googleapis.com/auth/pubsub']¶
- pubsub.publisher_client.log¶
- pubsub.publisher_client.init_api_root(api_root)¶
- Parameters:
api_root (str | None)
- Return type:
tuple[bool, str]
- class pubsub.publisher_client.PublisherClient(*, service_file=None, session=None, token=None, api_root=None)¶
- Parameters:
service_file (str | IO[AnyStr] | None)
session (requests.Session | None)
token (gcloud.aio.auth.Token | None)
api_root (str | None)
- _api_root: str¶
- _api_is_dev: bool¶
- session¶
- token¶
- static project_path(project)¶
- Parameters:
project (str)
- Return type:
str
- classmethod subscription_path(project, subscription)¶
- Parameters:
project (str)
subscription (str)
- Return type:
str
- classmethod topic_path(project, topic)¶
- Parameters:
project (str)
topic (str)
- Return type:
str
- async _headers()¶
- Return type:
dict[str, str]
- async list_topics(project, query_params=None, *, session=None, timeout=10)¶
List topics
- Parameters:
project (str)
query_params (dict[str, str] | None)
session (requests.Session | None)
timeout (int)
- Return type:
dict[str, Any]
- async create_topic(topic, body=None, *, session=None, timeout=10)¶
Create topic.
- Parameters:
topic (str)
body (dict[str, Any] | None)
session (requests.Session | None)
timeout (int)
- Return type:
dict[str, Any]
- async delete_topic(topic, *, session=None, timeout=10)¶
Delete topic.
- Parameters:
topic (str)
session (requests.Session | None)
timeout (int)
- Return type:
None
- async publish(topic, messages, session=None, timeout=10)¶
- Parameters:
topic (str)
messages (list[pubsub.utils.PubsubMessage])
session (requests.Session | None)
timeout (int)
- Return type:
dict[str, Any]
- async close()¶
- Return type:
None
- async __aenter__()¶
- Return type:
- async __aexit__(*args)¶
- Parameters:
args (Any)
- Return type:
None