I-Requests proxy yendawo yomsebenzi ku-Google Cloud Composer

Dala i-Requests Session yendawo yomsebenzi enomzila ocacile esikhundleni sokushintsha indawo ye-proxy yohlelo lwe-worker olwabiwe.

Ngomsebenzi we-Cloud Composer odinga isicelo se-HTTP esisodwa sokuphuma nge-proxy, lungiselela iklayenti le-HTTP ngaphakathi kwe-callable yomsebenzi:

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

Sebenzisa le callable ngokuhlelo lwemisebenzi olukhona lwe-DAG. I-proxy kufanele ifinyeleleke kusuka ku-worker osebenzisa umsebenzi. Ezingxoxweni ze-API zomphakathi ezivunyelwe ngaphandle kokuqinisekiswa kwe-proxy, uhlu lwe-proxy ye-HTTP lunikeza abazongenela i-HTTP proxy URL yesikhathi. Gcina i-URL eqinisekisiwe noma okunye ukulungiselela kwe-akhawunti emthonjeni wemfihlo ohlosiwe wokuthunyelwa.

I-Session nempendulo ziyavalwa lapho umsebenzi uphela. I-trust_env=False ivimbela ukuhlanganiswa kwe-Requests nendawo, ukuze izilungiselelo ze-proxy ezizuzwe njengefa zingashintshi indlela elindelekile yaleli klayenti, futhi ivale nokukhethwa kwe-CA bundle kwe-Requests okusekelwe endaweni. Uma kudingeka, nikeza i-CA bundle ehlosiwe ngokukhetha kwe-verify yaleli klayenti.

Izinto eziguqukayo zendawo ezilungiselelwe indawo ye-Airflow ephethwe zinendawo ebanzi kanye nemikhawulo echazwe yipulatifomu. Ukudlulisela umzila kule Session kugcina isinqumo sixhunyaniswe nomsebenzi we-HTTP walo msebenzi ngaphandle kokushintsha i-os.environ kwezinye izinhlelo ezikuhlelo lwe-worker.

Izihloko ezihlobene