a !f @s,dZddlZddlmZGdddeZdS)zDefine API Topics.N)_rfc3339_to_datetimec@sNeZdZdZdZd ddZeddZeddZed d Z e d d Z dS)MessageaMessages can be published to a topic and received by subscribers. See: https://cloud.google.com/pubsub/reference/rest/v1/PubsubMessage :type data: bytes :param data: the payload of the message :type message_id: string :param message_id: An ID assigned to the message by the API. :type attributes: dict or None :param attributes: Extra metadata associated by the publisher with the message. NcCs||_||_||_dS)N)data message_id _attributes)selfrr attributesr V/var/www/html/python-backend/venv/lib/python3.9/site-packages/gcloud/pubsub/message.py__init__(szMessage.__init__cCs|jduri|_|jS)z'Lazily-constructed attribute dictionaryN)rrr r r r-s zMessage.attributescCs$|jd}|durtdt|S)aReturn sortable timestamp from attributes, if passed. Allows sorting messages in publication order (assuming consistent clocks across all publishers). :rtype: :class:`datetime.datetime` :returns: timestamp (in UTC timezone) parsed from RFC 3339 timestamp :raises: ValueError if timestamp not in ``attributes``, or if it does not match the RFC 3339 format. timestampNz No timestamp)rget ValueErrorr)rZstampr r r r 4s zMessage.timestampcCs|jS)z~Return server-set timestamp. :rtype: string :returns: timestamp (in UTC timezone) in RFC 3339 format )_service_timestampr r r r service_timestampEszMessage.service_timestampcCs:t|dd}|||d|dd}|d|_|S)zFactory: construct message from API representation. :type api_repr: dict or None :param api_repr: The API representation of the message :rtype: :class:`Message` :returns: The message created from the response. rZ messageIdr)rrrZpublishTimestamp)base64 b64decoderr)clsZapi_reprrinstancer r r from_api_reprNs  zMessage.from_api_repr)N) __name__ __module__ __qualname____doc__rr propertyrr r classmethodrr r r r rs    r)rrZgcloud._helpersrobjectrr r r r s