O*SSKJr SSKrSSKrSSKrSSKrSSKrSSKrSSKJrJ r J r J r J r J r Jr SSKrSSKJr SSKJr SSKJr SSKJr SSKJr SS KJr SS KJr SS KJr SS KJr SS K J!r! SSK"J#r$ SSK"Jr% SSK&J'r( \$RRr)\RT(aSSK+J,r, SSKJ-r- SSK.J/r/ SSK0J1r2 \Rf"\45r5\%RlRo5r8\\Rr\Rt4r;"SS\(Rx5r=g))absolute_importN)AnyDictOptionalSequenceTupleTypeUnion)gapic_v1)AnonymousCredentials)service_account)types) exceptions)futures)thread)ordered_sequencer)unordered_sequencer)FlowController) gapic_version)client) pubsub_v1)_batch) OptionalRetry)pubsubcN^\rSrSrSrS)S\\R\4S\\R\4S\ 4U4Sjjjr \ S*S\ S\\R\4S\ SS4S jj5r\r\S\ 4S j5r\U4S j5rS \ S \ S\4SjrS \ S \ SS4SjrS+U4SjjrS\R0R2\R0R24S \ S\S \ SSSSS\\\ 4SS4SjjrS,SjrS,SjrS,SjrS,SjrS,Sjr S,S jr!S-S \ S!S"S \ SS4S#jjr"S$\#SS4S%jr$S-S \ S&\S \ SS4S'jjr%S(r&U=r'$).Client<a)A publisher client for Google Cloud Pub/Sub. This creates an object that is capable of publishing messages. Generally, you can instantiate this client with no arguments, and you get sensible defaults. Args: batch_settings: The settings for batch publishing. publisher_options: The options for the publisher client. Note that enabling message ordering will override the publish retry timeout to be infinite. kwargs: Any additional arguments provided are sent as keyword arguments to the underlying :class:`~google.cloud.pubsub_v1.gapic.publisher_client.PublisherClient`. Generally you should not need to set additional keyword arguments. Regional endpoints can be set via ``client_options`` that takes a single key-value pair that defines the endpoint. Example: .. code-block:: python from google.cloud import pubsub_v1 publisher_client = pubsub_v1.PublisherClient( # Optional batch_settings = pubsub_v1.types.BatchSettings( max_bytes=1024, # One kilobyte max_latency=1, # One second ), # Optional publisher_options = pubsub_v1.types.PublisherOptions( enable_message_ordering=False, flow_control=pubsub_v1.types.PublishFlowControl( message_limit=2000, limit_exceeded_behavior=pubsub_v1.types.LimitExceededBehavior.BLOCK, ), ), # Optional client_options = { "api_endpoint": REGIONAL_ENDPOINT } ) batch_settingspublisher_optionskwargsc 0>[U5[RLd[U5S:XdS5e[U5[RLd[U5S:XdS5e[ R RS5(a1S[ R RS50US'[5US'[R"U6Ul URSUl [TU]0"S 0UD6 URRUl[ R"Ul[R"U6UlUR$R)5Ul0UlSUlSUl[3URR45Ulg) NrzBbatch_settings must be of type BatchSettings or an empty sequence.zHpublisher_options must be of type PublisherOptions or an empty sequence.PUBSUB_EMULATOR_HOST api_endpointclient_options credentialsF)typer BatchSettingslenPublisherOptionsosenvirongetr r_enable_message_orderingsuper__init__ _transport_host_targetrBatch _batch_classr make_lock _batch_lock _sequencers _is_stopped_commit_threadr flow_control_flow_controller)selfrrr __class__s :lib/third_party/google/cloud/pubsub_v1/publisher/client.pyr0Client.__init__nsn  E$7$7 73~;NRS;S P O P S " #u'='= =$%* V V V + ::>>0 1 1 /E F(F# $%9$:F= !"'!7!79J!K(,(>(>q(A% "6",, "LL#11>B ,,668AC :>!/t/E/E/R/R Sfilenamereturnc Z[RRU5nXCS'U"U40UD6$)acCreates an instance of this client using the provided credentials file. Args: filename: The path to the service account private key JSON file. batch_settings: The settings for batch publishing. kwargs: Additional arguments to pass to the constructor. Returns: A Publisher instance that is the constructed client. r%)r Credentialsfrom_service_account_file)clsrBrr r%s r?rF Client.from_service_account_files2*&11KKHU +}>,V,,rAcUR$)zMReturn the target (where the API is). Returns: The location of the API. )r3r=s r?target Client.targets||rAcN>Sn[R"U[S9 [5$)aOThe underlying gapic API client. .. versionchanged:: 2.10.0 Instead of a GAPIC ``PublisherClient`` client instance, this property is a proxy object to it with the same interface. .. deprecated:: 2.10.0 Use the GAPIC methods and properties on the client instance directly instead of through the :attr:`api` attribute. zThe "api" property only exists for backward compatibility, access its attributes directly thorugh the client instance (e.g. "client.foo" instead of "client.api.foo").)category)warningswarnDeprecationWarningr/)r=msgr>s r?api Client.apis% ,  c$67wrAtopic ordering_keycX4nURRU5nUcBUS:Xa[R"X5nO[R "XU5nX@RU'U$)zTGet an existing sequencer or create a new one given the (topic, ordering_key) pair. )r8r-rUnorderedSequencerrOrderedSequencerr=rUrV sequencer_key sequencers r?_get_or_create_sequencerClient._get_or_create_sequencersk- $$((7  r!/BB4O ->> /8  ] +rANcNUR UR(a [S5eUR(d [ S5eX4nUR R U5nUc[RS5 OUR5 SSS5 g!,(df  g=f)aResume publish on an ordering key that has had unrecoverable errors. Args: topic: The topic to publish messages to. ordering_key: A string that identifies related messages for which publish order should be respected. Raises: RuntimeError: If called after publisher has been stopped by a `stop()` method call. ValueError: If the topic/ordering key combination has not been seen before by this client. z-Cannot resume publish on a stopped publisher.zICannot resume publish on a topic/ordering key if ordering is not enabled.NzCError: The topic/ordering key combination has not been seen before.) r7r9 RuntimeErrorr. ValueErrorr8r-_LOGGERdebugunpauser[s r?resume_publishClient.resume_publishs   "#RSS00 & #1M((,,];I  ( !!#%  s BB B$c$>[TU]"U0UD6$)z#Call the GAPIC public API directly.)r/publish)r=argsr r>s r?_gapic_publishClient._gapic_publish sw///rArXdataretryrtimeoutztypes.OptionalTimeoutattrsz"pubsub_v1.publisher.futures.Futurec |^^[U[5(d [S5eTR(dUS:wa [ S5e[ R "U5R 5HOupx[U[5(aM[U[5(aURS5Xg'MF[S5e [X#US9n [RRU 5mTRRT5 UU4Sjn U[(R*R,LaTR.R0nU[(R*R,LaTR.R2nTR4 TR6(a [9S 5eTR(aoU[(R*R,LaATR:n U R<U R>R@nURCS 5nOURCS 5nTREX5nUR?TXES 9n U RGU 5 TRI5 U sSSS5 $![R a2n ["R$"5n U R'U 5 U sSn A $Sn A ff=f!,(df  g=f) a Publish a single message. .. note:: Messages in Pub/Sub are blobs of bytes. They are *binary* data, not text. You must send data as a bytestring (``bytes`` in Python 3; ``str`` in Python 2), and this library will raise an exception if you send a text string. The reason that this is so important (and why we do not try to coerce for you) is because Pub/Sub is also platform independent and there is no way to know how to decode messages properly on the other side; therefore, encoding and decoding is a required exercise for the developer. Add the given message to this object; this will cause it to be published once the batch either has enough messages or a sufficient period of time has elapsed. This method may block if LimitExceededBehavior.BLOCK is used in the flow control settings. Example: >>> from google.cloud import pubsub_v1 >>> client = pubsub_v1.PublisherClient() >>> topic = client.topic_path('[PROJECT]', '[TOPIC]') >>> data = b'The rain in Wales falls mainly on the snails.' >>> response = client.publish(topic, data, username='guido') Args: topic: The topic to publish messages to. data: A bytestring representing the message body. This must be a bytestring. ordering_key: A string that identifies related messages for which publish order should be respected. Message ordering must be enabled for this client to use this feature. retry: Designation of what errors, if any, should be retried. If `ordering_key` is specified, the total retry deadline will be changed to "infinity". If given, it overides any retry passed into the client through the ``publisher_options`` argument. timeout: The timeout for the RPC request. Can be used to override any timeout passed in through ``publisher_options`` when instantiating the client. attrs: A dictionary of attributes to be sent as metadata. (These may be text strings or byte strings.) Returns: A :class:`~google.cloud.pubsub_v1.publisher.futures.Future` instance that conforms to Python Standard library's :class:`~concurrent.futures.Future` interface (but not an instance of that class). Raises: RuntimeError: If called after publisher has been stopped by a `stop()` method call. pubsub_v1.publisher.exceptions.MessageTooLargeError: If publishing the ``message`` would exceed the max size limit on the backend. z=Data being published to Pub/Sub must be sent as a bytestring.rXzSCannot publish a message with an ordering key when message ordering is not enabled.zutf-8zGAll attributes being published to Pub/Sub must be sent as text strings.)rmrV attributesNc<>TRRT5 gN)r<release)futuremessager=s r?on_publish_done'Client.publish..on_publish_done|s  ! ! ) )' 2rAz&Cannot publish on a stopped publisher.gA)rnro)% isinstancebytes TypeErrorr.rbcopyitemsstrdecode_raw_proto_pubbsub_message gapic_types PubsubMessagewrapr<addrFlowControlLimitErrorrFuture set_exceptionr methodDEFAULTrrnror7r9rar1_wrapped_methodsri_retry with_deadliner^add_done_callback!_ensure_commit_timer_runs_no_lock)r=rUrmrVrnrorpkv vanilla_pbexcrvrx transport base_retryr]rws` @r?riClient.publish sFN$&&O ,,1C+  IIe$**,DA!S!!!U##88G,+  -0U ++00<   ! ! % %g .  3 HOO++ +**00E hoo-- -,,44G   "#KLL ,,HOO333 $I!*!;!;IStart a new thread to actually wait and commit the sequencers.zThread-PubSubBatchCommitterT)namerKdaemonN) threadingThread_wait_and_commit_sequencersr:startrJs r?rClient._start_commit_threads: (...33  !!#rAc2[R"URR5 [R S5 UR  UR(a SSS5 gUR5 SUl SSS5 g!,(df  g=f)z;Wait up to the batching timeout, and commit all sequencers.zCommit thread is waking upN) timesleeprrrcrdr7r9_commit_sequencersr:rJs r?r"Client._wait_and_commit_sequencerssh 4&&223 23      # # %"&D    s B(B Bc(URR5VVs/sHupUR5(dMUPM nnnUHnURU M URR5HnUR 5 M gs snnf)z1Clean up finished sequencers and commit the rest.N)r8r~ is_finishedvaluescommit)r=keyr]finished_sequencer_keysr\s r?rClient._commit_sequencerss#'"2"2"8"8":# ":$$& ": # 5M  /5))002I    3# s BBcUR UR(a [S5eSUlURR 5HnUR 5 M SSS5 g!,(df  g=f)aImmediately publish all outstanding messages. Asynchronously sends all outstanding messages and prevents future calls to `publish()`. Method should be invoked prior to deleting this `Client()` object in order to ensure that no pending messages are lost. .. note:: This method is non-blocking. Use `Future()` objects returned by `publish()` to make sure all publish requests completed, either in success or error. Raises: RuntimeError: If called after publisher has been stopped by a `stop()` method call. z(Cannot stop a publisher already stopped.TN)r7r9rar8rstop)r=r]s r?r Client.stopsY&  "#MNN#D !--446  7   s AA++ A9batchz_batch.thread.BatchcHURX5nURU5 grt)r^ _set_batch)r=rUrrVr]s r?rClient._set_batchs"11%F U#rA batch_classcXlgrt)r5)r=rs r?_set_batch_classClient._set_batch_classs'rAr]c&X4nX RU'grt)r8)r=rUr]rVr\s r?_set_sequencerClient._set_sequencers- *3'rA) r5r7r:r.r<r9r8r3rr)r&r&)r&)rCzpubsub_types.PublishResponse)rCN)rX)(__name__ __module__ __qualname____firstlineno____doc__r rr(rr*rr0 classmethodrrFfrom_service_account_jsonpropertyrKrS SequencerTyper^rfrkr rrr{rirrrrrrrr rr__static_attributes__ __classcell__)r>s@r?rr<s'/f@BEG,Te118;<,T!!7!7!AB,T ,T,T\@B--e118;<- -  --0!: &c""$C"$s"$t"$H0!)!8!8+3??+B+B QQQ Q  Q ) Qucz"Q .Qf5( $ ' !<MO$$!6$FI$ $(D(T( IK44%24BE4 44rAr)> __future__rr}loggingr+rrtypingrrrrrr r rOgoogle.api_corer google.auth.credentialsr google.oauth2r google.cloud.pubsub_v1r google.cloud.pubsub_v1.publisherrr'google.cloud.pubsub_v1.publisher._batchr+google.cloud.pubsub_v1.publisher._sequencerrr0google.cloud.pubsub_v1.publisher.flow_controllerrgoogle.pubsub_v1rpackage_versionr#google.pubsub_v1.services.publisherrpublisher_client __version__ TYPE_CHECKING google.cloudrr*google.pubsub_v1.services.publisher.clientrgoogle.pubsub_v1.typesr pubsub_types getLoggerrrcrpbrrZrYrPublisherClientrr&rAr?rs'   DDD$8)(74:IKK=1J))  &7H=   H %)6699;&&(;(N(NN F4  - -F4rA