Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/kombu/transport/sqlalchemy/__pycache__/__init__.cpython-39.pyc
Ðазад
a o�h~ � @ s� d Z ddlmZ ddlZddlmZmZ ddlmZ ddl m Z m Z ddl m Z ddlmZ dd lmZ dd lmZ dd lmZ d d lmZ d dlmZ d dlmZ d dlm Z m Z dZ d� e e!e ��Z"e�#� Z$G dd� dej%�Z%G dd� dej&�Z&dS )aG SQLAlchemy Transport module for kombu. Kombu transport using SQL Database as the message store. Features ======== * Type: Virtual * Supports Direct: yes * Supports Topic: yes * Supports Fanout: no * Supports Priority: no * Supports TTL: no Connection String ================= .. code-block:: sqla+SQL_ALCHEMY_CONNECTION_STRING sqlalchemy+SQL_ALCHEMY_CONNECTION_STRING For details about ``SQL_ALCHEMY_CONNECTION_STRING`` see SQLAlchemy Engine Configuration documentation. Examples -------- .. code-block:: # PostgreSQL with default driver sqla+postgresql://scott:tiger@localhost/mydatabase # PostgreSQL with psycopg2 driver sqla+postgresql+psycopg2://scott:tiger@localhost/mydatabase # PostgreSQL with pg8000 driver sqla+postgresql+pg8000://scott:tiger@localhost/mydatabase # MySQL with default driver sqla+mysql://scott:tiger@localhost/foo # MySQL with mysqlclient driver (a maintained fork of MySQL-Python) sqla+mysql+mysqldb://scott:tiger@localhost/foo # MySQL with PyMySQL driver sqla+mysql+pymysql://scott:tiger@localhost/foo Transport Options ================= * ``queue_tablename``: Name of table storing queues. * ``message_tablename``: Name of table storing messages. Moreover parameters of :func:`sqlalchemy.create_engine()` function can be passed as transport options. � )� annotationsN)�dumps�loads)�Empty)� create_engine�text)�OperationalError)� sessionmaker)�virtual)�cached_property)� bytes_to_str� )�Message)� ModelBase)�Queue)�class_registry�metadata)r � r �.c s� e Zd ZdZdZi Z� fdd�Zdd� Zdd� Zd d � Z e d d � �Z d d� Z dd� Z dd� Zdd� Zdd� Zdd� Zdd� Zdd � Zed d � �Zed d � �Z� ZS )!�ChannelzThe channel class.Nc s& | � |jj� t� j|fi |�� d S �N)� _configure_entity_tablenames�client�transport_options�super�__init__)�self� connection�kwargs�� __class__� ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/kombu/transport/sqlalchemy/__init__.pyr \ s zChannel.__init__c C s, |� dd�| _|� dd�| _| jo&| j d S )N�queue_tablenameZ kombu_queue�message_tablenameZ kombu_message)�getr# r$ � queue_cls� message_cls)r �optsr! r! r" r ` s z$Channel._configure_entity_tablenamesc C s� | j j}|j�� }|�dd � |�dd � |�dd � |�dd � |�dd � |�dd � |�dd � |�dd � |�d d � t|jfi |��S ) Nr# r$ �callbackZerrback� max_retriesZinterval_startZ interval_stepZ interval_maxZ retry_errors)r r r �copy�popr �hostname)r �conninfor r! r! r" �_engine_from_configk s zChannel._engine_from_configc C s� | j j}|j| jvr�t�b |j| jv r@| j|j W d � S | �� }t|d�}t�|� ||f| j|j< W d � n1 s�0 Y | j|j S )N)�bind) r r r- �_engines�_MUTEXr/ r r Z create_all)r r. Zengine�Sessionr! r! r" �_openz s .z Channel._openc C s$ | j d u r | �� \}}|� | _ | j S r )�_sessionr4 )r �_r3 r! r! r" �session� s zChannel.sessionc C s� | j �| j��| jj|k��� }|s�t�� | j �| j��| jj|k��� }|r`|W d � S | �|�}| j �|� z| j �� W n t y� | j � � Y n0 W d � n1 s�0 Y |S r ) r7 �queryr& �filter�name�firstr2 �add�commitr �rollback�r �queue�objr! r! r" �_get_or_create� s" � � .zChannel._get_or_createc K s | � |� d S r )rB )r r@ r r! r! r" � _new_queue� s zChannel._new_queuec K sV | � |�}| �t|�|�}| j�|� z| j�� W n tyP | j�� Y n0 d S r )rB r' r r7 r< r= r r> )r r@ �payloadr rA �messager! r! r" �_put� s z Channel._putc C s� | � |�}| jjjdkr(| j�td�� z�| j�| j��� � | jj |j k�� | jj dk�� | jj�� | jj ��d��� }|r�d|_ tt|j��W | j�� S t� �W | j�� n | j�� 0 d S )NZsqlitezBEGIN IMMEDIATE TRANSACTIONFr )rB r7 r0 r: �executer r8 r' Zwith_for_updater9 �queue_id�id�visibleZorder_byZsent_at�limitr; r r rD r= r )r r@ rA �msgr! r! r" �_get� s, � ���� �z Channel._getc C s( | � |�}| j�| j��| jj|jk�S r )rB r7 r8 r' r9 rH rI r? r! r! r" � _query_all� s �zChannel._query_allc C sB | � |�jdd�}z| j�� W n ty< | j�� Y n0 |S )NF)Zsynchronize_session)rN �deleter7 r= r r> )r r@ �countr! r! r" �_purge� s zChannel._purgec C s | � |��� S r )rN rP )r r@ r! r! r" �_size� s z Channel._sizec C sf |t vr^t�B |t v r,t | W d � S tt|�|tf|�W d � S 1 sT0 Y t | S r )r r2 �type�strr )r r: �base�nsr! r! r" �_declarative_cls� s 2zChannel._declarative_clsc C s | � dtd| ji�S )Nr � __tablename__)rW � QueueBaser# �r r! r! r" r& � s �zChannel.queue_clsc C s | � dtd| ji�S )Nr rX )rW � MessageBaser$ rZ r! r! r" r' � s �zChannel.message_cls)�__name__� __module__� __qualname__�__doc__r5 r1 r r r/ r4 �propertyr7 rB rC rF rM rN rQ rR rW r r& r' � __classcell__r! r! r r" r V s* r c @ s2 e Zd ZdZeZdZdZdZdZe fZ dd� Z dS ) � TransportzThe transport class.Tr �sql� sqlalchemyc C s dd l }|jS )Nr )rd � __version__)r rd r! r! r" �driver_version� s zTransport.driver_versionN) r\ r] r^ r_ r Z can_parse_url� default_portZ driver_typeZ driver_namer Zconnection_errorsrf r! r! r! r" rb � s rb )'r_ � __future__r � threading�jsonr r r@ r rd r r Zsqlalchemy.excr Zsqlalchemy.ormr Zkombu.transportr Z kombu.utilsr Zkombu.utils.encodingr �modelsr r[ r r rY r r �VERSION�join�maprT re �RLockr2 r rb r! r! r! r" �<module> s( 5
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка