Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/celery/backends/__pycache__/gcs.cpython-39.pyc
Ðазад
a t�hl � @ s� d Z ddlmZ ddlmZmZ ddlmZ ddlmZ ddl m Z ddl m Z ddl mZ dd lmZ d d lmZ z0dd lZdd lmZ ddlmZ ddlmZ W n ey� d ZY n0 dZG dd� de�Z d S )z5Google Cloud Storage result store backend for Celery.� )�ThreadPoolExecutor)�datetime� timedelta)�getpid)�RLock)� bytes_to_str)� dictfilter)� url_to_parts)�ImproperlyConfigured� )�KeyValueStoreBackendN)�storage)�Client)� DEFAULT_RETRY)� GCSBackendc sp e Zd ZdZ� fdd�Zdd� Zdd� Zdd � Zd d � Ze d d � �Z e dd� �Z dd� Z dd� Z dd� Z� ZS )r z)Google Cloud Storage task result backend.c s t � jf i |�� t� | _t� | _t| _d | _t s:t d��| j j }| j rd| �� }|jf i t|��� |�d�| _| js~t d��|�d�| _| js�t d��|�dd��d�| _t|�d d ��| _t|�d �p�d �| _| jd k r�t d | j� d���n"| j�r| �� �st d| j� ���d S )Nz8You must install google-cloud-storage to use gcs backend� gcs_bucketz:Missing bucket name: specify gcs_bucket to use gcs backendZ gcs_projectz6Missing project:specify gcs_project to use gcs backend� gcs_base_path� �/Zgcs_threadpool_maxsize� Zgcs_ttlr z Invalid ttl: z# must be greater than or equal to 0z>Missing lifecycle rule to use gcs backend with ttl on bucket: )�super�__init__r �_lockr �_pidr � _retry_policy�_clientr r Zapp�conf�url�_params_from_url�updater �get� bucket_name�project�strip� base_path�int�_threadpool_maxsize�float�ttl� _is_bucket_lifecycle_rule_exists)�self�kwargsr Z url_params�� __class__� ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/celery/backends/gcs.pyr sJ � � � � ��zGCSBackend.__init__c C s@ t |�}| �|�}z|j| jd�W S tjjy: Y d S 0 d S �N��retry)r � _get_blobZdownload_as_bytesr r �blobZNotFound�r* �keyr4 r. r. r/ r E s zGCSBackend.getc C sB t |�}| �|�}| jr.t�� t| jd� |_|j|| jd� d S )N)�secondsr1 ) r r3 r( r �utcnowr Z custom_timeZupload_from_stringr )r* r6 �valuer4 r. r. r/ �setM s zGCSBackend.setc C s, t |�}| �|�}|�� r(|j| jd� d S r0 )r r3 �exists�deleter r5 r. r. r/ r< T s zGCSBackend.deletec C s< t � �"}t|�| j|��W d � S 1 s.0 Y d S �N)r �list�mapr )r* �keys�poolr. r. r/ �mgetZ s zGCSBackend.mgetc C s� | j �� | jr.| jt� kr.| jW d � S t| jd�| _t� | _tjj| j | j dd�}| jj }|� d|� |j j � d|� | jW d � S 1 s�0 Y dS )zReturns a storage client.N)r" � )�pool_connections� pool_maxsize� max_retrieszhttps://)r r r r r r" �requests�adapters� HTTPAdapterr& Z_http�mountZ _auth_request�session)r* �adapterZ client_httpr. r. r/ �client^ s � zGCSBackend.clientc C s | j �| j�S r= )rM �bucketr! )r* r. r. r/ rN v s zGCSBackend.bucketc C s& | j r| j � d|� �n|}| j�|�S )Nr )r$ rN r4 )r* r6 Zkey_bucket_pathr. r. r/ r3 z s zGCSBackend._get_blobc C s4 | j }|�� |jD ]}|d d dkr dS qdS )N�action�type�DeleteTF)rN �reloadZlifecycle_rules)r* rN �ruler. r. r/ r) ~ s z+GCSBackend._is_bucket_lifecycle_rule_existsc C s t | j�}|j|jd�|j�S )N)r r )r r �hostname�path�query)r* Z url_partsr. r. r/ r � s ��zGCSBackend._params_from_url)�__name__� __module__� __qualname__�__doc__r r r: r< rB �propertyrM rN r3 r) r � __classcell__r. r. r, r/ r s ( r ) rZ �concurrent.futuresr r r �osr � threadingr Zkombu.utils.encodingr Zkombu.utils.functionalr Zkombu.utils.urlr Zcelery.exceptionsr �baser rG Z google.cloudr Zgoogle.cloud.storager Zgoogle.cloud.storage.retryr � ImportError�__all__r r. r. r. r/ �<module> s$
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка