U wтТi╘Ру@s8dZddlmZddlZddlmZGddД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)┌_BaseServicecseZdZdZd=ЗfddД ZddДZddДZd d ДZddДZd dДZ ddДZ ddДZddДZddДZ ddДZddДZddДZddДZdd ДZd!d"ДZd#d$ДZd%d&ДZd'd(ДZd)d*ДZd+d,ДZd-d.ДZd/d0ДZd1d2ДZd3d4ДZd5d6ДZd7d8ДZd9d:ДZd;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. NcstГа|б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.pyrszSourcesService.__init__cKs6d|d<|аdбr |j|f|ОS|j|f|О}|SdS)aDelete 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┌datarrr┌delete_sources_id s z SourcesService.delete_sources_idcKsf|j|f|О\}}}}}|jjdd||||gidg|а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}┌DELETENrr ┌_preload_contentT┌_request_timeout┌ urlopen_kwй┌bodyZpost_params┌filesZ response_typeZ auth_settingsrr rrZcollection_formatsrй┌_delete_sources_id_preparer┌call_apirйrrr┌local_var_params┌path_params┌query_params┌ header_params┌body_paramsrrrr6s( ёz/SourcesService.delete_sources_id_with_http_infoc╦sl|j|f|О\}}}}}|jjdd||||gidg|аdб|аdб|аddб|аdбi|аd dбd НIdHS)aaDelete 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. rrNrr rTrrrrr!rrr┌delete_sources_id_asyncYs( ёz&SourcesService.delete_sources_id_asyncc KsРtГ}ddg}|аd||бd|ks0|ddkr8tdГВi}d|krP|d|d<g}i}d|krl|d|d<d}|jаdgб|d<|||||fS) Nr┌zap_trace_spanrzKMissing 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й rrrr"┌ all_paramsr#r$r%r&rrrrys& z)SourcesService._delete_sources_id_preparecKs2d|d<|аdбr|jf|ОS|jf|О}|SdS)aList 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 rN)r┌get_sources_with_http_info)rrrrrr┌get_sourcesФs zSourcesService.get_sourcescKsd|jf|О\}}}}}|jjdd||||gidg|аdб|аdб|аddб|аdбi|аd d бdНS)aList 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┌Sourcesrr rTrrNrй┌_get_sources_preparerr rйrrr"r#r$r%r&rrrr4кs( ёz)SourcesService.get_sources_with_http_infoc╦sj|jf|О\}}}}}|jjdd||||gidg|аdб|аdб|аddб|аdбi|аd d бdНId HS)acList 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. r6r7r8rr rTrrNrr9r;rrr┌get_sources_async═s( ёz SourcesService.get_sources_asynccKsztГ}ddg}|аd||бi}g}d|kr>|аd|dfбi}d|krV|d|d<d}|jаdgб|d<|||||fS)Nr(┌orgr5r*r+r,)r.r/┌appendrr1)rrr"r3r#r$r%r&rrrr:эs z#SourcesService._get_sources_preparecKs6d|d<|аdбr |j|f|ОS|j|f|О}|SdS)aRetrieve 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 rN)r┌get_sources_id_with_http_inforrrr┌get_sources_ids zSourcesService.get_sources_idcKsf|j|f|О\}}}}}|jjdd||||gidg|а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. rr7┌Sourcerr rTrrNrй┌_get_sources_id_preparerr rr!rrrr?s( ёz,SourcesService.get_sources_id_with_http_infoc╦sl|j|f|О\}}}}}|jjdd||||gidg|аdб|аdб|аddб|аdбi|аd d бdНId HS)aeRetrieve 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. rr7rArr rTrrNrrBr!rrr┌get_sources_id_async=s( ёz#SourcesService.get_sources_id_asyncc KsРtГ}ddg}|аd||бd|ks0|ddkr8tdГВi}d|krP|d|d<g}i}d|krl|d|d<d}|jаdgб|d<|||||fS) Nrr(r@zHMissing the required parameter `source_id` when calling `get_sources_id`r)r*r+r,r-r2rrrrC]s& z&SourcesService._get_sources_id_preparecKs6d|d<|аdбr |j|f|ОS|j|f|О}|SdS)aaGet 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 rN)r┌%get_sources_id_buckets_with_http_inforrrr┌get_sources_id_bucketsxs z%SourcesService.get_sources_id_bucketscKsf|j|f|О\}}}}}|jjdd||||gidg|аdб|аdб|аddб|аdбi|аd d бdНS)apGet 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┌Bucketsrr rTrrNrй┌_get_sources_id_buckets_preparerr rr!rrrrEПs( ёz4SourcesService.get_sources_id_buckets_with_http_infoc╦sl|j|f|О\}}}}}|jjdd||||gidg|аdб|аdб|аddб|аdбi|аd d бdНId HS)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. rGr7rHrr rTrrNrrIr!rrr┌get_sources_id_buckets_async│s( ёz+SourcesService.get_sources_id_buckets_asyncc KsмtГ}dddg}|аd||бd|ks2|ddkr:tdГВi}d|krR|d|d<g}d|krp|аd|dfбi}d|krИ|d|d<d}|jаdgб|d <|||||fS) Nrr(r=rFzPMissing the required parameter `source_id` when calling `get_sources_id_buckets`r)r*r+r,)r.r/r0r>rr1r2rrrrJ╘s* z.SourcesService._get_sources_id_buckets_preparecKs6d|d<|аdбr |j|f|ОS|j|f|О}|SdS)a1Get 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 rN)r┌$get_sources_id_health_with_http_inforrrr┌get_sources_id_healthёs z$SourcesService.get_sources_id_healthcKsf|j|f|О\}}}}}|jjdd||||gidg|а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┌HealthCheckrr rTrrNrй┌_get_sources_id_health_preparerr rr!rrrrLs( ёz3SourcesService.get_sources_id_health_with_http_infoc╦sl|j|f|О\}}}}}|jjdd||||gidg|аdб|аdб|аddб|аdбi|аd d бdНId HS)asGet 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. rNr7rOrr rTrrNrrPr!rrr┌get_sources_id_health_async*s( ёz*SourcesService.get_sources_id_health_asyncc KsРtГ}ddg}|аd||бd|ks0|ddkr8tdГВi}d|krP|d|d<g}i}d|krl|d|d<d}|jаdgб|d<|||||fS) Nrr(rMzOMissing the required parameter `source_id` when calling `get_sources_id_health`r)r*r+r,r-r2rrrrQJs& z-SourcesService._get_sources_id_health_preparecKs:d|d<|аdбr"|j||f|ОS|j||f|О}|SdS)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 rN)r┌patch_sources_id_with_http_info)rr┌sourcerrrrr┌patch_sources_ides zSourcesService.patch_sources_idc Ksh|j||f|О\}}}}}|jjdd||||gidg|аdб|аdб|аddб|аdбi|аd d бdНS)ajUpdate 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┌PATCHrArr rTrrNrй┌_patch_sources_id_preparerr rй rrrTrr"r#r$r%r&rrrrS|s( ёz.SourcesService.patch_sources_id_with_http_infoc ╦sn|j||f|О\}}}}}|jjdd||||gidg|аdб|аdб|аddб|аdбi|аd d бdНId HS)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. rrVrArr rTrrNrrWrYrrr┌patch_sources_id_asyncаs( ёz%SourcesService.patch_sources_id_asyncc Ks╨tГ}dddg}|аd||бd|ks2|ddkr:tdГВd|ksN|ddkrVtdГВi}d|krn|d|d<g}i}d|krК|d|d<d} d|krЮ|d} |jаd gб|d <|jаd gб|d<||||| fS)NrrTr(rUzJMissing 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/r0rr1Zselect_header_content_type) rrrTrr"r3r#r$r%r&rrrrX┴s8 z(SourcesService._patch_sources_id_preparecKs6d|d<|аdбr |j|f|ОS|j|f|О}|SdS)aCreate 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 rN)r┌post_sources_with_http_info)rrTrrrrr┌post_sourcesцs zSourcesService.post_sourcescKsf|j|f|О\}}}}}|jjdd||||gidg|а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┌POSTrArr rTrrNrй┌_post_sources_preparerr rйrrTrr"r#r$r%r&rrrr]№s( ёz*SourcesService.post_sources_with_http_infoc╦sl|j|f|О\}}}}}|jjdd||||gidg|аdб|аdб|аddб|аdбi|аd d бdНId HS)aeCreate 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. r6r_rArr rTrrNrr`rbrrr┌post_sources_asyncs( ёz!SourcesService.post_sources_asyncc KsЮtГ}ddg}|аd||бd|ks0|ddkr8tdГВi}g}i}d|krX|d|d<d}d|krl|d}|jаdgб|d<|jаdgб|d<|||||fS) NrTr(r^zCMissing the required parameter `source` when calling `post_sources`r*r+r,r[r\) rrTrr"r3r#r$r%r&rrrra?s, z$SourcesService._post_sources_prepare)N)"┌__name__┌ __module__┌__qualname__┌__doc__rrrr'rr5r4r<r:r@r?rDrCrFrErKrJrMrLrRrQrUrSrZrXr^r]rcra┌ __classcell__rrr rrs<# # # $!# $!%# r)rg┌ __future__r┌reZ%influxdb_client.service._base_servicerrrrrr┌s