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

write_api_async.cpython-38.pyc

����ܒi�����������������������@���s����d�Z�ddlZddlmZmZ�ddlmZ�ddlmZm	Z	m
Z
�ddlmZm
Z
�ddlmZmZ�ddlmZ�dd	lmZ�dd
lmZ�e�d�Zer�ddlmZ�G�d
d��de�ZdS�)zKCollect and async write time series data to InfluxDB Cloud or InfluxDB OSS.�����N)�
ensure_future�gather)�defaultdict)�Union�Iterable�
NamedTuple)�Point�WritePrecision)�
_BaseWriteApi�_HAS_DATACLASS)�get_org_query_param)�DEFAULT_WRITE_PRECISION)�
PointSettingsz&influxdb_client.client.write_api_async)�	dataclassc�����������������������s����e�Zd�ZdZe��fedd���fdd�
Zddefeeeee	d�e
e	d�ee	d�ee	d	�e
e	d
�de	d�f�eed�d
d�Z���ZS�)�
WriteApiAsynca���
    Implementation for '/api/v2/write' endpoint.

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()
    N)�point_settings�returnc��������������������s���t���j||d��dS�)z�
        Initialize defaults.

:param influxdb_client: with default settings (organization)
        :param point_settings: settings to store default tags.
        )�influxdb_clientr���N)�super�__init__)�selfr���r�����	__class__���W/opt/alt/python38/lib/python3.8/site-packages/influxdb_client/client/write_api_async.pyr���"���s����zWriteApiAsync.__init__�strr����dict�bytesr���r���)�bucket�org�record�write_precisionr���c��������������
�������s����t�||�jd�}|��|��tt�}|�j|||fddi|���g�}|���D�]2\}}	|�t|�j	j
||d�|	�|dddd����qFt|ddi�I�d	H�}
|
D�]}t
|t�r�|�q�dd
d��|
D��kS�)a���
        Write time-series data into InfluxDB.

:param str bucket: specifies the destination bucket for writes (required)
        :param str, Organization org: specifies the destination organization for writes;
                                      take the ID, Name or Organization.
                                      If not specified the default value from ``InfluxDBClientAsync.org`` is used.
        :param WritePrecision write_precision: specifies the precision for the unix timestamps within
                                               the body line-protocol. The precision specified on a Point has precedes
                                               and is use for write.
        :param record: Point, Line Protocol, Dictionary, NamedTuple, Data Classes, Pandas DataFrame
        :key data_frame_measurement_name: name of measurement for writing Pandas DataFrame - ``DataFrame``
        :key data_frame_tag_columns: list of DataFrame columns which are tags,
                                     rest columns will be fields - ``DataFrame``
        :key data_frame_timestamp_column: name of DataFrame column which contains a timestamp. The column can be defined as a :class:`~str` value
                                          formatted as `2018-10-26`, `2018-10-26 12:00`, `2018-10-26 12:00:00-05:00`
                                          or other formats and types supported by `pandas.to_datetime <https://pandas.pydata.org/pandas-docs/stable/reference/api/pandas.to_datetime.html#pandas.to_datetime>`_ - ``DataFrame``
        :key data_frame_timestamp_timezone: name of the timezone which is used for timestamp column - ``DataFrame``
        :key record_measurement_key: key of record with specified measurement -
                                     ``dictionary``, ``NamedTuple``, ``dataclass``
        :key record_measurement_name: static measurement name - ``dictionary``, ``NamedTuple``, ``dataclass``
        :key record_time_key: key of record with specified timestamp - ``dictionary``, ``NamedTuple``, ``dataclass``
        :key record_tag_keys: list of record keys to use as a tag - ``dictionary``, ``NamedTuple``, ``dataclass``
        :key record_field_keys: list of record keys to use as a field  - ``dictionary``, ``NamedTuple``, ``dataclass``
        :return: ``True`` for successfully accepted data, otherwise raise an exception

Example:
            .. code-block:: python

# Record as Line Protocol
                await write_api.write("my-bucket", "my-org", "h2o_feet,location=us-west level=125i 1")

# Record as Dictionary
                dictionary = {
                    "measurement": "h2o_feet",
                    "tags": {"location": "us-west"},
                    "fields": {"level": 125},
                    "time": 1
                }
                await write_api.write("my-bucket", "my-org", dictionary)

# Record as Point
                from influxdb_client import Point
                point = Point("h2o_feet").tag("location", "us-west").field("level", 125).time(1)
                await write_api.write("my-bucket", "my-org", point)

DataFrame:
            If the ``data_frame_timestamp_column`` is not specified the index of `Pandas DataFrame <https://pandas.pydata.org/pandas-docs/stable/reference/api/pandas.DataFrame.html>`_
            is used as a ``timestamp`` for written data. The index can be `PeriodIndex <https://pandas.pydata.org/pandas-docs/stable/reference/api/pandas.PeriodIndex.html#pandas.PeriodIndex>`_
            or its must be transformable to ``datetime`` by
            `pandas.to_datetime <https://pandas.pydata.org/pandas-docs/stable/reference/api/pandas.to_datetime.html#pandas.to_datetime>`_.

If you would like to transform a column to ``PeriodIndex``, you can use something like:

.. code-block:: python

import pandas as pd

# DataFrame
                data_frame = ...
                # Set column as Index
                data_frame.set_index('column_name', inplace=True)
                # Transform index to PeriodIndex
                data_frame.index = pd.to_datetime(data_frame.index, unit='s')

)r����clientZprecision_from_pointT����
Fztext/plain; charset=utf-8)r���r����body�	precisionZ	async_reqZ_return_http_data_only�content_type�return_exceptionsNc�����������������S���s���g�|�]}|d��dk�qS�)����)����������r���)�.0�rer���r���r����
<listcomp>����s�����z'WriteApiAsync.write.<locals>.<listcomp>)r���Z_influxdb_clientZ_append_default_tagsr����list�
_serialize�items�appendr���Z_write_serviceZpost_write_async�joinr����
isinstance�	Exception)r���r���r���r ���r!����kwargsZpayloads�futuresZpayload_precisionZpayload_line�results�resultr���r���r����write+���s(����G

���
zWriteApiAsync.write)�__name__�
__module__�__qualname__�__doc__r���r���r
���r���r���r���r���r���r���r���r	����boolr9����
__classcell__r���r���r���r���r������s ���	�������r���)r=����logging�asyncior���r����collectionsr����typingr���r���r���r���r���r	���Zinfluxdb_client.client._baser
���r���Z#influxdb_client.client.util.helpersr���Z"influxdb_client.client.write.pointr
���Z influxdb_client.client.write_apir����	getLogger�logger�dataclassesr���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