🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 16:42:50 | PHP 8.2.32
📂
/ (Root)
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
influxdb_client
/
client
/
__pycache__
📍 /opt/alt/python38/lib/python3.8/site-packages/influxdb_client/client/__pycache__
🔄 Refresh
✏️
Editing: logging_handler.cpython-38.pyc
Read Only
U v�i� � @ s. d Z ddlZddlmZ G dd� dej�ZdS )z3Use the influxdb_client with python native logging.� N)�InfluxDBClientc s� e Zd ZdZee�i �j�� �dg Z ddd�� fdd� Z dd� Z dd �� fd d � Z ej dd �d d�Zej ed �dd�Z� ZS )�InfluxLoggingHandlerz� InfluxLoggingHandler instances dispatch logging events to influx. There is no need to set a Formatter. The raw input will be passed on to the influx write api. �messageN)� client_args�write_api_argsc s\ t � �� || _|dkr i n|}tf |||d�|��| _|dkrDi n|}| jjf |�| _dS )z� Initialize defaults. The arguments `client_args` and `write_api_args` can be dicts of kwargs. They are passed on to the InfluxDBClient and write_api calls respectively. N)�url�token�org)�super�__init__�bucketr �client� write_api)�selfr r r r r r �� __class__� �W/opt/alt/python38/lib/python3.8/site-packages/influxdb_client/client/logging_handler.pyr s z InfluxLoggingHandler.__init__c C s | � � dS )z#Make sure all resources are closed.N)�close�r r r r �__del__" s z InfluxLoggingHandler.__del__)�returnc s" | j �� | j�� t� �� dS )z'Close the write_api, client and logger.N)r r r r r r r r r & s zInfluxLoggingHandler.close)�recordr c C sj z,| � |�}| �|�}| jjf d|i|��W S ttfk rF � Y n tfk rd | �|� Y nX dS )z(Emit a record via the influxDB WriteApi.r N)�format�_get_extra_valuesr �write�KeyboardInterrupt� SystemExit� Exception� handleError)r r r �extrar r r �emit, s zInfluxLoggingHandler.emitc s, d� j i}|�� fdd�|j�� D �� |S )z� Extract all items from the record that were injected via extra. Example: `logging.debug(msg, extra={key: value, ...})`. r c s i | ]\}}|� j kr||�qS r )�DEFAULT_LOG_RECORD_KEYS)�.0�key�valuer r r � <dictcomp>> s � z:InfluxLoggingHandler._get_extra_values.<locals>.<dictcomp>)r �update�__dict__�items)r r r r r r r 7 s z&InfluxLoggingHandler._get_extra_values)�__name__� __module__� __qualname__�__doc__�list�logging� makeLogRecordr( �keysr" r r r � LogRecordr! �dictr � __classcell__r r r r r s r )r- r/ Zinfluxdb_clientr �Handlerr r r r r �<module> s
💾 Save Changes
❌ Cancel