pubsub.publisher_client

pubsub.publisher_client

pubsub.publisher_client

Module Contents

Classes

PublisherClient

Functions

init_api_root(api_root)

Attributes

SCOPES

log

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 (Optional[str]) –

Return type:

Tuple[bool, str]

class pubsub.publisher_client.PublisherClient(*, service_file=None, session=None, token=None, api_root=None)
Parameters:

  • service_file (Optional[Union[str, IO[AnyStr]]]) –

  • session (Optional[requests.Session]) –

  • token (Optional[gcloud.aio.auth.Token]) –

  • api_root (Optional[str]) –

_api_root: str
_api_is_dev: bool
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 (Optional[Dict[str, str]]) –

  • session (Optional[requests.Session]) –

  • timeout (int) –

Return type:

Dict[str, Any]

async create_topic(topic, body=None, *, session=None, timeout=10)

Create topic.

Parameters:

  • topic (str) –

  • body (Optional[Dict[str, Any]]) –

  • session (Optional[requests.Session]) –

  • timeout (int) –

Return type:

Dict[str, Any]

async delete_topic(topic, *, session=None, timeout=10)

Delete topic.

Parameters:

  • topic (str) –

  • session (Optional[requests.Session]) –

  • timeout (int) –

Return type:

None

async publish(topic, messages, session=None, timeout=10)
Parameters:
Return type:

Dict[str, Any]

async close()
Return type:

None

async __aenter__()
Return type:

PublisherClient

async __aexit__(*args)
Parameters:

args (Any) –

Return type:

None