byp4a55 professor6T9

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

influxdb_client_async.cpython-38.pyc

����ܒi94����������������������@���s����d�Z�ddlZddlZddlmZ�ddlmZ�ddlmZ�ddl	m
Z
�ddlmZ�ddl
mZ�dd	lmZ�e�d
�ZG�dd��de�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�dd�Zd
d��Ze	d#ed�dd��Z
e	d$dd��Zed�dd�Z
ed�dd�Zed�dd�Ze��feed�dd�Ze��fed�dd�Zed�d d!�Z���ZS�)%�InfluxDBClientAsyncz.InfluxDBClientAsync is client for InfluxDB v2.N�'��F)�token�org�returnc�����������
���
������s����t���jf�||||||dd�|���tjdd��dkrBddlm}�nddlm}�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,����'����zInfluxDBClientAsync.__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����zInfluxDBClientAsync.__aenter__c���������������������s���|�����I�dH��dS��zShutdown the client.N)�close)r)����exc_type�exc�tbr.���r.���r/����	__aexit__[���s����zInfluxDBClientAsync.__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����zInfluxDBClientAsync.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����zInfluxDBClientAsync.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����zInfluxDBClientAsync.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���Zinfluxdb_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���

Name	Type	Size	Owner/Group	Permission	Last Modified	Actions
.	dir	-	root/root	0755	2026-02-16 08:57:59
..	dir	-	root/root	0755	2026-02-16 08:57:59
__init__.cpython-38.pyc	text/x-bytecode.python	3.77 KB	root/root	0644	2026-02-16 08:57:59
_base.cpython-38.pyc	text/x-bytecode.python	18.41 KB	root/root	0644	2026-02-16 08:57:59
_pages.cpython-38.pyc	text/x-bytecode.python	2.76 KB	root/root	0644	2026-02-16 08:57:59
authorizations_api.cpython-38.pyc	text/x-bytecode.python	5.12 KB	root/root	0644	2026-02-16 08:57:59
bucket_api.cpython-38.pyc	text/x-bytecode.python	4.98 KB	root/root	0644	2026-02-16 08:57:59
delete_api.cpython-38.pyc	text/x-bytecode.python	1.93 KB	root/root	0644	2026-02-16 08:57:59
delete_api_async.cpython-38.pyc	text/x-bytecode.python	2.11 KB	root/root	0644	2026-02-16 08:57:59
exceptions.cpython-38.pyc	text/x-bytecode.python	1.53 KB	root/root	0644	2026-02-16 08:57:59
flux_csv_parser.cpython-38.pyc	text/x-bytecode.python	12.51 KB	root/root	0644	2026-02-16 08:57:59
flux_table.cpython-38.pyc	text/x-bytecode.python	11.74 KB	root/root	0644	2026-02-16 08:57:59
influxdb_client.cpython-38.pyc	text/x-bytecode.python	18.7 KB	root/root	0644	2026-02-16 08:57:59
influxdb_client_async.cpython-38.pyc	text/x-bytecode.python	13.45 KB	root/root	0644	2026-02-16 08:57:59
invokable_scripts_api.cpython-38.pyc	text/x-bytecode.python	12.59 KB	root/root	0644	2026-02-16 08:57:59
labels_api.cpython-38.pyc	text/x-bytecode.python	3.45 KB	root/root	0644	2026-02-16 08:57:59
logging_handler.cpython-38.pyc	text/x-bytecode.python	2.74 KB	root/root	0644	2026-02-16 08:57:59
organizations_api.cpython-38.pyc	text/x-bytecode.python	2.84 KB	root/root	0644	2026-02-16 08:57:59
query_api.cpython-38.pyc	text/x-bytecode.python	14.77 KB	root/root	0644	2026-02-16 08:57:59
query_api_async.cpython-38.pyc	text/x-bytecode.python	11.66 KB	root/root	0644	2026-02-16 08:57:59
tasks_api.cpython-38.pyc	text/x-bytecode.python	9.85 KB	root/root	0644	2026-02-16 08:57:59
users_api.cpython-38.pyc	text/x-bytecode.python	3.16 KB	root/root	0644	2026-02-16 08:57:59
warnings.cpython-38.pyc	text/x-bytecode.python	2.22 KB	root/root	0644	2026-02-16 08:57:59
write_api.cpython-38.pyc	text/x-bytecode.python	22.78 KB	root/root	0644	2026-02-16 08:57:59
write_api_async.cpython-38.pyc	text/x-bytecode.python	7.2 KB	root/root	0644	2026-02-16 08:57:59

Team Anon Force

https://t.me/Professor6T9x