Google Cloud Composer ত এটা টাস্ক-স্থানীয় Requests প্ৰক্সি

Cloud Composer টাস্ক এটাই যদি প্ৰক্সিৰ মাজেৰে এটা আউটবাউণ্ড HTTP অনুৰোধৰ প্ৰয়োজন হয়, তেন্তে টাস্কটোৰ callable ৰ ভিতৰত HTTP ক্লায়েন্টটো কনফিগাৰ কৰক:

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

DAG ৰ বৰ্তমানৰ টাস্ক বিন্যাসৰ জৰিয়তে এই callable ব্যৱহাৰ কৰক। প্ৰক্সিটো ইয়াক চলোৱা ৱৰ্কাৰৰ পৰা পাব লাগিব। প্ৰক্সি প্ৰমাণীকৰণ নোহোৱাকৈ অনুমোদিত ৰাজহুৱা API কলৰ বাবে HTTP প্ৰক্সি তালিকাই ছেছনৰ HTTP প্ৰক্সি URL ৰ বাবে প্ৰাৰ্থী যোগান ধৰে। প্ৰমাণিত URL বা অন্য একাউণ্ট কনফিগাৰেচন ডিপ্লয়মেণ্টৰ উদ্দেশ্য কৰা গোপন উৎসত ৰাখক।

ফাংচনটো শেষ হ’লে Session আৰু প্ৰতিক্ৰিয়া বন্ধ হয়। trust_env=Falseএ Requests ৰ পৰিৱেশ সংহতি নিষ্ক্ৰিয় কৰে, যাৰ ফলত উত্তৰাধিকাৰী প্ৰক্সি ছেটিংছে এই ক্লায়েন্টৰ উদ্দেশ্য কৰা আচৰণ প্ৰতিস্থাপন কৰিব নোৱাৰে, আৰু Requests ৰ পৰিৱেশ-ভিত্তিক CA bundle নিৰ্বাচনো নিষ্ক্ৰিয় কৰে। প্ৰয়োজন হ’লে এই ক্লায়েন্টৰ verify বিকল্পৰ জৰিয়তে উদ্দেশ্য কৰা CA bundle যোগান ধৰক।

পৰিচালিত Airflow পৰিৱেশৰ বাবে কনফিগাৰ কৰা পৰিৱেশ চলকৰ পৰিসৰ বেছি আৰু প্লেটফৰ্ম-নিৰ্ধাৰিত সীমাবদ্ধতা থাকে। এই Session লৈ ৰুটটো প্ৰেৰণ কৰিলে ৱৰ্কাৰ প্ৰচেছৰ অন্য ক’ডৰ বাবে os.environ সলনি নকৰাকৈ সিদ্ধান্তটো এই টাস্কৰ HTTP কাৰ্যৰ সৈতে সংযুক্ত হৈ থাকে।