Google Cloud Composer-en zereginerako tokiko Requests proxy bat

Proxy baten bidez irteerako HTTP eskaera bat behar duen Cloud Composer zeregin baterako, konfiguratu HTTP bezeroa zereginaren callable barruan:

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

Erabili callable hau DAGaren uneko zeregin antolamenduaren bidez. Proxyak berau exekutatzen duen workerretik irisgarria izan behar du. Proxy autentifikaziorik gabeko API publikoen baimendutako deietarako, HTTP proxy zerrendak hautagaiak eskaintzen ditu saioaren HTTP proxy URLrako. Mantendu autentifikatutako URL bat edo beste kontu konfigurazio bat hedapenarentzat aurreikusitako sekretu iturburuan.

Saioa eta erantzuna funtzioa amaitzean ixten dira. trust_env=False aukerak Requestsen ingurune integrazioa desgaitzen du, heredatutako proxy ezarpenek bezero honen aurreikusitako portaera ordez ez dezaten, eta Requestsen ingurunean oinarritutako CA bundle hautaketa ere desgaitzen du. Beharrezkoa bada, eman aurreikusitako CA bundle-a bezero honen verify aukeraren bidez.

Airflow ingurune kudeatu baterako konfiguratutako ingurune aldagaiek irismen handiagoa eta plataformak zehaztutako murriztapenak dituzte. Bidea saio honi pasatzeak erabakia zeregin honen HTTP eragiketari lotuta mantentzen du, worker prozesuko beste koderako os.environ aldatu gabe.