🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 15:55:41 | 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: influxdb_client_async.cpython-38.pyc
Read Only
U v�i94 � @ s� d Z ddlZddlZddlmZ ddlmZ ddlmZ ddl m Z ddl m Z ddl mZ dd lmZ e�d �ZG d d � d e�ZdS ) zuInfluxDBClientAsync is client for API defined in https://github.com/influxdata/openapi/blob/master/contracts/oss.yml.� N)� PingService)� _BaseClient��DeleteApiAsync)� QueryOptions�� QueryApiAsync)� PointSettings�� WriteApiAsyncz,influxdb_client.client.influxdb_client_asyncc s� e Zd ZdZd"eedd�� fdd� Zd d�d d �Zdd�d d �Zd d� Ze d#ed�dd��Z e d$dd��Z e d�dd�Z ed�dd�Zed�dd�Ze� feed�d d �Ze� fed�d d �Zed�d d!�Z� ZS )%�InfluxDBClientAsyncz.InfluxDBClientAsync is client for InfluxDB v2.N�' F)�token�org�returnc s� t � jf ||||||dd�|�� tjdd� dkrBddlm} n ddlm} z|� } | dkrftd ��W n0 tk r� dd lm } d } | d| d ��Y nX dd l m } | f | j | j | jd�|��| _dS )ap Initialize defaults. :param url: InfluxDB server API url (ex. http://localhost:8086). :param token: ``token`` to authenticate to the InfluxDB 2.x :param org: organization name (used as a default in Query, Write and Delete API) :param debug: enable verbose logging of http requests :param timeout: The maximal number of milliseconds for the whole HTTP request including connection establishment, request sending and response reading. It can also be a :class:`~aiohttp.ClientTimeout` which is directly pass to ``aiohttp``. :param enable_gzip: Enable Gzip compression for http requests. Currently, only the "Write" and "Query" endpoints supports the Gzip compression. :key bool verify_ssl: Set this to false to skip verifying SSL certificate when calling API from https server. :key str ssl_ca_cert: Set this to customize the certificate file to verify the peer. :key str cert_file: Path to the certificate that will be used for mTLS authentication. :key str cert_key_file: Path to the file contains private key for mTLS certificate. :key str cert_key_password: String or function which returns password for decrypting the mTLS private key. :key ssl.SSLContext ssl_context: Specify a custom Python SSL Context for the TLS/ mTLS handshake. Be aware that only delivered certificate/ key files or an SSL Context are possible. :key str proxy: Set this to configure the http proxy to be used (ex. http://localhost:3128) :key str proxy_headers: A dictionary containing headers that will be sent to the proxy. Could be used for proxy authentication. :key int connection_pool_maxsize: The total number of simultaneous connections. Defaults to "multiprocessing.cpu_count() * 5". :key bool auth_basic: Set this to true to enable basic authentication when talking to a InfluxDB 1.8.x that does not use auth-enabled but is protected by a reverse proxy with basic authentication. (defaults to false, don't set to true when talking to InfluxDB 2) :key str username: ``username`` to authenticate via username and password credentials to the InfluxDB 2.x :key str password: ``password`` to authenticate via username and password credentials to the InfluxDB 2.x :key bool allow_redirects: If set to ``False``, do not follow HTTP redirects. ``True`` by default. :key int max_redirects: Maximum number of HTTP redirects to follow. ``10`` by default. :key dict client_session_kwargs: Additional configuration arguments for :class:`~aiohttp.ClientSession` :key type client_session_type: Type of aiohttp client to use. Useful for third party wrappers like ``aiohttp-retry``. :class:`~aiohttp.ClientSession` by default. :key list[str] profilers: list of enabled Flux profilers zaiohttp.client)�urlr r �debug�timeout� enable_gzipZhttp_client_loggerN� )� � r )�get_running_loop)�_get_running_loopzno running event loop)� InfluxDBErrorzjThe async client should be initialised inside async coroutine otherwise there can be unexpected behaviour.)�response�message)�ApiClientAsync)� configuration� header_name� header_value)�super�__init__�sys� version_info�asyncior r � RuntimeErrorZ!influxdb_client.client.exceptionsr Z_async.api_clientr �confZauth_header_nameZauth_header_value� api_client) �selfr r r r r r �kwargsr �loopr r r �� __class__� �]/opt/alt/python38/lib/python3.8/site-packages/influxdb_client/client/influxdb_client_async.pyr" s, '�� ��z InfluxDBClientAsync.__init__)r c � s | S )zb Enter the runtime context related to this object. return: self instance r. �r) r. r. r/ � __aenter__S s z InfluxDBClientAsync.__aenter__c � s | � � I dH dS �zShutdown the client.N)�close)r) �exc_type�exc�tbr. r. r/ � __aexit__[ s z InfluxDBClientAsync.__aexit__c � s | j r | j �� I dH d| _ dS r2 )r( r3 r0 r. r. r/ r3 _ s zInfluxDBClientAsync.close� config.ini)� config_filec K s t jf |||d�|��S )a� Configure client via configuration file. The configuration has to be under 'influx' section. :param config_file: Path to configuration file :param debug: Enable verbose logging of http requests :param enable_gzip: Enable Gzip compression for http requests. Currently, only the "Write" and "Query" endpoints supports the Gzip compression. :key config_name: Name of the configuration section of the configuration file :key str proxy_headers: A dictionary containing headers that will be sent to the proxy. Could be used for proxy authentication. :key urllib3.util.retry.Retry retries: Set the default retry strategy that is used for all HTTP requests except batching writes. As a default there is no one retry strategy. :key ssl.SSLContext ssl_context: Specify a custom Python SSL Context for the TLS/ mTLS handshake. Be aware that only delivered certificate/ key files or an SSL Context are possible. The supported formats: - https://docs.python.org/3/library/configparser.html - https://toml.io/en/ - https://www.json.org/json-en.html Configuration options: - url - org - token - timeout, - verify_ssl - ssl_ca_cert - cert_file - cert_key_file - cert_key_password - connection_pool_maxsize - auth_basic - profilers - proxy config.ini example:: [influx2] url=http://localhost:8086 org=my-org token=my-token timeout=6000 connection_pool_maxsize=25 auth_basic=false profilers=query,operator proxy=http:proxy.domain.org:8080 [tags] id = 132-987-655 customer = California Miner data_center = ${env.data_center} config.toml example:: [influx2] url = "http://localhost:8086" token = "my-token" org = "my-org" timeout = 6000 connection_pool_maxsize = 25 auth_basic = false profilers="query, operator" proxy = "http://proxy.domain.org:8080" [tags] id = "132-987-655" customer = "California Miner" data_center = "${env.data_center}" config.json example:: { "url": "http://localhost:8086", "token": "my-token", "org": "my-org", "active": true, "timeout": 6000, "connection_pool_maxsize": 55, "auth_basic": false, "profilers": "query, operator", "tags": { "id": "132-987-655", "customer": "California Miner", "data_center": "${env.data_center}" } } )r9 r r )r Z_from_config_file)�clsr9 r r r* r. r. r/ �from_config_filee s \ ��z$InfluxDBClientAsync.from_config_filec K s t jf ||d�|��S )a8 Configure client via environment properties. :param debug: Enable verbose logging of http requests :param enable_gzip: Enable Gzip compression for http requests. Currently, only the "Write" and "Query" endpoints supports the Gzip compression. :key str proxy: Set this to configure the http proxy to be used (ex. http://localhost:3128) :key str proxy_headers: A dictionary containing headers that will be sent to the proxy. Could be used for proxy authentication. :key urllib3.util.retry.Retry retries: Set the default retry strategy that is used for all HTTP requests except batching writes. As a default there is no one retry strategy. :key ssl.SSLContext ssl_context: Specify a custom Python SSL Context for the TLS/ mTLS handshake. Be aware that only delivered certificate/ key files or an SSL Context are possible. Supported environment properties: - INFLUXDB_V2_URL - INFLUXDB_V2_ORG - INFLUXDB_V2_TOKEN - INFLUXDB_V2_TIMEOUT - INFLUXDB_V2_VERIFY_SSL - INFLUXDB_V2_SSL_CA_CERT - INFLUXDB_V2_CERT_FILE - INFLUXDB_V2_CERT_KEY_FILE - INFLUXDB_V2_CERT_KEY_PASSWORD - INFLUXDB_V2_CONNECTION_POOL_MAXSIZE - INFLUXDB_V2_AUTH_BASIC - INFLUXDB_V2_PROFILERS - INFLUXDB_V2_TAG )r r )r Z_from_env_properties)r: r r r* r. r. r/ �from_env_properties� s !z'InfluxDBClientAsync.from_env_propertiesc � sV t | j�}z|�� I dH W dS tk rP } zt�d|� |�W 5 d}~X Y nX dS )zc Return the status of InfluxDB instance. :return: The status of InfluxDB. NTz!Unexpected error during /ping: %s)r r( �get_ping_async� Exception�loggerr )r) � ping_service�exr. r. r/ �ping� s zInfluxDBClientAsync.pingc � s& t | j�}|jdd�I dH }|�|�S )zq Return the version of the connected InfluxDB Server. :return: The version of InfluxDB. F)Z_return_http_data_onlyN)r r( r= Zresponse_header)r) r@ r r. r. r/ �version� s zInfluxDBClientAsync.versionc � s t | j�}|�� I dH S )zw Return the build type of the connected InfluxDB Server. :return: The type of InfluxDB build. N)r r( Zbuild_type_async)r) r@ r. r. r/ �build s zInfluxDBClientAsync.build)� query_optionsr c C s t | |�S )z� Create an asynchronous Query API instance. :param query_options: optional query api configuration :return: Query api instance r )r) rE r. r. r/ � query_api s z InfluxDBClientAsync.query_apic C s t | |d�S )a Create an asynchronous Write API instance. Example: .. code-block:: python from influxdb_client_async import InfluxDBClientAsync # Initialize async/await instance of Write API async with InfluxDBClientAsync(url="http://localhost:8086", token="my-token", org="my-org") as client: write_api = client.write_api() :param point_settings: settings to store default tags :return: write api instance )�influxdb_client�point_settingsr )r) rH r. r. r/ � write_api s z InfluxDBClientAsync.write_apic C s t | �S )z` Get the asynchronous delete metrics API instance. :return: delete api r r0 r. r. r/ � delete_api' s z InfluxDBClientAsync.delete_api)NNNr F)r8 NF)NF)�__name__� __module__� __qualname__�__doc__�strr" r1 r7 r3 � classmethodr; r< �boolrB rC rD r r rF r r rI r rJ � __classcell__r. r. r, r/ r s" �@^ " r )rN �loggingr# rG r Z influxdb_client.client._baser Z'influxdb_client.client.delete_api_asyncr Z influxdb_client.client.query_apir Z&influxdb_client.client.query_api_asyncr Z influxdb_client.client.write_apir Z&influxdb_client.client.write_api_asyncr � getLoggerr? r r. r. r. r/ �<module> s
💾 Save Changes
❌ Cancel