Seachfhreastalaí Requests áitiúil don tasc in Google Cloud Composer

Do thasc Cloud Composer a dteastaíonn iarraidh HTTP amháin amach trí sheachfhreastalaí uaithi, cumraigh an cliant HTTP taobh istigh de callable an taisc:

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

Úsáid an callable seo trí shocrú tascanna reatha an DAG. Caithfidh an seachfhreastalaí a bheith inrochtana ón worker a fhorghníomhaíonn é. Le haghaidh glaonna ceadaithe ar API poiblí gan fíordheimhniú seachfhreastalaí, soláthraíonn an liosta seachfhreastalaithe HTTP iarrthóirí do URL seachfhreastalaí HTTP an tseisiúin. Coinnigh URL fíordheimnithe nó cumraíocht chuntais eile sa fhoinse rúin atá beartaithe don imscaradh.

Dúntar an seisiún agus an freagra nuair a chríochnaíonn an fheidhm. Díchumasaíonn trust_env=False comhtháthú Requests leis an timpeallacht, rud a choisceann socruithe seachfhreastalaí a fuarthas le hoidhreacht ó iompar beartaithe an chliaint seo a athsholáthar, agus díchumasaíonn sé freisin roghnú CA bundle ag Requests atá bunaithe ar an timpeallacht. Soláthair an CA bundle beartaithe trí rogha verify an chliaint seo más gá.

Tá raon níos leithne agus srianta arna sainmhíniú ag an ardán ag athróga timpeallachta atá cumraithe do thimpeallacht Airflow bhainistithe. Trí an bealach a chur chuig an seisiún seo, fanann an cinneadh ceangailte le hoibríocht HTTP an taisc seo gan os.environ a athrú d'aon chód eile i bpróiseas an worker.