🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 04:47:45 | PHP 8.2.32
📂
/ (Root)
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
influxdb_client
/
service
/
__pycache__
📍 /opt/alt/python38/lib/python3.8/site-packages/influxdb_client/service/__pycache__
🔄 Refresh
✏️
Editing: query_service.cpython-38.pyc
Read Only
U w�i � � @ s8 d Z ddlmZ ddlZddlmZ G dd� de�ZdS )a InfluxDB OSS API Service. The InfluxDB v2 API provides a programmatic interface for all interactions with InfluxDB. Access the InfluxDB API using the `/api/v2/` endpoint. # noqa: E501 OpenAPI spec version: 2.0.0 Generated by: https://openapi-generator.tech � )�absolute_importN)� _BaseServicec s� e Zd ZdZd-� fdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dd� Z dd� Z dd� Z dd� Z dd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� Zd'd(� Zd)d*� Zd+d,� Z� ZS ).� QueryServicez�NOTE: This class is auto generated by OpenAPI Generator. Ref: https://openapi-generator.tech Do not edit the class manually. Nc s t � �|� dS )z.QueryService - a operation defined in OpenAPI.N)�super�__init__)�self� api_client�� __class__� �V/opt/alt/python38/lib/python3.8/site-packages/influxdb_client/service/query_service.pyr s zQueryService.__init__c K s2 d|d< |� d�r | jf |�S | jf |�}|S dS )a List Flux query suggestions. Lists Flux query suggestions. Each suggestion contains a [Flux function](https://docs.influxdata.com/flux/v0.x/stdlib/all-functions/) name and parameters. Use this endpoint to retrieve a list of Flux query suggestions used in the InfluxDB Flux Query Builder. #### Limitations - When writing a query, avoid using `_functionName()` helper functions exposed by this endpoint. Helper function names have an underscore (`_`) prefix and aren't meant to be used directly in queries--for example: - To sort on a column and keep the top n records, use the `top(n, columns=["_value"], tables=<-)` function instead of the `_sortLimit` helper function. `top` uses `_sortLimit`. #### Related Guides - [List of all Flux functions](https://docs.influxdata.com/flux/v0.x/stdlib/all-functions/) This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_query_suggestions(async_req=True) >>> result = thread.get() :param async_req bool :param str zap_trace_span: OpenTracing span context :return: FluxSuggestions If the method is called asynchronously, returns the request thread. T�_return_http_data_only� async_reqN)�get�$get_query_suggestions_with_http_info�r �kwargs�datar r r �get_query_suggestions s z"QueryService.get_query_suggestionsc K sd | j f |�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �S ) a% List Flux query suggestions. Lists Flux query suggestions. Each suggestion contains a [Flux function](https://docs.influxdata.com/flux/v0.x/stdlib/all-functions/) name and parameters. Use this endpoint to retrieve a list of Flux query suggestions used in the InfluxDB Flux Query Builder. #### Limitations - When writing a query, avoid using `_functionName()` helper functions exposed by this endpoint. Helper function names have an underscore (`_`) prefix and aren't meant to be used directly in queries--for example: - To sort on a column and keep the top n records, use the `top(n, columns=["_value"], tables=<-)` function instead of the `_sortLimit` helper function. `top` uses `_sortLimit`. #### Related Guides - [List of all Flux functions](https://docs.influxdata.com/flux/v0.x/stdlib/all-functions/) This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_query_suggestions_with_http_info(async_req=True) >>> result = thread.get() :param async_req bool :param str zap_trace_span: OpenTracing span context :return: FluxSuggestions If the method is called asynchronously, returns the request thread. �/api/v2/query/suggestions�GET�FluxSuggestionsr r �_preload_contentT�_request_timeout� urlopen_kwN� �bodyZ post_params�filesZ response_typeZ auth_settingsr r r r Zcollection_formatsr �� _get_query_suggestions_preparer �call_apir �r r �local_var_params� path_params� query_params� header_params� body_paramsr r r r 6 s( � �z1QueryService.get_query_suggestions_with_http_infoc � sj | j f |�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �I d H S ) ac List Flux query suggestions. Lists Flux query suggestions. Each suggestion contains a [Flux function](https://docs.influxdata.com/flux/v0.x/stdlib/all-functions/) name and parameters. Use this endpoint to retrieve a list of Flux query suggestions used in the InfluxDB Flux Query Builder. #### Limitations - When writing a query, avoid using `_functionName()` helper functions exposed by this endpoint. Helper function names have an underscore (`_`) prefix and aren't meant to be used directly in queries--for example: - To sort on a column and keep the top n records, use the `top(n, columns=["_value"], tables=<-)` function instead of the `_sortLimit` helper function. `top` uses `_sortLimit`. #### Related Guides - [List of all Flux functions](https://docs.influxdata.com/flux/v0.x/stdlib/all-functions/) This method makes an asynchronous HTTP request. :param async_req bool :param str zap_trace_span: OpenTracing span context :return: FluxSuggestions If the method is called asynchronously, returns the request thread. r r r r r r Tr r Nr r r! r r r �get_query_suggestions_asyncY s( � �z(QueryService.get_query_suggestions_asyncc K s` t � }dg}| �d||� i }g }i }d|kr:|d |d< d }| j�ddg�|d< |||||fS )N�zap_trace_spanr �Zap-Trace-Span�application/jsonz text/html�Accept)�locals�_check_operation_paramsr �select_header_accept�r r r" � all_paramsr# r$ r% r& r r r r y s �z+QueryService._get_query_suggestions_preparec K s6 d|d< |� d�r | j|f|�S | j|f|�}|S dS )a� Retrieve a query suggestion for a branching suggestion. Retrieves a query suggestion that contains the name and parameters of the requested function. Use this endpoint to pass a branching suggestion (a Flux function name) and retrieve the parameters of the requested function. #### Limitations - Use `/api/v2/query/suggestions/{name}` (without a trailing slash). `/api/v2/query/suggestions/{name}/` (note the trailing slash) results in a HTTP `301 Moved Permanently` status. - The function `name` must exist and must be spelled correctly. #### Related Guides - [List of all Flux functions](https://docs.influxdata.com/flux/v0.x/stdlib/all-functions/) This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_query_suggestions_name(name, async_req=True) >>> result = thread.get() :param async_req bool :param str name: A [Flux function](https://docs.influxdata.com/flux/v0.x/stdlib/all-functions/) name. (required) :param str zap_trace_span: OpenTracing span context :return: FluxSuggestion If the method is called asynchronously, returns the request thread. Tr r N)r �)get_query_suggestions_name_with_http_info)r �namer r r r r �get_query_suggestions_name� s z'QueryService.get_query_suggestions_namec K sf | j |f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �S ) a Retrieve a query suggestion for a branching suggestion. Retrieves a query suggestion that contains the name and parameters of the requested function. Use this endpoint to pass a branching suggestion (a Flux function name) and retrieve the parameters of the requested function. #### Limitations - Use `/api/v2/query/suggestions/{name}` (without a trailing slash). `/api/v2/query/suggestions/{name}/` (note the trailing slash) results in a HTTP `301 Moved Permanently` status. - The function `name` must exist and must be spelled correctly. #### Related Guides - [List of all Flux functions](https://docs.influxdata.com/flux/v0.x/stdlib/all-functions/) This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_query_suggestions_name_with_http_info(name, async_req=True) >>> result = thread.get() :param async_req bool :param str name: A [Flux function](https://docs.influxdata.com/flux/v0.x/stdlib/all-functions/) name. (required) :param str zap_trace_span: OpenTracing span context :return: FluxSuggestion If the method is called asynchronously, returns the request thread. � /api/v2/query/suggestions/{name}r �FluxSuggestionr r r Tr r Nr ��#_get_query_suggestions_name_preparer r r �r r2 r r" r# r$ r% r& r r r r1 � s( � �z6QueryService.get_query_suggestions_name_with_http_infoc � sl | j |f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �I d H S ) a4 Retrieve a query suggestion for a branching suggestion. Retrieves a query suggestion that contains the name and parameters of the requested function. Use this endpoint to pass a branching suggestion (a Flux function name) and retrieve the parameters of the requested function. #### Limitations - Use `/api/v2/query/suggestions/{name}` (without a trailing slash). `/api/v2/query/suggestions/{name}/` (note the trailing slash) results in a HTTP `301 Moved Permanently` status. - The function `name` must exist and must be spelled correctly. #### Related Guides - [List of all Flux functions](https://docs.influxdata.com/flux/v0.x/stdlib/all-functions/) This method makes an asynchronous HTTP request. :param async_req bool :param str name: A [Flux function](https://docs.influxdata.com/flux/v0.x/stdlib/all-functions/) name. (required) :param str zap_trace_span: OpenTracing span context :return: FluxSuggestion If the method is called asynchronously, returns the request thread. r4 r r5 r r r Tr r Nr r6 r8 r r r � get_query_suggestions_name_async� s( � �z-QueryService.get_query_suggestions_name_asyncc K s� t � }ddg}| �d||� d|ks0|d d kr8td��i }d|krP|d |d< g }i }d|krl|d |d< d }| j�dg�|d< |||||fS )Nr2 r( r3 zOMissing the required parameter `name` when calling `get_query_suggestions_name`r) r* r+ )r, r- � ValueErrorr r. ) r r2 r r" r0 r# r$ r% r& r r r r7 � s& � �z0QueryService._get_query_suggestions_name_preparec K s2 d|d< |� d�r | jf |�S | jf |�}|S dS )as Query data. Retrieves data from buckets. Use this endpoint to send a Flux query request and retrieve data from a bucket. #### Rate limits (with InfluxDB Cloud) `read` rate limits apply. For more information, see [limits and adjustable quotas](https://docs.influxdata.com/influxdb/cloud/account-management/limits/). #### Related guides - [Query with the InfluxDB API](https://docs.influxdata.com/influxdb/latest/query-data/execute-queries/influx-api/) - [Get started with Flux](https://docs.influxdata.com/flux/v0.x/get-started/) This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.post_query(async_req=True) >>> result = thread.get() :param async_req bool :param str zap_trace_span: OpenTracing span context :param str accept_encoding: The content encoding (usually a compression algorithm) that the client can understand. :param str content_type: :param str org: An organization name or ID. #### InfluxDB Cloud - Doesn't use the `org` parameter or `orgID` parameter. - Queries the bucket in the organization associated with the authorization (API token). #### InfluxDB OSS - Requires either the `org` parameter or `orgID` parameter. - Queries the bucket in the specified organization. :param str org_id: An organization ID. #### InfluxDB Cloud - Doesn't use the `org` parameter or `orgID` parameter. - Queries the bucket in the organization associated with the authorization (API token). #### InfluxDB OSS - Requires either the `org` parameter or `orgID` parameter. - Queries the bucket in the specified organization. :param Query query: Flux query or specification to execute :return: str If the method is called asynchronously, returns the request thread. Tr r N)r �post_query_with_http_infor r r r � post_query s zQueryService.post_queryc K sd | j f |�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �S ) a� Query data. Retrieves data from buckets. Use this endpoint to send a Flux query request and retrieve data from a bucket. #### Rate limits (with InfluxDB Cloud) `read` rate limits apply. For more information, see [limits and adjustable quotas](https://docs.influxdata.com/influxdb/cloud/account-management/limits/). #### Related guides - [Query with the InfluxDB API](https://docs.influxdata.com/influxdb/latest/query-data/execute-queries/influx-api/) - [Get started with Flux](https://docs.influxdata.com/flux/v0.x/get-started/) This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.post_query_with_http_info(async_req=True) >>> result = thread.get() :param async_req bool :param str zap_trace_span: OpenTracing span context :param str accept_encoding: The content encoding (usually a compression algorithm) that the client can understand. :param str content_type: :param str org: An organization name or ID. #### InfluxDB Cloud - Doesn't use the `org` parameter or `orgID` parameter. - Queries the bucket in the organization associated with the authorization (API token). #### InfluxDB OSS - Requires either the `org` parameter or `orgID` parameter. - Queries the bucket in the specified organization. :param str org_id: An organization ID. #### InfluxDB Cloud - Doesn't use the `org` parameter or `orgID` parameter. - Queries the bucket in the organization associated with the authorization (API token). #### InfluxDB OSS - Requires either the `org` parameter or `orgID` parameter. - Queries the bucket in the specified organization. :param Query query: Flux query or specification to execute :return: str If the method is called asynchronously, returns the request thread. � /api/v2/query�POST�strr r r Tr r Nr ��_post_query_preparer r r r! r r r r; s( � �z&QueryService.post_query_with_http_infoc � sj | j f |�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �I d H S ) a� Query data. Retrieves data from buckets. Use this endpoint to send a Flux query request and retrieve data from a bucket. #### Rate limits (with InfluxDB Cloud) `read` rate limits apply. For more information, see [limits and adjustable quotas](https://docs.influxdata.com/influxdb/cloud/account-management/limits/). #### Related guides - [Query with the InfluxDB API](https://docs.influxdata.com/influxdb/latest/query-data/execute-queries/influx-api/) - [Get started with Flux](https://docs.influxdata.com/flux/v0.x/get-started/) This method makes an asynchronous HTTP request. :param async_req bool :param str zap_trace_span: OpenTracing span context :param str accept_encoding: The content encoding (usually a compression algorithm) that the client can understand. :param str content_type: :param str org: An organization name or ID. #### InfluxDB Cloud - Doesn't use the `org` parameter or `orgID` parameter. - Queries the bucket in the organization associated with the authorization (API token). #### InfluxDB OSS - Requires either the `org` parameter or `orgID` parameter. - Queries the bucket in the specified organization. :param str org_id: An organization ID. #### InfluxDB Cloud - Doesn't use the `org` parameter or `orgID` parameter. - Queries the bucket in the organization associated with the authorization (API token). #### InfluxDB OSS - Requires either the `org` parameter or `orgID` parameter. - Queries the bucket in the specified organization. :param Query query: Flux query or specification to execute :return: str If the method is called asynchronously, returns the request thread. r= r> r? r r r Tr r Nr r@ r! r r r �post_query_asyncH s( � �z QueryService.post_query_asyncc K s� t � }ddddddg}| �d||� i }g }d|krF|�d|d f� d|kr`|�d|d f� i }d|krx|d |d < d|kr�|d |d < d|kr�|d |d < d }d|kr�|d }| j�d d g�|d< | j�d dg�|d < |||||fS )Nr( �accept_encoding� content_type�orgZorg_id�queryr< ZorgIDr) zAccept-Encoding� Content-Typezapplication/csvr* r+ zapplication/vnd.flux)r, r- �appendr r. �select_header_content_typer/ r r r rA m s4 ��z QueryService._post_query_preparec K s2 d|d< |� d�r | jf |�S | jf |�}|S dS )ag Analyze a Flux query. Analyzes a [Flux query](https://docs.influxdata.com/flux/v0.x/) for syntax errors and returns the list of errors. In the following sample query, `from()` is missing the property key. ```json { "query": "from(: \\"iot_center\\")\\ |> range(start: -90d)\\ |> filter(fn: (r) => r._measurement == \\"environment\\")", "type": "flux" } ``` If you pass this in a request to the `/api/v2/analyze` endpoint, InfluxDB returns an `errors` list that contains an error object for the missing key. #### Limitations - The endpoint doesn't validate values in the query--for example: - The following sample query has correct syntax, but contains an incorrect `from()` property key: ```json { "query": "from(foo: \\"iot_center\\")\\ |> range(start: -90d)\\ |> filter(fn: (r) => r._measurement == \\"environment\\")", "type": "flux" } ``` If you pass this in a request to the `/api/v2/analyze` endpoint, InfluxDB returns an empty `errors` list. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.post_query_analyze(async_req=True) >>> result = thread.get() :param async_req bool :param str zap_trace_span: OpenTracing span context :param str content_type: :param Query query: Flux query to analyze :return: AnalyzeQueryResponse If the method is called asynchronously, returns the request thread. Tr r N)r �!post_query_analyze_with_http_infor r r r �post_query_analyze� s z QueryService.post_query_analyzec K sd | j f |�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �S ) av Analyze a Flux query. Analyzes a [Flux query](https://docs.influxdata.com/flux/v0.x/) for syntax errors and returns the list of errors. In the following sample query, `from()` is missing the property key. ```json { "query": "from(: \\"iot_center\\")\\ |> range(start: -90d)\\ |> filter(fn: (r) => r._measurement == \\"environment\\")", "type": "flux" } ``` If you pass this in a request to the `/api/v2/analyze` endpoint, InfluxDB returns an `errors` list that contains an error object for the missing key. #### Limitations - The endpoint doesn't validate values in the query--for example: - The following sample query has correct syntax, but contains an incorrect `from()` property key: ```json { "query": "from(foo: \\"iot_center\\")\\ |> range(start: -90d)\\ |> filter(fn: (r) => r._measurement == \\"environment\\")", "type": "flux" } ``` If you pass this in a request to the `/api/v2/analyze` endpoint, InfluxDB returns an empty `errors` list. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.post_query_analyze_with_http_info(async_req=True) >>> result = thread.get() :param async_req bool :param str zap_trace_span: OpenTracing span context :param str content_type: :param Query query: Flux query to analyze :return: AnalyzeQueryResponse If the method is called asynchronously, returns the request thread. �/api/v2/query/analyzer> �AnalyzeQueryResponser r r Tr r Nr ��_post_query_analyze_preparer r r r! r r r rJ � s( � �z.QueryService.post_query_analyze_with_http_infoc � sj | j f |�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �I d H S ) a� Analyze a Flux query. Analyzes a [Flux query](https://docs.influxdata.com/flux/v0.x/) for syntax errors and returns the list of errors. In the following sample query, `from()` is missing the property key. ```json { "query": "from(: \\"iot_center\\")\\ |> range(start: -90d)\\ |> filter(fn: (r) => r._measurement == \\"environment\\")", "type": "flux" } ``` If you pass this in a request to the `/api/v2/analyze` endpoint, InfluxDB returns an `errors` list that contains an error object for the missing key. #### Limitations - The endpoint doesn't validate values in the query--for example: - The following sample query has correct syntax, but contains an incorrect `from()` property key: ```json { "query": "from(foo: \\"iot_center\\")\\ |> range(start: -90d)\\ |> filter(fn: (r) => r._measurement == \\"environment\\")", "type": "flux" } ``` If you pass this in a request to the `/api/v2/analyze` endpoint, InfluxDB returns an empty `errors` list. This method makes an asynchronous HTTP request. :param async_req bool :param str zap_trace_span: OpenTracing span context :param str content_type: :param Query query: Flux query to analyze :return: AnalyzeQueryResponse If the method is called asynchronously, returns the request thread. rL r> rM r r r Tr r Nr rN r! r r r �post_query_analyze_async� s( � �z%QueryService.post_query_analyze_asyncc K s� t � }dddg}| �d||� i }g }i }d|kr>|d |d< d|krR|d |d< d }d|krf|d }| j�dg�|d< | j�dg�|d< |||||fS ) Nr( rD rF rK r) rG r* r+ �r, r- r r. rI r/ r r r rO � s( ��z(QueryService._post_query_analyze_preparec K s2 d|d< |� d�r | jf |�S | jf |�}|S dS )a� Generate a query Abstract Syntax Tree (AST). Analyzes a Flux query and returns a complete package source [Abstract Syntax Tree (AST)](https://docs.influxdata.com/influxdb/latest/reference/glossary/#abstract-syntax-tree-ast) for the query. Use this endpoint for deep query analysis such as debugging unexpected query results. A Flux query AST provides a semantic, tree-like representation with contextual information about the query. The AST illustrates how the query is distributed into different components for execution. #### Limitations - The endpoint doesn't validate values in the query--for example: The following sample Flux query has correct syntax, but contains an incorrect `from()` property key: ```js from(foo: "iot_center") |> range(start: -90d) |> filter(fn: (r) => r._measurement == "environment") ``` The following sample JSON shows how to pass the query in the request body: ```js from(foo: "iot_center") |> range(start: -90d) |> filter(fn: (r) => r._measurement == "environment") ``` The following code sample shows how to pass the query as JSON in the request body: ```json { "query": "from(foo: \\"iot_center\\")\\ |> range(start: -90d)\\ |> filter(fn: (r) => r._measurement == \\"environment\\")" } ``` Passing this to `/api/v2/query/ast` will return a successful response with a generated AST. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.post_query_ast(async_req=True) >>> result = thread.get() :param async_req bool :param str zap_trace_span: OpenTracing span context :param str content_type: :param LanguageRequest language_request: The Flux query to analyze. :return: ASTResponse If the method is called asynchronously, returns the request thread. Tr r N)r � post_query_ast_with_http_infor r r r �post_query_ast s zQueryService.post_query_astc K sd | j f |�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �S ) a� Generate a query Abstract Syntax Tree (AST). Analyzes a Flux query and returns a complete package source [Abstract Syntax Tree (AST)](https://docs.influxdata.com/influxdb/latest/reference/glossary/#abstract-syntax-tree-ast) for the query. Use this endpoint for deep query analysis such as debugging unexpected query results. A Flux query AST provides a semantic, tree-like representation with contextual information about the query. The AST illustrates how the query is distributed into different components for execution. #### Limitations - The endpoint doesn't validate values in the query--for example: The following sample Flux query has correct syntax, but contains an incorrect `from()` property key: ```js from(foo: "iot_center") |> range(start: -90d) |> filter(fn: (r) => r._measurement == "environment") ``` The following sample JSON shows how to pass the query in the request body: ```js from(foo: "iot_center") |> range(start: -90d) |> filter(fn: (r) => r._measurement == "environment") ``` The following code sample shows how to pass the query as JSON in the request body: ```json { "query": "from(foo: \\"iot_center\\")\\ |> range(start: -90d)\\ |> filter(fn: (r) => r._measurement == \\"environment\\")" } ``` Passing this to `/api/v2/query/ast` will return a successful response with a generated AST. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.post_query_ast_with_http_info(async_req=True) >>> result = thread.get() :param async_req bool :param str zap_trace_span: OpenTracing span context :param str content_type: :param LanguageRequest language_request: The Flux query to analyze. :return: ASTResponse If the method is called asynchronously, returns the request thread. �/api/v2/query/astr> � ASTResponser r r Tr r Nr ��_post_query_ast_preparer r r r! r r r rR $ s( � �z*QueryService.post_query_ast_with_http_infoc � sj | j f |�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �I d H S ) a@ Generate a query Abstract Syntax Tree (AST). Analyzes a Flux query and returns a complete package source [Abstract Syntax Tree (AST)](https://docs.influxdata.com/influxdb/latest/reference/glossary/#abstract-syntax-tree-ast) for the query. Use this endpoint for deep query analysis such as debugging unexpected query results. A Flux query AST provides a semantic, tree-like representation with contextual information about the query. The AST illustrates how the query is distributed into different components for execution. #### Limitations - The endpoint doesn't validate values in the query--for example: The following sample Flux query has correct syntax, but contains an incorrect `from()` property key: ```js from(foo: "iot_center") |> range(start: -90d) |> filter(fn: (r) => r._measurement == "environment") ``` The following sample JSON shows how to pass the query in the request body: ```js from(foo: "iot_center") |> range(start: -90d) |> filter(fn: (r) => r._measurement == "environment") ``` The following code sample shows how to pass the query as JSON in the request body: ```json { "query": "from(foo: \\"iot_center\\")\\ |> range(start: -90d)\\ |> filter(fn: (r) => r._measurement == \\"environment\\")" } ``` Passing this to `/api/v2/query/ast` will return a successful response with a generated AST. This method makes an asynchronous HTTP request. :param async_req bool :param str zap_trace_span: OpenTracing span context :param str content_type: :param LanguageRequest language_request: The Flux query to analyze. :return: ASTResponse If the method is called asynchronously, returns the request thread. rT r> rU r r r Tr r Nr rV r! r r r �post_query_ast_asyncI s( � �z!QueryService.post_query_ast_asyncc K s� t � }dddg}| �d||� i }g }i }d|kr>|d |d< d|krR|d |d< d }d|krf|d }| j�dg�|d< | j�dg�|d< |||||fS ) Nr( rD Zlanguage_requestrS r) rG r* r+ rQ r/ r r r rW k s( ��z$QueryService._post_query_ast_prepare)N)�__name__� __module__� __qualname__�__doc__r r r r' r r3 r1 r9 r7 r< r; rB rA rK rJ rP rO rS rR rX rW � __classcell__r r r r r s, # $!(%#%" %"r )r\ � __future__r �reZ%influxdb_client.service._base_servicer r r r r r �<module> s
💾 Save Changes
❌ Cancel