Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/kombu/__pycache__/serialization.cpython-39.pyc
Ðазад
a o�hV< � @ s� d Z ddlmZ ddlZddlZddlZddlZddlmZ ddl m Z ddl m Z ddl mZmZmZmZmZ dd lmZ dd lmZmZ d Zed d g�Zeddg�Zej � d�r�dd� Z nej Z ej Z!e"ej#�$dd��Z%edd�Z&e e'feffdd��Z(e!fdd�Z)dd � Z*G d d � d �Z+e+� Z,e,j-Z-e,j.Z.e,j/Z/e,j0Z0d d � Z1d!d"� Z2d#d$� Z3d%d&� Z4d'd(� Z5d)d*� Z6e2� e5� e3� e6� e,�7d+� e8� Z9e9fd,d-�Z:e9fd.d/�Z;e;� ed0�D ] \Z<Z=e/e<j>ge=�R � �q�d3d1d2�Z?dS )4zSerialization utilities.� )� annotationsN)� namedtuple)�contextmanager��BytesIO� )�ContentDisallowed� DecodeError� EncodeError�SerializerNotInstalled�reraise)� entrypoints)� bytes_to_str� str_to_bytes)�pickle�loads�dumps�register� unregister�binaryz ascii-8bit�application/datazapplication/text�javac C s t �|�| �d S )Nr )�codecs� getdecoder)�tZcoding� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/kombu/serialization.py�_decode s r ZPICKLE_PROTOCOL� �codec)� content_type�content_encoding�encoderc c s^ z d V W nN |y � Y n< |yX } z$t | | |�t�� d � W Y d }~n d }~0 0 d S )N� )r �sys�exc_info)�wrapper�include�exclude�excr r r �_reraise_errors% s r* c C s |t | ��S �Nr )�s�loadr r r � pickle_loads0 s r. c C s | r| � d|� d�S |S )Nz (�)r )�first�secondr r r �parenthesize_alias5 s r2 c @ sd e Zd ZdZdd� Zddd�Zdd� Zd d � Zd d � Zd d� Z ddd�Z dde fdd�Z dd� Z dS )�SerializerRegistryz2The registry keeps track of serialization methods.c C s6 i | _ i | _d | _d | _d | _t� | _i | _i | _d S r+ ) � _encoders� _decoders�_default_encode�_default_content_type�_default_content_encoding�set�_disabled_content_types� type_to_name� name_to_type)�selfr r r �__init__< s zSerializerRegistry.__init__�utf-8c C s< |rt |||�| j|< |r$|| j|< || j|< || j|< dS )a� Register a new encoder/decoder. Arguments: --------- name (str): A convenience name for the serialization method. encoder (callable): A method that will be passed a python data structure and should return a string representing the serialized data. If :const:`None`, then only a decoder will be registered. Encoding will not be possible. decoder (Callable): A method that will be passed a string representing serialized data and should return a python data structure. If :const:`None`, then only an encoder will be registered. Decoding will not be possible. content_type (str): The mime-type describing the serialized structure. content_encoding (str): The content encoding (character set) that the `decoder` method will be returning. Will usually be `utf-8`, `us-ascii`, or `binary`. N)r r4 r5 r; r< )r= �namer" �decoderr r! r r r r F s � zSerializerRegistry.registerc C s" d|vr| j | }| j�|� d S �N�/)r< r: �discard�r= r@ r r r �enableh s zSerializerRegistry.enablec C s" d|vr| j | }| j�|� d S rB )r< r: �addrE r r r �disablem s zSerializerRegistry.disablec C sl zF| j | }| j�|d� | j�|d� | j�|d� | j �|d� W n tyf td|� ���Y n0 dS )a Unregister registered encoder/decoder. Arguments: --------- name (str): Registered serialization method name. Raises ------ SerializerNotInstalled: If a serializer by that name cannot be found. N�!No encoder/decoder installed for )r< r5 �popr4 r; �KeyErrorr )r= r@ r r r r r r s �z SerializerRegistry.unregisterc C s@ z| j | \| _| _| _W n ty: td|� ���Y n0 dS )a� Set the default serialization method used by this library. Arguments: --------- name (str): The name of the registered serialization method. For example, `json` (default), `pickle`, `yaml`, `msgpack`, or any custom methods registered using :meth:`register`. Raises ------ SerializerNotInstalled: If the serialization method requested is not available. �No encoder installed for N)r4 r7 r8 r6 rK r rE r r r �_set_default_serializer� s � � �z*SerializerRegistry._set_default_serializerNc C s� |dkrt |�S |r.| j�|�s.td|� ���|sFt|t�rFdd|fS |s�t|t�r�ttdd�� |� d�}W d � n1 s�0 Y d d|fS |r�| j| \}}}n| j }| j }| j }tt�� ||�}W d � n1 s�0 Y |||fS ) a� Encode data. Serialize a data structure into a string suitable for sending as an AMQP message body. Arguments: --------- data (List, Dict, str): The message data to send. serializer (str): An optional string representing the serialization method you want the data marshalled into. (For example, `json`, `raw`, or `pickle`). If :const:`None` (default), then json will be used, unless `data` is a :class:`str` or :class:`unicode` object. In this latter case, no serialization occurs as it would be unnecessary. Note that if `serializer` is specified, then that serialization method will be used even if a :class:`str` or :class:`unicode` object is passed in. Returns ------- Tuple[str, str, str]: A three-item tuple containing the content type (e.g., `application/json`), content encoding, (e.g., `utf-8`) and a string containing the serialized data. Raises ------ SerializerNotInstalled: If the serialization method requested is not available. �rawrL r r r �r( r? Nz text/plain) � raw_encoder4 �getr � isinstance�bytes�strr* r �encoder6 r7 r8 )r= �data� serializer�payloadr r! r" r r r r � s* "� ( � &zSerializerRegistry.dumpsFc C s� |r t |�nd}|dur6||vrP||vrP| �|d��n|| jv rP|sP| �|d��|pVd�� }|� r�| j�|�}|r�tt�� ||�W d � S 1 s�0 Y |tv� r�t |t �� s�tt�� t ||�W d � S 1 s�0 Y |S )a� Decode serialized data. Deserialize a data stream as serialized using `dumps` based on `content_type`. Arguments: --------- data (bytes, buffer, str): The message data to deserialize. content_type (str): The content-type of the data. (e.g., `application/json`). content_encoding (str): The content-encoding of the data. (e.g., `utf-8`, `binary`, or `us-ascii`). accept (Set): List of content-types to accept. Raises ------ ContentDisallowed: If the content-type is not accepted. Returns ------- Any: The unserialized data. r NZ untrusted�disabledr? ) r �_for_untrusted_contentr: �lowerr5 rQ r* r � SKIP_DECODErR rT r )r= rV r r! �accept�forceZ_trusted_content�decoder r r r � s, �� & � (zSerializerRegistry.loadsc C s t d�|t| j�||�|���S )Nz-Refusing to deserialize {} content of type {})r �formatr2 r; rQ )r= �ctype�whyr r r rZ s ��z)SerializerRegistry._for_untrusted_content)r? )N)�__name__� __module__� __qualname__�__doc__r> r rF rH r rM r �TRUSTED_CONTENTr rZ r r r r r3 9 s � " C� 1r3 c C s\ d}| }t |t�rNd}ttdd�� |�|�}W d � qR1 sB0 Y nd}|||fS )zSpecial case serializer.r r? r rO Nr )rR rT r* r rU )rV r rX r! r r r rP ! s *rP c C s( ddl m} tjd| j| jddd� dS )z2Register a encoder/decoder for JSON serialization.r )�jsonrh zapplication/jsonr? �r r! N)Z kombu.utilsrh �registryr r r )�_jsonr r r � register_json. s �rl c C sT z$ddl } tjd| j| jddd� W n* tyN dd� }t�dd|d� Y n0 dS ) z�Register a encoder/decoder for YAML serialization. It is slower than JSON, but allows for more data types to be serialized. Useful if you need to send data such as dates r N�yamlzapplication/x-yamlr? ri c _ s t d��dS )z�Raise SerializerNotInstalled. Used in case a client receives a yaml message, but yaml isn't installed. z9No decoder installed for YAML. Install the PyYAML libraryN�r ��args�kwargsr r r � not_availableE s �z$register_yaml.<locals>.not_available)rm rj r Z safe_dumpZ safe_load� ImportError)rm rr r r r � register_yaml7 s � rt c C s t t| ��S r+ )r. r �r, r r r �unpickleP s rv c C s& t jfdd�} tjd| tddd� dS )zpRegister pickle serializer. The fastest serialization method, but restricts you to python clients. c S s || t d�S )N)�protocol)�pickle_protocol)�objZdumperr r r � pickle_dumpsZ s z%register_pickle.<locals>.pickle_dumpsr z application/x-python-serializer ri N)r r rj r rv )rz r r r �register_pickleT s �r{ c s� d } }zPddl }|jdkrFddl m� m� � fdd�} �fdd�}nd d � }| } }W n& ttfy~ d d � }| } }Y n0 tjd | |ddd� dS )zZRegister msgpack serializer. See Also -------- https://msgpack.org/. Nr )r r ��packb�unpackbc s � | dd�S )NT)� use_bin_typer ru )r} r r �packo s z register_msgpack.<locals>.packc s � | dd�S )NF)rN r ru )r~ r r �unpackr s z register_msgpack.<locals>.unpackc _ s t d��d S )Nz(msgpack requires msgpack-python >= 0.4.0rn ro r r r �version_mismatchu s �z*register_msgpack.<locals>.version_mismatchc _ s t d��d S )NzKNo decoder installed for msgpack. Please install the msgpack-python libraryrn ro r r r rr z s �z'register_msgpack.<locals>.not_available�msgpackzapplication/x-msgpackr ri )r� �versionr} r~ rs � ValueErrorrj r )r� r� r� r� rr r r| r �register_msgpackb s" �r� rh c C sL | t u rg d�n| } | durH| D ]&}zt�|� W q tyD Y q 0 q dS )z�Enable serializers that are considered to be unsafe. Note: ---- Will enable ``pickle``, ``yaml`` and ``msgpack`` by default, but you can also specify a list of serializers (by name or content type) to enable. )r rm r� N)�NOTSETrj rF rK )�choices�choicer r r �enable_insecure_serializers� s r� c C sH | t u rdgn| } tjD ]}t�|� q| durD| D ]}t�|� q4dS )aJ Disable untrusted serializers. Will disable all serializers except ``json`` or you can specify a list of deserializers to allow. Note: ---- Producers will still be able to serialize data in these formats, but consumers will not accept incoming data using the untrusted content types. rh N)r� rj r5 rH rF )�allowedr@ r r r � disable_insecure_serializers� s r� zkombu.serializersc sh � s t jn� � | durdz� fdd�| D �W S tyb } z td|jd � ���W Y d}~n d}~0 0 | S )z�Replace aliases of content_types with full names from registry. Raises ------ SerializerNotInstalled: If the serialization method requested is not available. Nc s h | ]}d |v r|n� | �qS )rC r )�.0�n�r< r r � <setcomp>� � z)prepare_accept_content.<locals>.<setcomp>rI r )rj r< rK r rp )Z content_typesr< �er r� r �prepare_accept_content� s �r� )N)@rf � __future__r r �osr r$ � collectionsr � contextlibr �ior � exceptionsr r r r r Z utils.compatr Zutils.encodingr r �__all__� frozensetr\ rg �platform� startswithr r_ r- Z pickle_load�int�environrQ rx r � Exceptionr* r. r2 r3 rj r r r r rP rl rt rv r{ r� rM �objectr� r� r� �eprp r@ r� r r r r �<module> sd � b %
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка