🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 06:30: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: restore_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 ).�RestoreServicez�NOTE: This class is auto generated by OpenAPI Generator. Ref: https://openapi-generator.tech Do not edit the class manually. Nc s t � �|� dS )z0RestoreService - a operation defined in OpenAPI.N)�super�__init__)�self� api_client�� __class__� �X/opt/alt/python38/lib/python3.8/site-packages/influxdb_client/service/restore_service.pyr s zRestoreService.__init__c K s: d|d< |� d�r"| j||f|�S | j||f|�}|S dS )a� Overwrite storage metadata for a bucket with shard info from a backup.. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.post_restore_bucket_id(bucket_id, body, async_req=True) >>> result = thread.get() :param async_req bool :param str bucket_id: The bucket ID. (required) :param str body: Database info serialized as protobuf. (required) :param str zap_trace_span: OpenTracing span context :param str content_type: :return: str If the method is called asynchronously, returns the request thread. T�_return_http_data_only� async_reqN)�get�%post_restore_bucket_id_with_http_info)r � bucket_id�body�kwargs�datar r r �post_restore_bucket_id s z%RestoreService.post_restore_bucket_idc K sh | j ||f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �S ) a� Overwrite storage metadata for a bucket with shard info from a backup.. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.post_restore_bucket_id_with_http_info(bucket_id, body, async_req=True) >>> result = thread.get() :param async_req bool :param str bucket_id: The bucket ID. (required) :param str body: Database info serialized as protobuf. (required) :param str zap_trace_span: OpenTracing span context :param str content_type: :return: str If the method is called asynchronously, returns the request thread. �!/api/v2/restore/bucket/{bucketID}�POST�strr r �_preload_contentT�_request_timeout� urlopen_kwN� r Z post_params�filesZ response_typeZ auth_settingsr r r r Zcollection_formatsr �� _post_restore_bucket_id_preparer �call_apir � r r r r �local_var_params� path_params� query_params� header_params� body_paramsr r r r 8 s( � �z4RestoreService.post_restore_bucket_id_with_http_infoc � sn | j ||f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �I d H S ) a Overwrite storage metadata for a bucket with shard info from a backup.. This method makes an asynchronous HTTP request. :param async_req bool :param str bucket_id: The bucket ID. (required) :param str body: Database info serialized as protobuf. (required) :param str zap_trace_span: OpenTracing span context :param str content_type: :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_restore_bucket_id_async] s( � �z+RestoreService.post_restore_bucket_id_asyncc K s� t � }ddddg}| �d||� d|ks4|d d kr<td��d|ksP|d d krXtd��i }d|krp|d |d< g }i }d|kr�|d |d < d|kr�|d |d < d } d|kr�|d } | j�d g�|d < | j�d g�|d < ||||| fS )Nr r �zap_trace_span� content_typer zPMissing the required parameter `bucket_id` when calling `post_restore_bucket_id`zKMissing the required parameter `body` when calling `post_restore_bucket_id`ZbucketID�Zap-Trace-Span� Content-Type�application/json�Accept� text/plain��localsZ_check_operation_params� ValueErrorr Zselect_header_acceptZselect_header_content_type) r r r r r" � all_paramsr# r$ r% r& r r r r s< � � ��z.RestoreService._post_restore_bucket_id_preparec K s6 d|d< |� d�r | j|f|�S | j|f|�}|S dS )a� Create a new bucket pre-seeded with shard info from a backup.. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.post_restore_bucket_metadata(bucket_metadata_manifest, async_req=True) >>> result = thread.get() :param async_req bool :param BucketMetadataManifest bucket_metadata_manifest: Metadata manifest for a bucket. (required) :param str zap_trace_span: OpenTracing span context :return: RestoredBucketMappings If the method is called asynchronously, returns the request thread. Tr r N)r �+post_restore_bucket_metadata_with_http_info)r �bucket_metadata_manifestr r r r r � post_restore_bucket_metadata� s z+RestoreService.post_restore_bucket_metadatac K sf | j |f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �S ) a� Create a new bucket pre-seeded with shard info from a backup.. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.post_restore_bucket_metadata_with_http_info(bucket_metadata_manifest, async_req=True) >>> result = thread.get() :param async_req bool :param BucketMetadataManifest bucket_metadata_manifest: Metadata manifest for a bucket. (required) :param str zap_trace_span: OpenTracing span context :return: RestoredBucketMappings If the method is called asynchronously, returns the request thread. � /api/v2/restore/bucketMetadatar �RestoredBucketMappingsr r r Tr r Nr ��%_post_restore_bucket_metadata_preparer r r �r r4 r r" r# r$ r% r& r r r r3 � s( � �z:RestoreService.post_restore_bucket_metadata_with_http_infoc � sl | j |f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �I d H S ) a� Create a new bucket pre-seeded with shard info from a backup.. This method makes an asynchronous HTTP request. :param async_req bool :param BucketMetadataManifest bucket_metadata_manifest: Metadata manifest for a bucket. (required) :param str zap_trace_span: OpenTracing span context :return: RestoredBucketMappings If the method is called asynchronously, returns the request thread. r6 r r7 r r r Tr r Nr r8 r: r r r �"post_restore_bucket_metadata_async� s( � �z1RestoreService.post_restore_bucket_metadata_asyncc K s� t � }ddg}| �d||� d|ks0|d d kr8td��i }g }i }d|krX|d |d< d }d|krl|d }| j�dg�|d< | j�dg�|d< |||||fS ) Nr4 r( r5 zeMissing the required parameter `bucket_metadata_manifest` when calling `post_restore_bucket_metadata`r* r, r- r+ r/ ) r r4 r r" r2 r# r$ r% r& r r r r9 � s, � ��z4RestoreService._post_restore_bucket_metadata_preparec K s6 d|d< |� d�r | j|f|�S | j|f|�}|S dS )ad Overwrite the embedded KV store on the server with a backed-up snapshot.. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.post_restore_kv(body, async_req=True) >>> result = thread.get() :param async_req bool :param file body: Full KV snapshot. (required) :param str zap_trace_span: OpenTracing span context :param str content_encoding: The value tells InfluxDB what compression is applied to the line protocol in the request payload. To make an API request with a GZIP payload, send `Content-Encoding: gzip` as a request header. :param str content_type: :return: PostRestoreKVResponse If the method is called asynchronously, returns the request thread. Tr r N)r � post_restore_kv_with_http_info�r r r r r r r �post_restore_kv s z RestoreService.post_restore_kvc K sf | j |f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �S ) as Overwrite the embedded KV store on the server with a backed-up snapshot.. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.post_restore_kv_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param file body: Full KV snapshot. (required) :param str zap_trace_span: OpenTracing span context :param str content_encoding: The value tells InfluxDB what compression is applied to the line protocol in the request payload. To make an API request with a GZIP payload, send `Content-Encoding: gzip` as a request header. :param str content_type: :return: PostRestoreKVResponse If the method is called asynchronously, returns the request thread. �/api/v2/restore/kvr �PostRestoreKVResponser r r Tr r Nr ��_post_restore_kv_preparer r r �r r r r" r# r$ r% r& r r r r< 6 s( � �z-RestoreService.post_restore_kv_with_http_infoc � sl | j |f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �I d H S ) a� Overwrite the embedded KV store on the server with a backed-up snapshot.. This method makes an asynchronous HTTP request. :param async_req bool :param file body: Full KV snapshot. (required) :param str zap_trace_span: OpenTracing span context :param str content_encoding: The value tells InfluxDB what compression is applied to the line protocol in the request payload. To make an API request with a GZIP payload, send `Content-Encoding: gzip` as a request header. :param str content_type: :return: PostRestoreKVResponse If the method is called asynchronously, returns the request thread. r? r r@ r r r Tr r Nr rA rC r r r �post_restore_kv_async[ s( � �z$RestoreService.post_restore_kv_asyncc K s� t � }ddddg}| �d||� d|ks4|d d kr<td��i }g }i }d|kr\|d |d< d|krp|d |d< d|kr�|d |d < d }d|kr�|d }| j�d g�|d < | j�d g�|d < |||||fS ) Nr r( �content_encodingr) r> zDMissing the required parameter `body` when calling `post_restore_kv`r* �Content-Encodingr+ r, r- r. r/ � r r r r" r2 r# r$ r% r& r r r rB } s4 � ��z'RestoreService._post_restore_kv_preparec K s: d|d< |� d�r"| j||f|�S | j||f|�}|S dS )aq Restore a TSM snapshot into a shard.. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.post_restore_shard_id(shard_id, body, async_req=True) >>> result = thread.get() :param async_req bool :param str shard_id: The shard ID. (required) :param file body: TSM snapshot. (required) :param str zap_trace_span: OpenTracing span context :param str content_encoding: The value tells InfluxDB what compression is applied to the line protocol in the request payload. To make an API request with a GZIP payload, send `Content-Encoding: gzip` as a request header. :param str content_type: :return: None If the method is called asynchronously, returns the request thread. Tr r N)r �$post_restore_shard_id_with_http_info)r �shard_idr r r r r r �post_restore_shard_id� s z$RestoreService.post_restore_shard_idc K sh | j ||f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d�d �S ) a� Restore a TSM snapshot into a shard.. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.post_restore_shard_id_with_http_info(shard_id, body, async_req=True) >>> result = thread.get() :param async_req bool :param str shard_id: The shard ID. (required) :param file body: TSM snapshot. (required) :param str zap_trace_span: OpenTracing span context :param str content_encoding: The value tells InfluxDB what compression is applied to the line protocol in the request payload. To make an API request with a GZIP payload, send `Content-Encoding: gzip` as a request header. :param str content_type: :return: None If the method is called asynchronously, returns the request thread. � /api/v2/restore/shards/{shardID}r Nr r r Tr r r �� _post_restore_shard_id_preparer r r � r rI r r r" r# r$ r% r& r r r rH � s( � �z3RestoreService.post_restore_shard_id_with_http_infoc � sn | j ||f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d�d �I dH S ) a� Restore a TSM snapshot into a shard.. This method makes an asynchronous HTTP request. :param async_req bool :param str shard_id: The shard ID. (required) :param file body: TSM snapshot. (required) :param str zap_trace_span: OpenTracing span context :param str content_encoding: The value tells InfluxDB what compression is applied to the line protocol in the request payload. To make an API request with a GZIP payload, send `Content-Encoding: gzip` as a request header. :param str content_type: :return: None If the method is called asynchronously, returns the request thread. rK r Nr r r Tr r r rL rN r r r �post_restore_shard_id_async� s( � �z*RestoreService.post_restore_shard_id_asyncc K s� t � }dddddg}| �d||� d|ks6|d d kr>td��d|ksR|d d krZtd��i }d|krr|d |d < g }i }d|kr�|d |d < d|kr�|d |d < d|kr�|d |d < d } d|kr�|d } | j�d g�|d< | j�dg�|d < ||||| fS )NrI r r( rE r) rJ zNMissing the required parameter `shard_id` when calling `post_restore_shard_id`zJMissing the required parameter `body` when calling `post_restore_shard_id`ZshardIDr* rF r+ r, r- r. r/ ) r rI r r r" r2 r# r$ r% r& r r r rM s@ � � ��z-RestoreService._post_restore_shard_id_preparec K s6 d|d< |� d�r | j|f|�S | j|f|�}|S dS )aV Overwrite the embedded SQL store on the server with a backed-up snapshot.. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.post_restore_sql(body, async_req=True) >>> result = thread.get() :param async_req bool :param file body: Full SQL snapshot. (required) :param str zap_trace_span: OpenTracing span context :param str content_encoding: The value tells InfluxDB what compression is applied to the line protocol in the request payload. To make an API request with a GZIP payload, send `Content-Encoding: gzip` as a request header. :param str content_type: :return: None If the method is called asynchronously, returns the request thread. Tr r N)r � post_restore_sql_with_http_infor= r r r �post_restore_sql+ s z RestoreService.post_restore_sqlc K sf | j |f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d�d �S ) ae Overwrite the embedded SQL store on the server with a backed-up snapshot.. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.post_restore_sql_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param file body: Full SQL snapshot. (required) :param str zap_trace_span: OpenTracing span context :param str content_encoding: The value tells InfluxDB what compression is applied to the line protocol in the request payload. To make an API request with a GZIP payload, send `Content-Encoding: gzip` as a request header. :param str content_type: :return: None If the method is called asynchronously, returns the request thread. �/api/v2/restore/sqlr Nr r r Tr r r ��_post_restore_sql_preparer r r rC r r r rP C s( � �z.RestoreService.post_restore_sql_with_http_infoc � sl | j |f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d�d �I dH S ) a� Overwrite the embedded SQL store on the server with a backed-up snapshot.. This method makes an asynchronous HTTP request. :param async_req bool :param file body: Full SQL snapshot. (required) :param str zap_trace_span: OpenTracing span context :param str content_encoding: The value tells InfluxDB what compression is applied to the line protocol in the request payload. To make an API request with a GZIP payload, send `Content-Encoding: gzip` as a request header. :param str content_type: :return: None If the method is called asynchronously, returns the request thread. rR r Nr r r Tr r r rS rC r r r �post_restore_sql_asynch s( � �z%RestoreService.post_restore_sql_asyncc K s� t � }ddddg}| �d||� d|ks4|d d kr<td��i }g }i }d|kr\|d |d< d|krp|d |d< d|kr�|d |d < d }d|kr�|d }| j�d g�|d < | j�d g�|d < |||||fS ) Nr r( rE r) rQ zEMissing the required parameter `body` when calling `post_restore_sql`r* rF r+ r, r- r. r/ rG r r r rT � s4 � ��z(RestoreService._post_restore_sql_prepare)N)�__name__� __module__� __qualname__�__doc__r r r r' r r5 r3 r; r9 r> r< rD rB rJ rH rO rM rQ rP rU rT � __classcell__r r r r r s, %"'# %"#&#)%"r )rY � __future__r �reZ%influxdb_client.service._base_servicer r r r r r �<module> s
💾 Save Changes
❌ Cancel