o
    EDiH                     @   sF   d dl Z d dlZddlmZ ddlmZ eeZdd Z	dd Z
dS )	    N   )errors)CompressionMethodBytec                 C   sH   zt d|  t}|jW S  ty#   tjd| dd td	| w )N.zUnable to import module %sT)exc_infoz Unknown compression method: '{}')
	importlibimport_module__name__
CompressorImportErrorloggerwarningr   UnknownCompressionMethodformat)algmodule r   _/var/www/Datamplify/venv/lib/python3.10/site-packages/clickhouse_driver/compression/__init__.pyget_compressor_cls
   s   r   c                 C   s@   | t jkrtdt}|jS | t jkrtdt}|jS t )Nz.lz4z.zstd)	r   LZ4r   r   r	   ZSTDr   r   Decompressor)method_typer   r   r   r   get_decompressor_cls   s   

r   )r   logging r   protocolr   	getLoggerr	   r   r   r   r   r   r   r   <module>   s    
