🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 04:52:35 | 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: sources_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,� Zd-d.� Zd/d0� Zd1d2� Zd3d4� Z d5d6� Z d7d8� Z d9d:� Z d;d<� Z � Z!S )>�SourcesServicez�NOTE: This class is auto generated by OpenAPI Generator. Ref: https://openapi-generator.tech Do not edit the class manually. Nc s t � �|� dS )z0SourcesService - a operation defined in OpenAPI.N)�super�__init__)�self� api_client�� __class__� �X/opt/alt/python38/lib/python3.8/site-packages/influxdb_client/service/sources_service.pyr s zSourcesService.__init__c K s6 d|d< |� d�r | j|f|�S | j|f|�}|S dS )a Delete a source. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_sources_id(source_id, async_req=True) >>> result = thread.get() :param async_req bool :param str source_id: The source ID. (required) :param str zap_trace_span: OpenTracing span context :return: None If the method is called asynchronously, returns the request thread. T�_return_http_data_only� async_reqN)�get� delete_sources_id_with_http_info�r � source_id�kwargs�datar r r �delete_sources_id s z SourcesService.delete_sources_idc K sf | j |f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d�d �S ) a* Delete a source. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_sources_id_with_http_info(source_id, async_req=True) >>> result = thread.get() :param async_req bool :param str source_id: The source ID. (required) :param str zap_trace_span: OpenTracing span context :return: None If the method is called asynchronously, returns the request thread. �/api/v2/sources/{sourceID}�DELETENr r �_preload_contentT�_request_timeout� urlopen_kw� �bodyZ post_params�filesZ response_typeZ auth_settingsr r r r Zcollection_formatsr ��_delete_sources_id_preparer �call_apir �r r r �local_var_params� path_params� query_params� header_params� body_paramsr r r r 6 s( � �z/SourcesService.delete_sources_id_with_http_infoc � sl | j |f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d�d �I dH S ) aa Delete a source. This method makes an asynchronous HTTP request. :param async_req bool :param str source_id: The source ID. (required) :param str zap_trace_span: OpenTracing span context :return: None If the method is called asynchronously, returns the request thread. r r Nr r r Tr r r r r! r r r �delete_sources_id_asyncY s( � �z&SourcesService.delete_sources_id_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 ) Nr �zap_trace_spanr zKMissing the required parameter `source_id` when calling `delete_sources_id`�sourceID�Zap-Trace-Span�application/json�Accept��locals�_check_operation_params� ValueErrorr �select_header_accept� r r r r" � all_paramsr# r$ r% r& r r r r y s& � �z)SourcesService._delete_sources_id_preparec K s2 d|d< |� d�r | jf |�S | jf |�}|S dS )a List all sources. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_sources(async_req=True) >>> result = thread.get() :param async_req bool :param str zap_trace_span: OpenTracing span context :param str org: The name of the organization. :return: Sources If the method is called asynchronously, returns the request thread. Tr r N)r �get_sources_with_http_info)r r r r r r � get_sources� s zSourcesService.get_sourcesc K sd | j f |�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �S ) a List all sources. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_sources_with_http_info(async_req=True) >>> result = thread.get() :param async_req bool :param str zap_trace_span: OpenTracing span context :param str org: The name of the organization. :return: Sources If the method is called asynchronously, returns the request thread. �/api/v2/sources�GET�Sourcesr r r Tr r Nr ��_get_sources_preparer r r �r r r" r# r$ r% r& r r r r4 � s( � �z)SourcesService.get_sources_with_http_infoc � sj | j f |�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �I d H S ) ac List all sources. This method makes an asynchronous HTTP request. :param async_req bool :param str zap_trace_span: OpenTracing span context :param str org: The name of the organization. :return: Sources If the method is called asynchronously, returns the request thread. r6 r7 r8 r r r Tr r Nr r9 r; r r r �get_sources_async� s( � �z SourcesService.get_sources_asyncc K sz t � }ddg}| �d||� i }g }d|kr>|�d|d f� i }d|krV|d |d< d }| j�dg�|d< |||||fS )Nr( �orgr5 r* r+ r, )r. r/ �appendr r1 )r r r" r3 r# r$ r% r& r r r r: � s �z#SourcesService._get_sources_preparec K s6 d|d< |� d�r | j|f|�S | j|f|�}|S dS )a Retrieve a source. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_sources_id(source_id, async_req=True) >>> result = thread.get() :param async_req bool :param str source_id: The source ID. (required) :param str zap_trace_span: OpenTracing span context :return: Source If the method is called asynchronously, returns the request thread. Tr r N)r � get_sources_id_with_http_infor r r r �get_sources_id s z SourcesService.get_sources_idc K sf | j |f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �S ) a+ Retrieve a source. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_sources_id_with_http_info(source_id, async_req=True) >>> result = thread.get() :param async_req bool :param str source_id: The source ID. (required) :param str zap_trace_span: OpenTracing span context :return: Source If the method is called asynchronously, returns the request thread. r r7 �Sourcer r r Tr r Nr ��_get_sources_id_preparer r r r! r r r r? s( � �z,SourcesService.get_sources_id_with_http_infoc � sl | j |f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �I d H S ) ae Retrieve a source. This method makes an asynchronous HTTP request. :param async_req bool :param str source_id: The source ID. (required) :param str zap_trace_span: OpenTracing span context :return: Source If the method is called asynchronously, returns the request thread. r r7 rA r r r Tr r Nr rB r! r r r �get_sources_id_async= s( � �z#SourcesService.get_sources_id_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 ) Nr r( r@ zHMissing the required parameter `source_id` when calling `get_sources_id`r) r* r+ r, r- r2 r r r rC ] s& � �z&SourcesService._get_sources_id_preparec K s6 d|d< |� d�r | j|f|�S | j|f|�}|S dS )aa Get buckets in a source. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_sources_id_buckets(source_id, async_req=True) >>> result = thread.get() :param async_req bool :param str source_id: The source ID. (required) :param str zap_trace_span: OpenTracing span context :param str org: The name of the organization. :return: Buckets If the method is called asynchronously, returns the request thread. Tr r N)r �%get_sources_id_buckets_with_http_infor r r r �get_sources_id_bucketsx s z%SourcesService.get_sources_id_bucketsc K sf | j |f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �S ) ap Get buckets in a source. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_sources_id_buckets_with_http_info(source_id, async_req=True) >>> result = thread.get() :param async_req bool :param str source_id: The source ID. (required) :param str zap_trace_span: OpenTracing span context :param str org: The name of the organization. :return: Buckets If the method is called asynchronously, returns the request thread. �"/api/v2/sources/{sourceID}/bucketsr7 �Bucketsr r r Tr r Nr �� _get_sources_id_buckets_preparer r r r! r r r rE � s( � �z4SourcesService.get_sources_id_buckets_with_http_infoc � sl | j |f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �I d H S ) a� Get buckets in a source. This method makes an asynchronous HTTP request. :param async_req bool :param str source_id: The source ID. (required) :param str zap_trace_span: OpenTracing span context :param str org: The name of the organization. :return: Buckets If the method is called asynchronously, returns the request thread. rG r7 rH r r r Tr r Nr rI r! r r r � get_sources_id_buckets_async� s( � �z+SourcesService.get_sources_id_buckets_asyncc K s� t � }dddg}| �d||� d|ks2|d d kr:td��i }d|krR|d |d< g }d|krp|�d|d f� i }d|kr�|d |d< d }| j�dg�|d < |||||fS ) Nr r( r= rF zPMissing the required parameter `source_id` when calling `get_sources_id_buckets`r) r* r+ r, )r. r/ r0 r> r r1 r2 r r r rJ � s* � �z.SourcesService._get_sources_id_buckets_preparec K s6 d|d< |� d�r | j|f|�S | j|f|�}|S dS )a1 Get the health of a source. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_sources_id_health(source_id, async_req=True) >>> result = thread.get() :param async_req bool :param str source_id: The source ID. (required) :param str zap_trace_span: OpenTracing span context :return: HealthCheck If the method is called asynchronously, returns the request thread. Tr r N)r �$get_sources_id_health_with_http_infor r r r �get_sources_id_health� s z$SourcesService.get_sources_id_healthc K sf | j |f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �S ) a@ Get the health of a source. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_sources_id_health_with_http_info(source_id, async_req=True) >>> result = thread.get() :param async_req bool :param str source_id: The source ID. (required) :param str zap_trace_span: OpenTracing span context :return: HealthCheck If the method is called asynchronously, returns the request thread. �!/api/v2/sources/{sourceID}/healthr7 � HealthCheckr r r Tr r Nr �� _get_sources_id_health_preparer r r r! r r r rL s( � �z3SourcesService.get_sources_id_health_with_http_infoc � sl | j |f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �I d H S ) as Get the health of a source. This method makes an asynchronous HTTP request. :param async_req bool :param str source_id: The source ID. (required) :param str zap_trace_span: OpenTracing span context :return: HealthCheck If the method is called asynchronously, returns the request thread. rN r7 rO r r r Tr r Nr rP r! r r r �get_sources_id_health_async* s( � �z*SourcesService.get_sources_id_health_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 ) Nr r( rM zOMissing the required parameter `source_id` when calling `get_sources_id_health`r) r* r+ r, r- r2 r r r rQ J s& � �z-SourcesService._get_sources_id_health_preparec K s: d|d< |� d�r"| j||f|�S | j||f|�}|S dS )a[ Update a Source. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.patch_sources_id(source_id, source, async_req=True) >>> result = thread.get() :param async_req bool :param str source_id: The source ID. (required) :param Source source: Source update (required) :param str zap_trace_span: OpenTracing span context :return: Source If the method is called asynchronously, returns the request thread. Tr r N)r � patch_sources_id_with_http_info)r r �sourcer r r r r �patch_sources_ide s z SourcesService.patch_sources_idc K sh | j ||f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �S ) aj Update a Source. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.patch_sources_id_with_http_info(source_id, source, async_req=True) >>> result = thread.get() :param async_req bool :param str source_id: The source ID. (required) :param Source source: Source update (required) :param str zap_trace_span: OpenTracing span context :return: Source If the method is called asynchronously, returns the request thread. r �PATCHrA r r r Tr r Nr ��_patch_sources_id_preparer r r � r r rT r r" r# r$ r% r& r r r rS | s( � �z.SourcesService.patch_sources_id_with_http_infoc � sn | j ||f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �I d H S ) a� Update a Source. This method makes an asynchronous HTTP request. :param async_req bool :param str source_id: The source ID. (required) :param Source source: Source update (required) :param str zap_trace_span: OpenTracing span context :return: Source If the method is called asynchronously, returns the request thread. r rV rA r r r Tr r Nr rW rY r r r �patch_sources_id_async� s( � �z%SourcesService.patch_sources_id_asyncc K s� t � }dddg}| �d||� d|ks2|d d kr:td��d|ksN|d d krVtd��i }d|krn|d |d< g }i }d|kr�|d |d< d } d|kr�|d } | j�d g�|d < | j�d g�|d < ||||| fS ) Nr rT r( rU zJMissing the required parameter `source_id` when calling `patch_sources_id`zGMissing the required parameter `source` when calling `patch_sources_id`r) r* r+ r, � Content-Type�r. r/ r0 r r1 Zselect_header_content_type) r r rT r r" r3 r# r$ r% r& r r r rX � s8 � � ��z(SourcesService._patch_sources_id_preparec K s6 d|d< |� d�r | j|f|�S | j|f|�}|S dS )a Create a source. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.post_sources(source, async_req=True) >>> result = thread.get() :param async_req bool :param Source source: Source to create (required) :param str zap_trace_span: OpenTracing span context :return: Source If the method is called asynchronously, returns the request thread. Tr r N)r �post_sources_with_http_info)r rT r r r r r � post_sources� s zSourcesService.post_sourcesc K sf | j |f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �S ) a& Create a source. This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.post_sources_with_http_info(source, async_req=True) >>> result = thread.get() :param async_req bool :param Source source: Source to create (required) :param str zap_trace_span: OpenTracing span context :return: Source If the method is called asynchronously, returns the request thread. r6 �POSTrA r r r Tr r Nr ��_post_sources_preparer r r �r rT r r" r# r$ r% r& r r r r] � s( � �z*SourcesService.post_sources_with_http_infoc � sl | j |f|�\}}}}}| jjdd||||g i dg |�d�|�d�|�dd�|�d�i |�d d �d �I d H S ) ae Create a source. This method makes an asynchronous HTTP request. :param async_req bool :param Source source: Source to create (required) :param str zap_trace_span: OpenTracing span context :return: Source If the method is called asynchronously, returns the request thread. r6 r_ rA r r r Tr r Nr r` rb r r r �post_sources_async s( � �z!SourcesService.post_sources_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 ) NrT r( r^ zCMissing the required parameter `source` when calling `post_sources`r* r+ r, r[ r\ ) r rT r r" r3 r# r$ r% r& r r r ra ? s, � ��z$SourcesService._post_sources_prepare)N)"�__name__� __module__� __qualname__�__doc__r r r r' r r5 r4 r< r: r@ r? rD rC rF rE rK rJ rM rL rR rQ rU rS rZ rX r^ r] rc ra � __classcell__r r r r r s< # # # $! # $!%# r )rg � __future__r �reZ%influxdb_client.service._base_servicer r r r r r �<module> s
💾 Save Changes
❌ Cancel