dZddlmZddlmZddlmZddlmZddlmZddlm Z ddl m Z dd l m Z dd lmZdd lmZd ZGd deZy)z"Utilities for Pub/Sub Lite topics.)absolute_import)division)unicode_literals) cloudpubsub)types)message_transforms)topics) lite_util) gapic_util) http_encodingcRtjtjS)N) credentials)rPublisherClientr GetGapicCredentials0lib/googlecloudsdk/api_lib/pubsub/lite_topics.pyGetDefaultPublisherClientrs!  $ $002 44rc:eZdZdZddZdZdZdZ d dZy) rz,Wrapper client for a Pub/Sub Lite publisher.Nc*|xs t|_yN)r_client)selfclients r__init__zPublisherClient.__init__'s868DLrc:|jj|Sr)r __enter__)rs rrzPublisherClient.__enter__*sLL Krc>|jj|||yr)r__exit__)rexc_type exc_value tracebacks rrzPublisherClient.__exit__.sLL(Iy9rctjtj|jtj |j |jS)N)projectlocationname)r TopicPathr ProjectIdToProjectNumber projectsIdLocationToZoneOrRegion locationsIdtopicsId)rresources r_TopicResourceToPathz$PublisherClient._TopicResourceToPath1sD ??2283F3FG11(2F2FG     rc|s|stjd|j|}|xsi}|r&tj||tj < t jj|jj|tj||fi|jS#t$r*}tjdj!|d}~wwxYw)ahPublishes a message to the specified Pub/Sub Lite topic. Args: topic_resource: The pubsub.lite_topic resource to publish to. message: The string message to publish. ordering_key: The key for ordering delivery to subscribers. attributes: A dict of attributes to attach to the message. event_time: A user-specified event timestamp. Raises: EmptyMessageException: if the message is empty. PublishOperationException: if the publish operation is not successful. Returns: The messageId of the published message, containing the Partition and Offset. zdYou cannot send an empty message. You must specify either a MESSAGE, one or more ATTRIBUTE, or both.z,Publish operation failed with error: {error})errorN)r EmptyMessageExceptionr.rencode_attribute_event_timePUBSUB_LITE_EVENT_TIMErMessageMetadatadecoderpublishr Encoderesult ExceptionPublishOperationExceptionformat)rtopic_resourcemessage ordering_key attributes event_time topic_pathes rPublishzPublisherClient.Publish7s. :  ( ( 5 66**>:J!rJ  8 8 D#::;J  " " ) ) $,,  z=+?+?+H+ ;/9 ;;A68EE J  , , 8 ? ?a ? H JJJsAB77 C*%C%%C*r)NNNN) __name__ __module__ __qualname____doc__rrrr.rCrrrrr$s-49:  &JrrN)rG __future__rrrgoogle.cloud.pubsubliterr#google.cloud.pubsublite.cloudpubsubrgooglecloudsdk.api_lib.pubsubr !googlecloudsdk.command_lib.pubsubr googlecloudsdk.corer googlecloudsdk.core.utilr robjectrrrrrPs; )&'/)B07*24 9Jf9Jr