o id(@sddlZddlZddlZddlZddlmZmZmZddlm Z m Z m Z m Z m Z ddlmZddlmZddlmZmZedZGdd d eZdS) N) _api_version _max_timeouts_backoff_period) ClientErrorApiError HttpBackoff HttpTimeoutApiNotInitialized)resolve_http_client)is_p3k) construct_urlnormalize_tagsz datadog.apic@sheZdZdZeZeZdZdZdZdZ e ddZ e       d ddZ e d d Z e d d ZdS) APIClientz_ Datadog API client: format and submit API calls to Datadog. Embeds a HTTP client. NrFcCs|jst|_|jS)z6 Getter for the embedded HTTP client. ) _http_clientr )clsrJ/home/ubuntu/.local/lib/python3.10/site-packages/datadog/api/api_client.py_get_http_client%szAPIClient._get_http_clientc " KszE|s|\} } t| ddlm} m}m}m}m}m }m }m }m }m }| dur0tdi}| |d<|r<||d<|s@t}|rh|rhd|vr\|dD]}|dd d krZ||d<qLn |dd d krh||d<d | vrt| d trt| d }d || d <d | vrt| d trd d d| d D| d <t|trtj||jd}d|d<| rt|d}d|d<t|||}t}|j|||| |||||d }t t|dd}t!"d|j#|||fd|_$|j%}|r1zt&rt'|(d}nt'|}Wnt)yt)d*|wt|tr0|r0d|vr0|r,|j#|vs0t+|nd}|dur<||}|rD||fWS|WSt,yV|j$d7_$t-y} z,|rt!.t/| |durzd| j0diWYd} ~ S|d| j0diWYd} ~ Sd} ~ wt+y} z5|r| j0ddpgD]}!t!.|!q|dur| j0dWYd} ~ S|| j0dWYd} ~ Sd} ~ ww)a Make an HTTP API request :param method: HTTP method to use to contact API endpoint :type method: HTTP method string :param path: API endpoint url :type path: url :param api_version: The API version used :param body: dictionary to be sent in the body of the request :type body: dictionary :param response_formatter: function to format JSON response from HTTP API request :type response_formatter: JSON input function :param error_formatter: function to format JSON error response from HTTP API request :type error_formatter: JSON input function :param attach_host_name: link the new resource object to the host name :type attach_host_name: bool :param suppress_response_errors_on_codes: suppress ApiError on `errors` key in the response for the given HTTP status codes :type suppress_response_errors_on_codes: None|list(int) :param compress_payload: compress the payload using zlib :type compress_payload: bool :param params: dictionary to be sent in the query string of the request :type params: dictionary :returns: JSON or formatted response from HTTP API request r) _api_key_application_key _api_host_mute _host_name_proxies _max_retries_timeout_cacert_return_raw_responseNz9API key is not set. Please run 'initialize' method first.z DD-API-KEYzDD-APPLICATION-KEYserieshosttags, monitor_idscss|]}t|VqdS)N)str).0irrr sz#APIClient.submit..) sort_keyszapplication/jsonz Content-Typezutf-8deflatezContent-Encoding) methodurlheadersparamsdatatimeout max_retriesproxiesverifyg@@z%s %s %s (%sms)zInvalid JSON response: {0}errors)1_should_submit_backoff_statusr datadog.apirrrrrrrrrrr rget isinstancelistr joindictjsondumps _sort_keyszlibcompressencoder timerrequestroundloginfo status_code_timeout_countercontentr loadsdecode ValueErrorformatrrrerrorr$args)"rr*path api_versionbodyattach_host_nameresponse_formattererror_formatter!suppress_response_errors_on_codescompress_payloadr-_backoff_time_leftrrrrrrrrrrr, obj_paramstag_listr+ start_timeresultdurationrK response_objerPrrrsubmit/s1 0            zAPIClient.submitcCst}d}|js|j|jkrtd|j||_d}|S|jrD|\}}|dkr:td|d|_d|_d}|Std|d}|Sd}|S)z Returns True if we're in a state where we should make a request (backoff expired, no backoff in effect), false otherwise. FzCMax number of datadog timeouts exceeded, backing off for %s secondsrzHExiting backoff state after %s seconds, will try to submit metrics againNTz=In backoff state, won't submit metrics for another %s seconds)rD_backoff_timestamprJrrGrHrr7)rnow should_submitbacked_off_timer[rrrr6s:  zAPIClient._should_submitcCs0t}||j}|j|}t|dt|dfS)zN Get a backoff report, i.e. backoff total and remaining time. )rDrdrrF)rrergr[rrrr7s  zAPIClient._backoff_status)NNFNNNF)__name__ __module__ __qualname____doc__rrrdrJr@r classmethodrrcr6r7rrrrrs0   ? +r)r>loggingrDrAr8rrrdatadog.api.exceptionsrrrrr datadog.api.http_clientr datadog.util.compatr datadog.util.formatr r getLoggerrGobjectrrrrrs