په Google Cloud Composer کې د دندې لپاره محلي Requests پروکسي

که چېرې یوه Cloud Composer دنده اړتیا لري چې یو بهرنی HTTP غوښتنه د پروکسي له لارې ولېږي، نو HTTP کلاینټ د دندې د callable دننه تنظیم کړئ:

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

دا callable د DAG د موجوده دندې ترتیباتو له لارې وکاروئ. پروکسي باید د هغه worker له خوا چې دنده پرمخ وړي د لاسرسي وړ وي. د اجازه ورکړل شوو عامه API غوښتنو لپاره چې پروکسي تصدیق ته اړتیا نه لري، د HTTP پروکسي لیست د غونډې د HTTP پروکسي URL لپاره نوماندان برابروي. تصدیق شوی URL یا بله حسابي ترتیبات د ځای پرځای کولو په ټاکل شوي پټ سرچینه کې وساتئ.

کله چې فنکشن پای ته ورسېږي، Session او ځواب بندېږي. trust_env=False د Requests د چاپېریال ادغام نابشپړوي، او د پاتې شوو پروکسي تنظیماتو مخه نیسي چې د دې کلاینټ ټاکل شوی چلند بدل کړي، او همدارنګه د Requests د چاپېریال پر بنسټ د CA بنډل ټاکنه نابشپړوي. که اړتیا وي، ټاکل شوی CA بنډل د دې کلاینټ د verify انتخاب له لارې ورکړئ.

د مدیریت شوي Airflow چاپېریال لپاره تنظیم شوي چاپېریالي متغیرونه پراخه حد او د پلیټفارم ټاکل شوې محدودیتونه لري. لارې ته دې Session ته سپارل پریکړه د دې دندې HTTP عملیاتو پورې تړلې ساتي او د worker پروسې په نورو کوډونو کې os.environ نه بدلوي.