pubsub.subscriber_message

pubsub.subscriber_message

pubsub.subscriber_message

Module Contents

Classes

SubscriberMessage

Functions

parse_publish_time(publish_time)

pubsub.subscriber_message.parse_publish_time(publish_time)
Parameters:

publish_time (str) –

Return type:

datetime.datetime

class pubsub.subscriber_message.SubscriberMessage(ack_id, message_id, publish_time, data, attributes, delivery_attempt=None)
Parameters:
  • ack_id (str) –

  • message_id (str) –

  • publish_time (datetime.datetime) –

  • data (Optional[bytes]) –

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

  • delivery_attempt (Optional[int]) –

static from_repr(received_message)
Parameters:

received_message (Dict[str, Any]) –

Return type:

SubscriberMessage

to_repr()
Return type:

Dict[str, Any]