Aṣojú Requests tí ó jẹ́ ti iṣẹ́-ẹ̀ka nínú Google Cloud Composer

Fún iṣẹ́-ẹ̀ka Cloud Composer tí ó nílò ìbéèrè HTTP kan tí ó jáde nípasẹ̀ aṣojú, ṣètò ẹ̀rọ HTTP nínú callable iṣẹ́-ẹ̀ka náà:

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

Lo callable yìí nípasẹ̀ ètò iṣẹ́-ẹ̀ka DAG tí ó wà tẹ́lẹ̀. Aṣojú gbọ́dọ̀ jẹ́ àṣeyọrí láti ọ̀dọ̀ worker tí ó ń ṣiṣẹ́ iṣẹ́-ẹ̀ka náà. Fún àwọn ìpè API gbangba tí a gbà láyè láìsí ìjẹ́rìí aṣojú, àkójọ aṣojú HTTP ń pèsè àwọn olùdíje fún URL aṣojú HTTP ti session. Tọ́jú URL tí a jẹ́rìí tàbí ìṣètò àkọsílẹ̀ mìíràn nínú orísun àṣírí tí ìfilọ́lẹ̀ pinnu.

Session àti ìdáhùn ń pa dé nígbà tí iṣẹ́ náà bá parí. trust_env=False ń pa ìsopọ̀ àyíká Requests dé, èyí ń dá àwọn ètò aṣojú tí a jogún dúró láti rọ́pò ìhùwàsí tí a pinnu fún ẹ̀rọ yìí, ó sì tún pa yíyan CA bundle tí ó dá lórí àyíká Requests dé. Bí ó bá yẹ, pèsè CA bundle tí a pinnu nípasẹ̀ àṣàyàn verify ti ẹ̀rọ yìí.

Àwọn oníyípadà àyíká tí a ṣètò fún àyíká Airflow tí a ń ṣàkóso ní ìwọ̀n tí ó gbòòrò sí i àti àwọn ìdíwọ́ tí pẹpẹ pinnu. Pípa ọ̀nà náà fún Session yìí ń jẹ́ kí ìpinnu dúró lórí iṣẹ́ HTTP ti iṣẹ́-ẹ̀ka yìí láìyí os.environ fún kòòdù mìíràn nínú ìlànà worker.