Proxy Requests oo ku eg-ni-gooni ah Google Cloud Composer

Hawsha Cloud Composer oo u baahan hal codsi HTTP oo baxa oo mara proxy, ku habee macmiilka HTTP gudaha callable-ka hawsha:

def fetch_status():
    import requests

    with requests.Session() as session:
        session.trust_env = False
        with session.get(
            'https://api.example/health',
            proxies={'https': 'http://proxy.example:8080'},
            timeout=(5, 30),
        ) as response:
            response.raise_for_status()
            return response.status_code

Isticmaal callable-kan iyada oo loo marayo habaynta hawsha DAG ee jirta. Proxy waa in laga gaari karo worker-ka fulinaya hawsha. Wicitaannada API ee dadweynaha ee la ogolaaday ee aan u baahnayn xaqiijinta proxy, liiska proxy HTTP wuxuu bixiyaa musharixiin loogu talagalay URL-ka proxy HTTP ee fadhiga. Ku hay URL la xaqiijiyay ama habayn kale oo akoonka ah isha sirta ee loogu talagalay baahinta.

Session-ka iyo jawaabtu way xirmaan marka hawshu dhammaato. trust_env=False wuxuu damiyaa iska-xidhka deegaanka ee Requests, isagoo ka hortagaya in dejinta proxy ee la dhaxlay beddesho dhaqanka loogu talagalay macmiilkan, wuxuuna sidoo kale damiyaa xulashada CA bundle ee Requests ee ku salaysan deegaanka. Haddii loo baahdo, bixi CA bundle-ka loogu talagalay iyada oo loo marayo ikhtiyaarka verify ee macmiilkan.

Doorsooyinka deegaanka ee loo habeeyay deegaan Airflow la maamulo waxay leeyihiin baaxad ballaadhan iyo xannibaadyo ay qeexday madal. U gudbinta waddada Session-kan waxay go’aanka ku hayaan hawlgal HTTP ee hawshan iyada oo aan os.environ loo beddelin koodka kale ee habka worker.