🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 16:45:22 | 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: query_api.cpython-38.pyc
Read Only
U v�i�< � @ sl d Z ddlmZmZmZmZ ddlmZ ddlm Z ddl m Z m Z m Z G dd� de�ZG dd � d e �Zd S ) u� Querying InfluxDB by FluxLang. Flux is InfluxData’s functional data scripting language designed for querying, analyzing, and acting on data. � )�List� Generator�Any�Callable)�Dialect)� _BaseQueryApi)� FluxRecord� TableList� CSVIteratorc @ s( e Zd ZdZdee edd�dd�ZdS )� QueryOptionszQuery options.N)� profilers�profiler_callback�returnc C s || _ || _dS )z� Initialize query options. :param profilers: list of enabled flux profilers :param profiler_callback: callback function return profilers (FluxRecord) N)r r )�selfr r � r �Q/opt/alt/python38/lib/python3.8/site-packages/influxdb_client/client/query_api.py�__init__ s zQueryOptions.__init__)NN)�__name__� __module__� __qualname__�__doc__r �strr r r r r r r s r c s� e Zd ZdZe� f� fdd� Zdejdfee e e d�dd�Z dejdfee d�d d �Z dee ed �d d �Zdee ededf d �dd�Zdeee e ed�dd�Zd eee e ed�dd�Zdd� Z� ZS ) �QueryApiz,Implementation for '/api/v2/query' endpoint.c s t � j||d� dS )z[ Initialize query client. :param influxdb_client: influxdb client )�influxdb_client� query_optionsN)�superr )r r r �� __class__r r r s zQueryApi.__init__N)�query�dialect�paramsr c C s2 | � |�}| jj|| �|||�ddd�}| �|�S )a" Execute the Flux query and return results as a CSV iterator. Each iteration returns a row of the CSV file. :param query: a Flux query :param str, Organization org: specifies the organization for executing the query; Take the ``ID``, ``Name`` or ``Organization``. If not specified the default value from ``InfluxDBClient.org`` is used. :param dialect: csv dialect format :param params: bind parameters :return: :class:`~Iterator[List[str]]` wrapped into :class:`~influxdb_client.client.flux_table.CSVIterator` :rtype: CSVIterator Serialization the query results to flattened list of values via :func:`~influxdb_client.client.flux_table.CSVIterator.to_values`: .. code-block:: python from influxdb_client import InfluxDBClient with InfluxDBClient(url="http://localhost:8086", token="my-token", org="my-org") as client: # Query: using CSV iterator csv_iterator = client.query_api().query_csv('from(bucket:"my-bucket") |> range(start: -10m)') # Serialize to values output = csv_iterator.to_values() print(output) .. code-block:: python [ ['#datatype', 'string', 'long', 'dateTime:RFC3339', 'dateTime:RFC3339', 'dateTime:RFC3339', 'double', 'string', 'string', 'string'] ['#group', 'false', 'false', 'true', 'true', 'false', 'false', 'true', 'true', 'true'] ['#default', '_result', '', '', '', '', '', '', '', ''] ['', 'result', 'table', '_start', '_stop', '_time', '_value', '_field', '_measurement', 'location'] ['', '', '0', '2022-06-16', '2022-06-16', '2022-06-16', '24.3', 'temperature', 'my_measurement', 'New York'] ['', '', '1', '2022-06-16', '2022-06-16', '2022-06-16', '25.3', 'temperature', 'my_measurement', 'Prague'] ... ] If you would like to turn off `Annotated CSV header's <https://docs.influxdata.com/influxdb/latest/reference/syntax/annotated-csv/>`_ you can use following code: .. code-block:: python from influxdb_client import InfluxDBClient, Dialect with InfluxDBClient(url="http://localhost:8086", token="my-token", org="my-org") as client: # Query: using CSV iterator csv_iterator = client.query_api().query_csv('from(bucket:"my-bucket") |> range(start: -10m)', dialect=Dialect(header=False, annotations=[])) for csv_line in csv_iterator: print(csv_line) .. code-block:: python [ ['', '_result', '0', '2022-06-16', '2022-06-16', '2022-06-16', '24.3', 'temperature', 'my_measurement', 'New York'] ['', '_result', '1', '2022-06-16', '2022-06-16', '2022-06-16', '25.3', 'temperature', 'my_measurement', 'Prague'] ... ] F��orgr � async_req�_preload_content)� _org_param� _query_api� post_query� _create_queryZ_to_csv)r r r" r r �responser r r � query_csv' s @ �zQueryApi.query_csv)r r c C s, | � |�}| jj|| �|||�ddd�}|S )a Execute synchronous Flux query and return result as raw unprocessed result as a str. :param query: a Flux query :param str, Organization org: specifies the organization for executing the query; Take the ``ID``, ``Name`` or ``Organization``. If not specified the default value from ``InfluxDBClient.org`` is used. :param dialect: csv dialect format :param params: bind parameters :return: str Fr! )r% r& r' r( )r r r" r r �resultr r r � query_rawm s �zQueryApi.query_raw)r r r c C s> | � |�}| jj|| �|| j|�dddd�}| j|| �� d�S )a� Execute synchronous Flux query and return result as a :class:`~influxdb_client.client.flux_table.FluxTable` list. :param query: the Flux query :param str, Organization org: specifies the organization for executing the query; Take the ``ID``, ``Name`` or ``Organization``. If not specified the default value from ``InfluxDBClient.org`` is used. :param params: bind parameters :return: :class:`~influxdb_client.client.flux_table.FluxTable` list wrapped into :class:`~influxdb_client.client.flux_table.TableList` :rtype: TableList Serialization the query results to flattened list of values via :func:`~influxdb_client.client.flux_table.TableList.to_values`: .. code-block:: python from influxdb_client import InfluxDBClient with InfluxDBClient(url="http://localhost:8086", token="my-token", org="my-org") as client: # Query: using Table structure tables = client.query_api().query('from(bucket:"my-bucket") |> range(start: -10m)') # Serialize to values output = tables.to_values(columns=['location', '_time', '_value']) print(output) .. code-block:: python [ ['New York', datetime.datetime(2022, 6, 7, 11, 3, 22, 917593, tzinfo=tzutc()), 24.3], ['Prague', datetime.datetime(2022, 6, 7, 11, 3, 22, 917593, tzinfo=tzutc()), 25.3], ... ] Serialization the query results to JSON via :func:`~influxdb_client.client.flux_table.TableList.to_json`: .. code-block:: python from influxdb_client import InfluxDBClient with InfluxDBClient(url="http://localhost:8086", token="my-token", org="my-org") as client: # Query: using Table structure tables = client.query_api().query('from(bucket:"my-bucket") |> range(start: -10m)') # Serialize to JSON output = tables.to_json(indent=5) print(output) .. code-block:: javascript [ { "_measurement": "mem", "_start": "2021-06-23T06:50:11.897825+00:00", "_stop": "2021-06-25T06:50:11.897825+00:00", "_time": "2020-02-27T16:20:00.897825+00:00", "region": "north", "_field": "usage", "_value": 15 }, { "_measurement": "mem", "_start": "2021-06-23T06:50:11.897825+00:00", "_stop": "2021-06-25T06:50:11.897825+00:00", "_time": "2020-02-27T16:20:01.897825+00:00", "region": "west", "_field": "usage", "_value": 10 }, ... ] F�r" r r# r$ Z_return_http_data_only�r )r% r& r' r( �default_dialectZ _to_tables�_get_query_options�r r r" r r) r r r r s J �zQueryApi.queryr c C s> | � |�}| jj|| �|| j|�dddd�}| j|| �� d�S )a Execute synchronous Flux query and return stream of FluxRecord as a Generator['FluxRecord']. :param query: the Flux query :param str, Organization org: specifies the organization for executing the query; Take the ``ID``, ``Name`` or ``Organization``. If not specified the default value from ``InfluxDBClient.org`` is used. :param params: bind parameters :return: Generator['FluxRecord'] Fr- r. )r% r& r' r( r/ Z_to_flux_record_streamr0 r1 r r r � query_stream� s �zQueryApi.query_streamF)r �data_frame_indexr �use_extension_dtypesc C s | j |||||d�}| �|�S )a� Execute synchronous Flux query and return Pandas DataFrame. .. note:: If the ``query`` returns tables with differing schemas than the client generates a :class:`~DataFrame` for each of them. :param query: the Flux query :param str, Organization org: specifies the organization for executing the query; Take the ``ID``, ``Name`` or ``Organization``. If not specified the default value from ``InfluxDBClient.org`` is used. :param data_frame_index: the list of columns that are used as DataFrame index :param params: bind parameters :param use_extension_dtypes: set to ``True`` to use panda's extension data types. Useful for queries with ``pivot`` function. When data has missing values, column data type may change (to ``object`` or ``float64``). Nullable extension types (``Int64``, ``Float64``, ``boolean``) support ``panda.NA`` value. For more info, see https://pandas.pydata.org/docs/user_guide/missing_data.html. :return: :class:`~DataFrame` or :class:`~List[DataFrame]` .. warning:: For the optimal processing of the query results use the ``pivot() function`` which align results as a table. .. code-block:: text from(bucket:"my-bucket") |> range(start: -5m, stop: now()) |> filter(fn: (r) => r._measurement == "mem") |> pivot(rowKey:["_time"], columnKey: ["_field"], valueColumn: "_value") For more info see: - https://docs.influxdata.com/resources/videos/pivots-in-flux/ - https://docs.influxdata.com/flux/latest/stdlib/universe/pivot/ - https://docs.influxdata.com/flux/latest/stdlib/influxdata/influxdb/schema/fieldsascols/ )r" r3 r r4 )�query_data_frame_streamZ_to_data_frames)r r r" r3 r r4 Z _generatorr r r �query_data_frame� s " �zQueryApi.query_data_framec C sF | � |�}| jj|| j|| j|dd�dddd�}| j||| �� |d�S )a� Execute synchronous Flux query and return stream of Pandas DataFrame as a :class:`~Generator[DataFrame]`. .. note:: If the ``query`` returns tables with differing schemas than the client generates a :class:`~DataFrame` for each of them. :param query: the Flux query :param str, Organization org: specifies the organization for executing the query; Take the ``ID``, ``Name`` or ``Organization``. If not specified the default value from ``InfluxDBClient.org`` is used. :param data_frame_index: the list of columns that are used as DataFrame index :param params: bind parameters :param use_extension_dtypes: set to ``True`` to use panda's extension data types. Useful for queries with ``pivot`` function. When data has missing values, column data type may change (to ``object`` or ``float64``). Nullable extension types (``Int64``, ``Float64``, ``boolean``) support ``panda.NA`` value. For more info, see https://pandas.pydata.org/docs/user_guide/missing_data.html. :return: :class:`~Generator[DataFrame]` .. warning:: For the optimal processing of the query results use the ``pivot() function`` which align results as a table. .. code-block:: text from(bucket:"my-bucket") |> range(start: -5m, stop: now()) |> filter(fn: (r) => r._measurement == "mem") |> pivot(rowKey:["_time"], columnKey: ["_field"], valueColumn: "_value") For more info see: - https://docs.influxdata.com/resources/videos/pivots-in-flux/ - https://docs.influxdata.com/flux/latest/stdlib/universe/pivot/ - https://docs.influxdata.com/flux/latest/stdlib/influxdata/influxdb/schema/fieldsascols/ T)Zdataframe_queryFr- )r3 r) r r4 )r% r& r' r( r/ Z_to_data_frame_streamr0 )r r r" r3 r r4 r) r r r r5 s " � ��z QueryApi.query_data_frame_streamc C s dS )zClose QueryAPI.Nr )r r r r �__del__4 s zQueryApi.__del__)NN)NN)NNNF)NNNF)r r r r r r r r/ r r �dictr r* r, r r r r r2 r �boolr6 r5 r7 � __classcell__r r r r r s& � FQ � � & � � -r N)r �typingr r r r r r Z influxdb_client.client._baser Z!influxdb_client.client.flux_tabler r r �objectr r r r r r �<module> s
💾 Save Changes
❌ Cancel