🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-09 13:06:18 | PHP 8.2.33
📂
/ (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: bucket_schemas_service.cpython-38.pyc
Read Only
U w�iw� � @ 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$� Z� ZS )&�BucketSchemasServicez�NOTE: This class is auto generated by OpenAPI Generator. Ref: https://openapi-generator.tech Do not edit the class manually. Nc s t � �|� dS )z6BucketSchemasService - a operation defined in OpenAPI.N)�super�__init__)�self� api_client�� __class__� �_/opt/alt/python38/lib/python3.8/site-packages/influxdb_client/service/bucket_schemas_service.pyr s z BucketSchemasService.__init__c K s: d|d< |� d�r"| j||f|�S | j||f|�}|S dS )a� Create a measurement schema for a bucket. Creates an _explict_ measurement [schema](https://docs.influxdata.com/influxdb/cloud/reference/glossary/#schema) for a bucket. _Explicit_ schemas are used to enforce column names, tags, fields, and data types for your data. By default, buckets have an _implicit_ schema-type (`"schemaType": "implicit"`) that conforms to your data. Use this endpoint to create schemas that prevent non-conforming write requests. #### Limitations - Buckets must be created with the "explict" `schemaType` in order to use schemas. #### Related guides - [Manage bucket schemas](https://docs.influxdata.com/influxdb/cloud/organizations/buckets/bucket-schema/). - [Create a bucket with an explicit schema](https://docs.influxdata.com/influxdb/cloud/organizations/buckets/create-bucket/#create-a-bucket-with-an-explicit-schema) This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.create_measurement_schema(bucket_id, measurement_schema_create_request, async_req=True) >>> result = thread.get() :param async_req bool :param str bucket_id: A bucket ID. Adds a schema for the specified bucket. (required) :param MeasurementSchemaCreateRequest measurement_schema_create_request: (required) :param str org: An organization name. Specifies the organization that owns the schema. :param str org_id: An organization ID. Specifies the organization that owns the schema. :return: MeasurementSchema If the method is called asynchronously, returns the request thread. T�_return_http_data_only� async_reqN)�get�(create_measurement_schema_with_http_info)r � bucket_id�!measurement_schema_create_request�kwargs�datar r r �create_measurement_schema s z.BucketSchemasService.create_measurement_schemac K s� | � � s ddlm} |�dd� | j||f|�\}}}}} | jjdd|||| g i dg |�d�|�d �|�d d �|�d �i |�d d�d�S )a� Create a measurement schema for a bucket. Creates an _explict_ measurement [schema](https://docs.influxdata.com/influxdb/cloud/reference/glossary/#schema) for a bucket. _Explicit_ schemas are used to enforce column names, tags, fields, and data types for your data. By default, buckets have an _implicit_ schema-type (`"schemaType": "implicit"`) that conforms to your data. Use this endpoint to create schemas that prevent non-conforming write requests. #### Limitations - Buckets must be created with the "explict" `schemaType` in order to use schemas. #### Related guides - [Manage bucket schemas](https://docs.influxdata.com/influxdb/cloud/organizations/buckets/bucket-schema/). - [Create a bucket with an explicit schema](https://docs.influxdata.com/influxdb/cloud/organizations/buckets/create-bucket/#create-a-bucket-with-an-explicit-schema) This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.create_measurement_schema_with_http_info(bucket_id, measurement_schema_create_request, async_req=True) >>> result = thread.get() :param async_req bool :param str bucket_id: A bucket ID. Adds a schema for the specified bucket. (required) :param MeasurementSchemaCreateRequest measurement_schema_create_request: (required) :param str org: An organization name. Specifies the organization that owns the schema. :param str org_id: An organization ID. Specifies the organization that owns the schema. :return: MeasurementSchema If the method is called asynchronously, returns the request thread. r ��CloudOnlyWarningr �Ohttps://docs.influxdata.com/influxdb/cloud/organizations/buckets/bucket-schema/�./api/v2/buckets/{bucketID}/schema/measurements�POST�MeasurementSchemar r �_preload_contentT�_request_timeout� urlopen_kwN� �bodyZ post_params�filesZ response_typeZ auth_settingsr r r r Zcollection_formatsr )�_is_cloud_instance� influxdb_client.client.warningsr � print_warning�"_create_measurement_schema_preparer �call_apir � r r r r r �local_var_params� path_params� query_params� header_params� body_paramsr r r r 9 s2 �� �z=BucketSchemasService.create_measurement_schema_with_http_infoc � s� | � � I dH s&ddlm} |�dd� | j||f|�\}}}}} | jjdd|||| g i dg |�d �|�d �|�d d �|�d �i |�dd�d�I dH S )a� Create a measurement schema for a bucket. Creates an _explict_ measurement [schema](https://docs.influxdata.com/influxdb/cloud/reference/glossary/#schema) for a bucket. _Explicit_ schemas are used to enforce column names, tags, fields, and data types for your data. By default, buckets have an _implicit_ schema-type (`"schemaType": "implicit"`) that conforms to your data. Use this endpoint to create schemas that prevent non-conforming write requests. #### Limitations - Buckets must be created with the "explict" `schemaType` in order to use schemas. #### Related guides - [Manage bucket schemas](https://docs.influxdata.com/influxdb/cloud/organizations/buckets/bucket-schema/). - [Create a bucket with an explicit schema](https://docs.influxdata.com/influxdb/cloud/organizations/buckets/create-bucket/#create-a-bucket-with-an-explicit-schema) This method makes an asynchronous HTTP request. :param async_req bool :param str bucket_id: A bucket ID. Adds a schema for the specified bucket. (required) :param MeasurementSchemaCreateRequest measurement_schema_create_request: (required) :param str org: An organization name. Specifies the organization that owns the schema. :param str org_id: An organization ID. Specifies the organization that owns the schema. :return: MeasurementSchema If the method is called asynchronously, returns the request thread. Nr r r r r r r r r r Tr r r )�_is_cloud_instance_asyncr# r r$ r% r r& r r' r r r � create_measurement_schema_asyncc s2 �� �z4BucketSchemasService.create_measurement_schema_asyncc K s� t � }ddddg}| �d||� d|ks4|d d kr<td��d|ksP|d d krXtd��i }d|krp|d |d< g }d|kr�|�d|d f� d|kr�|�d |d f� i }d } d|kr�|d } | j�d g�|d < | j�d g�|d < ||||| fS ) Nr r �org�org_idr zSMissing the required parameter `bucket_id` when calling `create_measurement_schema`zkMissing the required parameter `measurement_schema_create_request` when calling `create_measurement_schema`�bucketID�orgID�application/json�Accept� Content-Type��locals�_check_operation_params� ValueError�appendr �select_header_acceptZselect_header_content_type) r r r r r( � all_paramsr) r* r+ r, r r r r% � s< � � ��z7BucketSchemasService._create_measurement_schema_preparec K s: d|d< |� d�r"| j||f|�S | j||f|�}|S dS )a� Retrieve a measurement schema. Retrieves an explicit measurement [schema](https://docs.influxdata.com/influxdb/cloud/reference/glossary/#schema). This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_measurement_schema(bucket_id, measurement_id, async_req=True) >>> result = thread.get() :param async_req bool :param str bucket_id: A bucket ID. Retrieves schemas for the specified bucket. (required) :param str measurement_id: The measurement schema ID. Specifies the measurement schema to retrieve. (required) :param str org: Organization name. Specifies the organization that owns the schema. :param str org_id: Organization ID. Specifies the organization that owns the schema. :return: MeasurementSchema If the method is called asynchronously, returns the request thread. Tr r N)r �%get_measurement_schema_with_http_info)r r �measurement_idr r r r r �get_measurement_schema� s z+BucketSchemasService.get_measurement_schemac K s� | � � s ddlm} |�dd� | j||f|�\}}}}} | jjdd|||| g i dg |�d�|�d �|�d d �|�d �i |�d d�d�S )a� Retrieve a measurement schema. Retrieves an explicit measurement [schema](https://docs.influxdata.com/influxdb/cloud/reference/glossary/#schema). This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_measurement_schema_with_http_info(bucket_id, measurement_id, async_req=True) >>> result = thread.get() :param async_req bool :param str bucket_id: A bucket ID. Retrieves schemas for the specified bucket. (required) :param str measurement_id: The measurement schema ID. Specifies the measurement schema to retrieve. (required) :param str org: Organization name. Specifies the organization that owns the schema. :param str org_id: Organization ID. Specifies the organization that owns the schema. :return: MeasurementSchema If the method is called asynchronously, returns the request thread. r r r r �>/api/v2/buckets/{bucketID}/schema/measurements/{measurementID}�GETr r r r Tr r Nr )r" r# r r$ � _get_measurement_schema_preparer r& r � r r r> r r r( r) r* r+ r, r r r r= � s2 �� �z:BucketSchemasService.get_measurement_schema_with_http_infoc � s� | � � I dH s&ddlm} |�dd� | j||f|�\}}}}} | jjdd|||| g i dg |�d �|�d �|�d d �|�d �i |�dd�d�I dH S )a Retrieve a measurement schema. Retrieves an explicit measurement [schema](https://docs.influxdata.com/influxdb/cloud/reference/glossary/#schema). This method makes an asynchronous HTTP request. :param async_req bool :param str bucket_id: A bucket ID. Retrieves schemas for the specified bucket. (required) :param str measurement_id: The measurement schema ID. Specifies the measurement schema to retrieve. (required) :param str org: Organization name. Specifies the organization that owns the schema. :param str org_id: Organization ID. Specifies the organization that owns the schema. :return: MeasurementSchema If the method is called asynchronously, returns the request thread. Nr r r r r@ rA r r r r Tr r r )r- r# r r$ rB r r& r rC r r r � get_measurement_schema_async� s2 �� �z1BucketSchemasService.get_measurement_schema_asyncc K s� t � }ddddg}| �d||� d|ks4|d d kr<td��d|ksP|d d krXtd��i }d|krp|d |d< d|kr�|d |d < g }d|kr�|�d|d f� d|kr�|�d |d f� i }d } | j�d g�|d < ||||| fS ) Nr r> r/ r0 r? zPMissing the required parameter `bucket_id` when calling `get_measurement_schema`zUMissing the required parameter `measurement_id` when calling `get_measurement_schema`r1 � measurementIDr2 r3 r4 �r7 r8 r9 r: r r; ) r r r> r r( r< r) r* r+ r, r r r rB s6 � � �z4BucketSchemasService._get_measurement_schema_preparec K s6 d|d< |� d�r | j|f|�S | j|f|�}|S dS )aV List measurement schemas of a bucket. Lists _explicit_ [schemas](https://docs.influxdata.com/influxdb/cloud/reference/glossary/#schema) (`"schemaType": "explicit"`) for a bucket. _Explicit_ schemas are used to enforce column names, tags, fields, and data types for your data. By default, buckets have an _implicit_ schema-type (`"schemaType": "implicit"`) that conforms to your data. #### Related guides - [Using bucket schemas](https://www.influxdata.com/blog/new-bucket-schema-option-protect-from-unwanted-schema-changes/) This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_measurement_schemas(bucket_id, async_req=True) >>> result = thread.get() :param async_req bool :param str bucket_id: A bucket ID. Lists measurement schemas for the specified bucket. (required) :param str org: An organization name. Specifies the organization that owns the schema. :param str org_id: An organization ID. Specifies the organization that owns the schema. :param str name: A measurement name. Only returns measurement schemas with the specified name. :return: MeasurementSchemaList If the method is called asynchronously, returns the request thread. Tr r N)r �&get_measurement_schemas_with_http_info)r r r r r r r �get_measurement_schemas> s z,BucketSchemasService.get_measurement_schemasc K s� | � � s ddlm} |�dd� | j|f|�\}}}}}| jjdd||||g i dg |�d�|�d �|�d d �|�d �i |�d d�d�S )ae List measurement schemas of a bucket. Lists _explicit_ [schemas](https://docs.influxdata.com/influxdb/cloud/reference/glossary/#schema) (`"schemaType": "explicit"`) for a bucket. _Explicit_ schemas are used to enforce column names, tags, fields, and data types for your data. By default, buckets have an _implicit_ schema-type (`"schemaType": "implicit"`) that conforms to your data. #### Related guides - [Using bucket schemas](https://www.influxdata.com/blog/new-bucket-schema-option-protect-from-unwanted-schema-changes/) This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_measurement_schemas_with_http_info(bucket_id, async_req=True) >>> result = thread.get() :param async_req bool :param str bucket_id: A bucket ID. Lists measurement schemas for the specified bucket. (required) :param str org: An organization name. Specifies the organization that owns the schema. :param str org_id: An organization ID. Specifies the organization that owns the schema. :param str name: A measurement name. Only returns measurement schemas with the specified name. :return: MeasurementSchemaList If the method is called asynchronously, returns the request thread. r r r r r rA �MeasurementSchemaListr r r Tr r Nr )r" r# r r$ � _get_measurement_schemas_preparer r& r � r r r r r( r) r* r+ r, r r r rG W s2 � � �z;BucketSchemasService.get_measurement_schemas_with_http_infoc � s� | � � I dH s&ddlm} |�dd� | j|f|�\}}}}}| jjdd||||g i dg |�d �|�d �|�d d �|�d �i |�dd�d�I dH S )a� List measurement schemas of a bucket. Lists _explicit_ [schemas](https://docs.influxdata.com/influxdb/cloud/reference/glossary/#schema) (`"schemaType": "explicit"`) for a bucket. _Explicit_ schemas are used to enforce column names, tags, fields, and data types for your data. By default, buckets have an _implicit_ schema-type (`"schemaType": "implicit"`) that conforms to your data. #### Related guides - [Using bucket schemas](https://www.influxdata.com/blog/new-bucket-schema-option-protect-from-unwanted-schema-changes/) This method makes an asynchronous HTTP request. :param async_req bool :param str bucket_id: A bucket ID. Lists measurement schemas for the specified bucket. (required) :param str org: An organization name. Specifies the organization that owns the schema. :param str org_id: An organization ID. Specifies the organization that owns the schema. :param str name: A measurement name. Only returns measurement schemas with the specified name. :return: MeasurementSchemaList If the method is called asynchronously, returns the request thread. Nr r r r r rA rI r r r Tr r r )r- r# r r$ rJ r r& r rK r r r � get_measurement_schemas_async� s2 � � �z2BucketSchemasService.get_measurement_schemas_asyncc K s� t � }ddddg}| �d||� d|ks4|d d kr<td��i }d|krT|d |d< g }d|krr|�d|d f� d|kr�|�d|d f� d|kr�|�d|d f� i }d }| j�d g�|d < |||||fS ) Nr r/ r0 �namerH zQMissing the required parameter `bucket_id` when calling `get_measurement_schemas`r1 r2 r3 r4 rF ) r r r r( r< r) r* r+ r, r r r rJ � s. � �z5BucketSchemasService._get_measurement_schemas_preparec K s> d|d< |� d�r$| j|||f|�S | j|||f|�}|S dS )a� Update a measurement schema. Updates a measurement [schema](https://docs.influxdata.com/influxdb/cloud/reference/glossary/#schema). Use this endpoint to update the fields (`name`, `type`, and `dataType`) of a measurement schema. #### Limitations - You can't update the `name` of a measurement. #### Related guides - [Manage bucket schemas](https://docs.influxdata.com/influxdb/cloud/organizations/buckets/bucket-schema/). - [Using bucket schemas](https://www.influxdata.com/blog/new-bucket-schema-option-protect-from-unwanted-schema-changes/). This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.update_measurement_schema(bucket_id, measurement_id, measurement_schema_update_request, async_req=True) >>> result = thread.get() :param async_req bool :param str bucket_id: A bucket ID. Specifies the bucket to retrieve schemas for. (required) :param str measurement_id: A measurement schema ID. Retrieves the specified measurement schema. (required) :param MeasurementSchemaUpdateRequest measurement_schema_update_request: (required) :param str org: An organization name. Specifies the organization that owns the schema. :param str org_id: An organization ID. Specifies the organization that owns the schema. :return: MeasurementSchema If the method is called asynchronously, returns the request thread. Tr r N)r �(update_measurement_schema_with_http_info)r r r> �!measurement_schema_update_requestr r r r r �update_measurement_schema� s z.BucketSchemasService.update_measurement_schemac K s� | � � s ddlm} |�dd� | j|||f|�\}}}} } | jjdd||| | g i dg |�d�|�d �|�d d �|�d �i |�d d�d�S )a Update a measurement schema. Updates a measurement [schema](https://docs.influxdata.com/influxdb/cloud/reference/glossary/#schema). Use this endpoint to update the fields (`name`, `type`, and `dataType`) of a measurement schema. #### Limitations - You can't update the `name` of a measurement. #### Related guides - [Manage bucket schemas](https://docs.influxdata.com/influxdb/cloud/organizations/buckets/bucket-schema/). - [Using bucket schemas](https://www.influxdata.com/blog/new-bucket-schema-option-protect-from-unwanted-schema-changes/). This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.update_measurement_schema_with_http_info(bucket_id, measurement_id, measurement_schema_update_request, async_req=True) >>> result = thread.get() :param async_req bool :param str bucket_id: A bucket ID. Specifies the bucket to retrieve schemas for. (required) :param str measurement_id: A measurement schema ID. Retrieves the specified measurement schema. (required) :param MeasurementSchemaUpdateRequest measurement_schema_update_request: (required) :param str org: An organization name. Specifies the organization that owns the schema. :param str org_id: An organization ID. Specifies the organization that owns the schema. :return: MeasurementSchema If the method is called asynchronously, returns the request thread. r r r r r@ �PATCHr r r r Tr r Nr )r" r# r r$ �"_update_measurement_schema_preparer r& r � r r r> rO r r r( r) r* r+ r, r r r rN � s2 �� �z=BucketSchemasService.update_measurement_schema_with_http_infoc � s� | � � I dH s&ddlm} |�dd� | j|||f|�\}}}} } | jjdd||| | g i dg |�d �|�d �|�d d �|�d �i |�dd�d�I dH S )a Update a measurement schema. Updates a measurement [schema](https://docs.influxdata.com/influxdb/cloud/reference/glossary/#schema). Use this endpoint to update the fields (`name`, `type`, and `dataType`) of a measurement schema. #### Limitations - You can't update the `name` of a measurement. #### Related guides - [Manage bucket schemas](https://docs.influxdata.com/influxdb/cloud/organizations/buckets/bucket-schema/). - [Using bucket schemas](https://www.influxdata.com/blog/new-bucket-schema-option-protect-from-unwanted-schema-changes/). This method makes an asynchronous HTTP request. :param async_req bool :param str bucket_id: A bucket ID. Specifies the bucket to retrieve schemas for. (required) :param str measurement_id: A measurement schema ID. Retrieves the specified measurement schema. (required) :param MeasurementSchemaUpdateRequest measurement_schema_update_request: (required) :param str org: An organization name. Specifies the organization that owns the schema. :param str org_id: An organization ID. Specifies the organization that owns the schema. :return: MeasurementSchema If the method is called asynchronously, returns the request thread. Nr r r r r@ rQ r r r r Tr r r )r- r# r r$ rR r r& r rS r r r � update_measurement_schema_async s2 �� �z4BucketSchemasService.update_measurement_schema_asyncc K s$ t � }dddddg}| �d||� d|ks6|d d kr>td��d|ksR|d d krZtd��d|ksn|d d krvtd ��i }d|kr�|d |d < d|kr�|d |d < g }d|kr�|�d|d f� d|kr�|�d |d f� i } d } d|kr�|d } | j�d g�| d< | j�d g�| d< |||| | fS )Nr r> rO r/ r0 rP zSMissing the required parameter `bucket_id` when calling `update_measurement_schema`zXMissing the required parameter `measurement_id` when calling `update_measurement_schema`zkMissing the required parameter `measurement_schema_update_request` when calling `update_measurement_schema`r1 rE r2 r3 r4 r5 r6 ) r r r> rO r r( r< r) r* r+ r, r r r rR 4 sH � � � ��z7BucketSchemasService._update_measurement_schema_prepare)N)�__name__� __module__� __qualname__�__doc__r r r r. r% r? r= rD rB rH rG rL rJ rP rN rT rR � __classcell__r r r r r s$ *''*'#*' +(r )rX � __future__r �reZ%influxdb_client.service._base_servicer r r r r r �<module> s
💾 Save Changes
❌ Cancel