U vâ’ih1ã@sšdZddlZddlZddlZddlZddlmZddlZddlm Z ddlm Z ddlmZdd„Zd d „Z dd„ZGd d„dejƒZGdd„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 éN)Ú urlencode)ÚApiException)Ú_BaseRESTClient)Ú_UTF_8_encodingcÃs"t |j|j¡t |jd¡dS©Nz>>>)rZlog_requestÚmethodÚurlÚlog_headersÚheaders)ÚsessionÚtrace_config_ctxÚparams©rúL/opt/alt/python38/lib/python3.8/site-packages/influxdb_client/_async/rest.pyÚ_on_request_startsrcÃs|jrt |jd¡dSr)ÚchunkrÚlog_body)rÚcontextr rrrÚ_on_request_chunk_sentsrcÃspt |jj¡t |jd¡|jj}tƒ}| d¡IdH}|s@qJ||7}q*|rlt | t¡d¡|j|ddS)Nz<<<éd)Údata) rZlog_responseÚresponseÚstatusr r ÚcontentÚ bytearrayÚreadrÚdecoderZunread_data)rrr Zresponse_contentrrrrrÚ_on_request_end"s rc@s*eZdZdZdd„Zdd„Zd dd„ZdS) ÚRESTResponseAsyncúŠNOTE: This class is auto generated by OpenAPI Generator. Ref: https://openapi-generator.tech Do not edit the class manually. cCs ||_|j|_|j|_||_dS)zInitialize with HTTP response.N)Úaiohttp_responserÚreasonr)ÚselfÚresprrrrÚ__init__9szRESTResponseAsync.__init__cCs|jjS)z2Return a CIMultiDictProxy of the response headers.)r r ©r"rrrÚ getheaders@szRESTResponseAsync.getheadersNcCs|jj ||¡S)zReturn a given response header.)r r Úget)r"ÚnameÚdefaultrrrÚ getheaderDszRESTResponseAsync.getheader)N)Ú__name__Ú __module__Ú__qualname__Ú__doc__r$r&r*rrrrr2src@sreZdZdZddd„Zdd„Zdd d „Zddd„Zdd d„Zddd„Z ddd„Z ddd„Zd dd„Zd!dd„Z dS)"ÚRESTClientObjectAsyncréNcKsJ|dkr|j}|jdkrXtj|jd}|jrB|j|j|j|jd|j s^d|_ tj|_n|j}t j||d}|j|_|j|_| dd¡|_| dd ¡|_t ¡}|j t¡|j t¡|j t¡t|jttfƒrèt j |jd d}nt|jt j ƒrþ|j}nt j!j"}| dt j#¡} | d i¡} | f|||j$r6|gnddœ| —Ž|_%dS)zInitialize REST client.N)Úcafile)ÚcertfileÚkeyfileÚpasswordF)ÚlimitÚsslÚallow_redirectsTÚ max_redirectsé iè)ÚtotalZclient_session_typeZclient_session_kwargs)Ú connectorÚtimeoutZ trace_configs)&Zconnection_pool_maxsizeÚssl_contextr6Úcreate_default_contextZssl_ca_certÚ cert_fileÚload_cert_chainZ cert_key_fileZcert_key_passwordZ verify_sslÚcheck_hostnameÚ CERT_NONEÚverify_modeÚaiohttpZTCPConnectorÚproxyÚ proxy_headersr'r7r8ZTraceConfigZon_request_startÚappendrZon_request_chunk_sentrZon_request_endrÚ isinstancer<ÚintÚfloatZ ClientTimeoutÚclientÚDEFAULT_TIMEOUTZ ClientSessionÚdebugÚpool_manager)r"Ú configurationZ pools_sizeÚmaxsizeÚkwargsr=r;Ztrace_configr<Z_client_session_typeZ_client_session_kwargsrrrr$PsP þ þýüzRESTClientObjectAsync.__init__cÃs|j ¡IdHdS)z Dispose connection pool manager.N)rNÚcloser%rrrrR†szRESTClientObjectAsync.closeTc Ãsì| ¡}|dkst‚|r$|r$tdƒ‚|p*i}|p2i}d|krDd|d<||||j|jdœ} |jrh|j| d<|jrx|j| d<|r”| dd t|ƒ7<|d krt d|dtj ¡rÎ|dk rÄt |¡}|| d <nÂ|ddkrêt |¡| d <n¦|ddkrj|d=t ¡} |D]T}|\}} t| tƒrPt| ƒdkrP| j|| d| d| ddn| || ¡q | | d <n&t|tƒr€|| d <nd}td|d‚|jjf| ŽIdH}|rè| ¡IdH} t|| ƒ}d|jkrÜdksènt|d‚|S)aPExecute request. :param method: http request method :param url: http request url :param query_params: query parameters in the url :param headers: http request headers :param body: request json body, for `application/json` :param post_params: request post parameters, `application/x-www-form-urlencoded` and `multipart/form-data` :param _preload_content: this is a non-applicable field for the AiohttpClient. :param _request_timeout: timeout setting for this request. If one number provided, it will be total request timeout. It can also be a pair (tuple) of (connection, read) timeouts. )ÚGETÚHEADÚDELETEÚPOSTÚPUTÚPATCHÚOPTIONSz9body parameter cannot be used with post_params parameter.zContent-Typezapplication/json)rrr r7r8rErFrú?)rVrWrXrYrUÚjsonNrz!application/x-www-form-urlencodedzmultipart/form-dataééré)ÚvalueÚfilenameÚcontent_typez¨Cannot prepare a request message for provided arguments. Please check that your arguments match declared content type.)rr!éÈi+)Z http_resp)ÚupperÚAssertionErrorÚ ValueErrorr7r8rErFrÚreÚsearchÚ IGNORECASEr[ÚdumpsrDZFormDatarHÚtupleÚlenZ add_fieldÚbytesrrNÚrequestrrr)r"rrÚquery_paramsr ÚbodyÚpost_paramsÚ_preload_contentÚ_request_timeoutÚargsrÚparamÚkÚvÚmsgÚrrrrrmŠsjÿû ý zRESTClientObjectAsync.requestcÃs|jd|||||dIdHS)zPerform GET HTTP request.rS©r rqrrrnN©rm©r"rr rnrqrrrrrrSìsüzRESTClientObjectAsync.GETcÃs|jd|||||dIdHS)zPerform HEAD HTTP request.rTryNrzr{rrrrTõsüzRESTClientObjectAsync.HEADc Ãs |jd|||||||dIdHS)zPerform OPTIONS HTTP request.rY©r rnrprqrrroNrz©r"rr rnrprorqrrrrrrYþsúzRESTClientObjectAsync.OPTIONSc Ãs|jd||||||dIdHS)zPerform DELETE HTTP request.rU)r rnrqrrroNrz)r"rr rnrorqrrrrrrU sûzRESTClientObjectAsync.DELETEc Ãs |jd|||||||dIdHS)zPerform POST HTTP request.rVr|Nrzr}rrrrVsúzRESTClientObjectAsync.POSTc Ãs |jd|||||||dIdHS)zPerform PUT HTTP request.rWr|Nrzr}rrrrW súzRESTClientObjectAsync.PUTc Ãs |jd|||||||dIdHS)zPerform PATCH HTTP request.rXr|Nrzr}rrrrX+súzRESTClientObjectAsync.PATCH)r0N)NNNNTN)NNTN)NNTN)NNNNTN)NNNTN)NNNNTN)NNNNTN)NNNNTN)r+r,r-r.r$rRrmrSrTrYrUrVrWrXrrrrr/IsX 6þ bÿ ÿ þ ÿ þ ÿ þr/)r.Úior[rfr6Úurllib.parserrDZinfluxdb_client.restrrrrrrÚIOBaserÚobjectr/rrrrÚs