File manager - Edit - /home/newsbmcs.com/public_html/static/img/logo/azure.zip
Back
PK �V�Z�R4� � $ __pycache__/__init__.cpython-310.pycnu �[��� o �Ad � @ s d S )N� r r r �B/usr/lib/python3/dist-packages/cloudinit/sources/azure/__init__.py�<module> s PK �V�Zћ�� � __pycache__/imds.cpython-310.pycnu �[��� o �Ad� � @ s� d dl mZ d dlZd dlmZ d dlmZ d dlmZ d dl m Z m Z e� e �ZdZG dd � d �Zd d d d �dededededef dd�Z ddededefdd�Zddedefdd�Zdefdd�ZdS ) � )�DictN)�log)�util)�report_diagnostic_event)�UrlError�readurlz http://169.254.169.254/metadatac @ s: e Zd Zdddd�dededdfd d �Zdefd d �ZdS ) �ReadUrlRetryHandler)� � i� i� � � �?)� retry_codes�max_connection_errors�logging_backoffr r �returnNc C s" || _ || _|| _d| _d| _d S )Nr r )r r r �_logging_threshold�_request_count)�selfr r r � r �>/usr/lib/python3/dist-packages/cloudinit/sources/azure/imds.py�__init__ s z ReadUrlRetryHandler.__init__c C s� | j d7 _ t|t�std| tjd� dS d}d}t|jtjtj f�r4| j d8 _ | j dk r3d}n|j | j vr<d}| j | j krK| j | j9 _ nd}|sQ|s]td| j |f tjd� |S )N� z1Polling IMDS failed with unexpected exception: %r�� logger_funcFTr z1Polling IMDS failed attempt %d with exception: %r)r � isinstancer r �LOG�warning�cause�requests�ConnectionError�Timeoutr �coder r r �info)r �req_args� exceptionr �retryr r r �exception_callback& s> ��� � ��z&ReadUrlRetryHandler.exception_callback)�__name__� __module__� __qualname__�int�floatr �boolr& r r r r r s � � � �r Tr � )� log_response�retries�timeout�urlr. r/ r0 r c C sX t � }zt| |jddid|||d�}W |jS ty+ } z td| tjd� � d}~ww )zLFetch URL from IMDS. :raises UrlError: on error fetching metadata. �Metadata�trueF)� exception_cb�headers�infinite� log_req_respr/ r0 z&Failed to fetch metadata from IMDS: %sr N)r r r& r r r r �contents)r1 r. r/ r0 �handler�response�errorr r r � _fetch_urlM s( �����r< c C sF t | |d�}zt�|�W S ty" } z td| tjd� � d}~ww )zFetch IMDS metadata. :raises UrlError: on error fetching metadata. :raises ValueError: on error parsing metadata. �r/ z&Failed to parse metadata from IMDS: %sr N)r< r � load_json� ValueErrorr r r )r1 r/ �metadatar; r r r �_fetch_metadataj s ���rA c C sj z t d }t|| d�W S ty4 } z |jdkr/tdtjd� t d }t|| d�W Y d}~S � d}~ww )z�Fetch extended metadata, falling back to non-extended as required. :raises UrlError: on error fetching metadata. :raises ValueError: on error parsing metadata. z./instance?api-version=2021-08-01&extended=truer= i� z,Falling back to IMDS api-version: 2019-06-01r z /instance?api-version=2019-06-01N)�IMDS_URLrA r r! r r r )r/ r1 r; r r r � fetch_metadata_with_api_fallback s ���rC c C sR t d } tdddd�}t| |jddidd d d �}td |jd � d�tjd� |jS )zhFetch extended metadata, falling back to non-extended as required. :raises UrlError: on error. z'/reprovisiondata?api-version=2019-06-01g @r )r r )r r r r2 r3 TFr- )r4 r5 r6 r7 r0 z Polled IMDS r z time(s)r ) rB r r r& r r r �debugr8 )r1 r9 r: r r r �fetch_reprovision_data� s& �� �rE )r )�typingr r � cloudinitr �loggingr � cloudinit.sources.helpers.azurer �cloudinit.url_helperr r � getLoggerr' r rB r �strr, r* �bytesr< rA rC rE r r r r �<module> s> ;����� � ��� �PK �V�Z��C�� � imds.pynu �[��� # Copyright (C) 2022 Microsoft Corporation. # # This file is part of cloud-init. See LICENSE file for license information. from typing import Dict import requests from cloudinit import log as logging from cloudinit import util from cloudinit.sources.helpers.azure import report_diagnostic_event from cloudinit.url_helper import UrlError, readurl LOG = logging.getLogger(__name__) IMDS_URL = "http://169.254.169.254/metadata" class ReadUrlRetryHandler: def __init__( self, *, retry_codes=( 404, # not found (yet) 410, # gone / unavailable (yet) 429, # rate-limited/throttled 500, # server error ), max_connection_errors: int = 10, logging_backoff: float = 1.0, ) -> None: self.logging_backoff = logging_backoff self.max_connection_errors = max_connection_errors self.retry_codes = retry_codes self._logging_threshold = 1.0 self._request_count = 0 def exception_callback(self, req_args, exception) -> bool: self._request_count += 1 if not isinstance(exception, UrlError): report_diagnostic_event( "Polling IMDS failed with unexpected exception: %r" % (exception), logger_func=LOG.warning, ) return False log = True retry = True # Check for connection errors which may occur early boot, but # are otherwise indicative that we are not connecting with the # primary NIC. if isinstance( exception.cause, (requests.ConnectionError, requests.Timeout) ): self.max_connection_errors -= 1 if self.max_connection_errors < 0: retry = False elif exception.code not in self.retry_codes: retry = False if self._request_count >= self._logging_threshold: self._logging_threshold *= self.logging_backoff else: log = False if log or not retry: report_diagnostic_event( "Polling IMDS failed attempt %d with exception: %r" % (self._request_count, exception), logger_func=LOG.info, ) return retry def _fetch_url( url: str, *, log_response: bool = True, retries: int = 10, timeout: int = 2 ) -> bytes: """Fetch URL from IMDS. :raises UrlError: on error fetching metadata. """ handler = ReadUrlRetryHandler() try: response = readurl( url, exception_cb=handler.exception_callback, headers={"Metadata": "true"}, infinite=False, log_req_resp=log_response, retries=retries, timeout=timeout, ) except UrlError as error: report_diagnostic_event( "Failed to fetch metadata from IMDS: %s" % error, logger_func=LOG.warning, ) raise return response.contents def _fetch_metadata( url: str, retries: int = 10, ) -> Dict: """Fetch IMDS metadata. :raises UrlError: on error fetching metadata. :raises ValueError: on error parsing metadata. """ metadata = _fetch_url(url, retries=retries) try: return util.load_json(metadata) except ValueError as error: report_diagnostic_event( "Failed to parse metadata from IMDS: %s" % error, logger_func=LOG.warning, ) raise def fetch_metadata_with_api_fallback(retries: int = 10) -> Dict: """Fetch extended metadata, falling back to non-extended as required. :raises UrlError: on error fetching metadata. :raises ValueError: on error parsing metadata. """ try: url = IMDS_URL + "/instance?api-version=2021-08-01&extended=true" return _fetch_metadata(url, retries=retries) except UrlError as error: if error.code == 400: report_diagnostic_event( "Falling back to IMDS api-version: 2019-06-01", logger_func=LOG.warning, ) url = IMDS_URL + "/instance?api-version=2019-06-01" return _fetch_metadata(url, retries=retries) raise def fetch_reprovision_data() -> bytes: """Fetch extended metadata, falling back to non-extended as required. :raises UrlError: on error. """ url = IMDS_URL + "/reprovisiondata?api-version=2019-06-01" handler = ReadUrlRetryHandler( logging_backoff=2.0, max_connection_errors=0, retry_codes=( 404, 410, ), ) response = readurl( url, exception_cb=handler.exception_callback, headers={"Metadata": "true"}, infinite=True, log_req_resp=False, timeout=2, ) report_diagnostic_event( f"Polled IMDS {handler._request_count+1} time(s)", logger_func=LOG.debug, ) return response.contents PK �V�Z __init__.pynu �[��� PK �V�Z�R4� � $ __pycache__/__init__.cpython-310.pycnu �[��� PK �V�Zћ�� � � __pycache__/imds.cpython-310.pycnu �[��� PK �V�Z��C�� � @ imds.pynu �[��� PK �V�Z % __init__.pynu �[��� PK V @%
| ver. 1.4 |
Github
|
.
| PHP 8.2.28 | Generation time: 0.02 |
proxy
|
phpinfo
|
Settings