CURRENT PATH:
/
opt
/
gsutil
/
gslib
/
__pycache__
/
[ ⬅ KEMBALI ]
|
[ HOME ]
Upload File:
Upload Ke Sini
Dir Baru
File Baru
Editing:
pubsub_api.cpython-39.pyc
a +(Wg�, � @ sF d Z ddlmZ ddlmZ ddlmZ ddlmZ ddlZddlZddlZddl m Z ddl m Z dd lmZ dd lmZ dd lmZ dd lmZ dd lmZ ddlmZ ddlmZ ddlmZ ddlmZ ddl m Z ddl m Z ddl m!Z! ddl m"Z" ddl m#Z# ddl$m%Z% e j&Z'e �(� �r.dZ)ndZ)G dd� de*�Z+dS ) z>JSON gsutil Cloud API implementation for Google Cloud Storage.� )�absolute_import)�print_function)�division)�unicode_literalsN)� exceptions)�config)�AccessDeniedException)�BadRequestException)�NotFoundException)�PreconditionException)�ServiceException)� SetUpJsonCredentialsAndCache)�NoOpCredentials)�pubsub_v1_client)�pubsub_v1_messages)� system_util)� GetCertsFile)�GetMaxRetryDelay)� GetNewHttp)� GetNumRetries)�UTF8zVInsufficient OAuth2 scope to perform this operation. Please re-run `gcloud auth login`zRInsufficient OAuth2 scope to perform this operation. Please re-run `gsutil config`c sn e Zd ZdZd� fdd� Zdd� Zdd � Zd d � Zd d � Zdd� Z ddd�Z dd� Z dd� Z ddd�Z � ZS )� PubsubApiz;Wraps calls to the Cloud Pub/Sub v1 interface via apitools.Nr c s� t t| ��� || _t� | _t� | _d| _t � ddd�| _ t � ddd�}|rTd| nd| _ | j| j | j | _ t| ||d � |d k}|d k}tj| j | j||| jd �| _t� | _| j| j_t� | _| j| j_t| jt�r�| j�d d � dS )a' Performs necessary setup for interacting with Google Cloud Pub/Sub. Args: logger: logging.logger for outputting log messages. credentials: Credentials to be used for interacting with Google Cloud Pub/Sub debug: Debug level for the API implementation (0..3). zhttps://� CredentialsZgs_pubsub_hostzpubsub.googleapis.com�gs_pubsub_portN�:� )� credentials� )�url�http� log_request� log_responser �key�'AIzaSyDnacJHrKma0048b13sh8cgxNUwulubmJM)�superr �__init__�loggerr � certs_filer r � http_baser �get� host_base� host_port�url_baser �apitools_clientZPubsubV1r � api_clientr � num_retriesr �max_retry_wait� isinstancer �AddGlobalParam)�selfr& r �debugr r r! �� __class__� � /opt/gsutil/gslib/pubsub_api.pyr% ; s8 �� �zPubsubApi.__init__c C sT t j|d�}z| jj�|�W S tyN } z| j||d� W Y d }~n d }~0 0 d S )N��topic�� topic_name)�apitools_messagesZ PubsubProjectsTopicsGetRequestr. �projects_topics�Get� TRANSLATABLE_APITOOLS_EXCEPTIONS�_TranslateExceptionAndRaise�r3 r< �request�er7 r7 r8 �GetTopicg s zPubsubApi.GetTopicc C sT t j|d�}z| jj�|�W S tyN } z| j||d� W Y d }~n d }~0 0 d S )N)�namer; )r= ZTopicr. r> �Creater@ rA )r3 r< r: rD r7 r7 r8 � CreateTopicn s zPubsubApi.CreateTopicc C sT t j|d�}z| jj�|�W S tyN } z| j||d� W Y d}~n d}~0 0 dS )zOnly used in system tests.r9 r; N)r= Z!PubsubProjectsTopicsDeleteRequestr. r> �Deleter@ rA rB r7 r7 r8 � DeleteTopicu s �zPubsubApi.DeleteTopicc C sT t j|d�}z| jj�|�W S tyN } z| j||d� W Y d }~n d }~0 0 d S )N)�resourcer; )r= Z'PubsubProjectsTopicsGetIamPolicyRequestr. r> � GetIamPolicyr@ rA rB r7 r7 r8 �GetTopicIamPolicy~ s �zPubsubApi.GetTopicIamPolicyc C sb t j|d�}t j||d�}z| jj�|�W S ty\ } z| j||d� W Y d }~n d }~0 0 d S )N)�policy)rK �setIamPolicyRequestr; )r= �SetIamPolicyRequestZ'PubsubProjectsTopicsSetIamPolicyRequestr. r> � SetIamPolicyr@ rA )r3 r< rN �policy_requestrC rD r7 r7 r8 �SetTopicIamPolicy� s �zPubsubApi.SetTopicIamPolicyc C s> | j �tj�r | j �dt�� � | j||d�}|r8|�n� dS )a+ Translates an HTTP exception and raises the translated or original value. Args: e: Any Exception. topic_name: Optional topic name in request that caused the exception. Raises: Translated CloudApi exception, or the original exception if it was not translatable. z TranslateExceptionAndRaise: %sr; N)r& � isEnabledFor�logging�DEBUGr4 � traceback� format_exc�_TranslateApitoolsException)r3 rD r< �translated_exceptionr7 r7 r8 rA � s ��z%PubsubApi._TranslateExceptionAndRaisec C sh t |tj�rdt|dd �rdz8t�|j�t��}d|v rNd|d v rN|d d W S W n t yb Y n0 d S )N�content�error�message) r1 �apitools_exceptions� HttpError�getattr�json�loadsr[ �decoder � Exception)r3 � http_error�json_objr7 r7 r8 �_GetMessageFromHttpError� s z"PubsubApi._GetMessageFromHttpErrorc C sX z@|j d }|�d�}|dkr>||d � �d�d }d| W S W n tyR Y n0 d S )Nzwww-authenticatezscope="r �"� zAcceptable scopes: %s)�response�find�splitrd )r3 re �www_authenticate� scope_idx�scopesr7 r7 r8 �!_GetAcceptableScopesFromHttpError� s z+PubsubApi._GetAcceptableScopesFromHttpErrorc C s� t |tj��r�| �|�}|jdkr4t|p*d|jd�S |jdkr�dt|�v r\t|pRd|jd�S dt|�v r~tt|j| � |�d�S �n|jd k�r<d t|�v r�t|p�d |jd�S d t|�v r�t|p�d |jd�S dt|�v r�td|jd�S dt|�v �r td|jd�S dt|�v �r$tt|j| � |�d�S t|�p0|j |jd�S nX|jdk�rVt ||jd�S |jdk�rz|�rzt d| |jd�S |jdk�r�t ||jd�S t ||jd�S dS )a- Translates apitools exceptions into their gsutil equivalents. Args: e: Any exception in TRANSLATABLE_APITOOLS_EXCEPTIONS. topic_name: Optional topic name in request that caused the exception. Returns: ServiceException for translatable exceptions, None otherwise. i� z Bad Request)�statusi� zLogin Requiredz Access denied: login required.�insufficient_scope)rq �bodyi� z7The account for the specified project has been disabledzAccount disabled.z,Daily Limit for Unauthenticated Use Exceededz8Access denied: quota exceeded. Is your project ID valid?zUser Rate Limit Exceededz5Rate limit exceeded. Please retry this request later.zAccess Not Configuredz�Access Not Configured. Please go to the Google Cloud Platform Console (https://cloud.google.com/console#/project) for your project, select APIs and Auth and enable the Google Cloud Pub/Sub API.i� i� z The topic %s already exists.i� N)r1 r^ r_ rg � status_coder �strr �"_INSUFFICIENT_OAUTH2_SCOPE_MESSAGErp r] r r r )r3 rD r< r] r7 r7 r8 rY � sp � � � � � ��� � � z%PubsubApi._TranslateApitoolsException)NNr )N)N)�__name__� __module__� __qualname__�__doc__r% rE rH rJ rM rS rA rg rp rY � __classcell__r7 r7 r5 r8 r 8 s , r ),rz � __future__r r r r ra rU rW �apitools.base.pyr r^ �botor �gslib.cloud_apir r r r r �gslib.gcs_json_credentialsr �gslib.no_op_credentialsr Z!gslib.third_party.pubsub_apitoolsr r- r r= � gslib.utilsr Zgslib.utils.boto_utilr r r r �gslib.utils.constantsr r_ r@ �InvokedViaCloudSdkrv �objectr r7 r7 r7 r8 �<module> s> ��
SIMPAN
[ BATAL ]