Procs Requests lleol i'r dasg yn Google Cloud Composer

Ar gyfer tasg Cloud Composer sy'n gofyn am un cais HTTP allanol drwy brocs, ffurfweddwch y cleient HTTP y tu mewn i callable y dasg:

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

Defnyddiwch y callable hwn drwy drefniant tasgau presennol y DAG. Rhaid i'r procs fod yn gyrraeddadwy o'r gweithiwr sy'n ei weithredu. Ar gyfer galwadau API cyhoeddus a ganiateir heb ddilysu procs, mae'r rhestr procs HTTP yn cynnig ymgeiswyr ar gyfer URL procs HTTP y sesiwn. Cadwch URL dilysedig neu ffurfweddiad cyfrif arall yn y ffynhonnell gyfrinachau a fwriedir ar gyfer y defnydd.

Mae'r sesiwn a'r ymateb yn cau wrth i'r ffwythiant ddod i ben. Mae trust_env=False yn analluogi integreddiad Requests â'r amgylchedd, gan rwystro gosodiadau procs a etifeddwyd rhag disodli ymddygiad bwriadedig y cleient hwn, ac mae hefyd yn analluogi dewis CA bundle Requests yn seiliedig ar yr amgylchedd. Darparwch y CA bundle bwriadedig drwy opsiwn verify y cleient hwn os oes angen.

Mae gan newidynnau amgylchedd a ffurfweddwyd ar gyfer amgylchedd Airflow a reolir gwmpas ehangach a chyfyngiadau a bennir gan y platfform. Mae trosglwyddo'r llwybr i'r sesiwn hon yn cadw'r penderfyniad ynghlwm wrth weithrediad HTTP y dasg hon heb newid os.environ ar gyfer cod arall ym mhroses y gweithiwr.