Ամեն անգամ, երբ փաստաթուղթը տեղադրվում է որոշակի դույլի մեջ, ես ցանկանում եմ սկսել DAG-ի աշխատանքային հոսք այս փաստաթուղթը վերլուծելու համար: Ես պետք է գործարկեմ DAG-ի աշխատանքային հոսքը՝ օգտագործելով ամպային գործառույթները՝ օգտագործելով Ամպ պահեստավորման գործարկիչը և միջոցառման տեսակը Ավարտել և ստեղծել
Ինչպես գործարկել ամպային կոմպոզիտոր DAG-ը՝ օգտագործելով ամպային ֆունկցիան, երբ ֆայլը ավելացվում է ամպային պահեստում՝ Python 3.7-ի միջոցով:
Պատասխանները:
Թարմացում. 2019 թվականի սեպտեմբերի դրությամբ, այժմ գոյություն ունի Python-ի օրինակ փաստաթղթերը և փաստաթղթերի հատվածները կարելի է գտնել GitHub:
Նայեք այս փաստաթղթին, որը ցույց է տալիս, թե ինչպես գործարկել DAG-ը՝ օգտագործելով Google Cloud Functions-ը և ձեր ընտրած դույլը Finalize/Create միջոցառման ժամանակ
[Խմբագրվել է Python-ի հատուկ մանրամասներ ավելացնելու համար]
Քանի որ ձեզ Python-ի կարիք կա, և այս փաստաթուղթը NodeJS-ի համար է, այժմ դուք պետք է ինքնուրույն կատարեք հարմարվողականությունը: Composer-ում Airflow-ի API-ի զանգերն անցնում են ինքնության իմացող վստահված անձի միջոցով (տես այս դիագրամը, որը նույնպես ցուցադրված է ստորև, ավելի մանրամասն տեղեկությունների համար), և, հետևաբար, ձեր գրառման հարցումը DAG-ն գործարկելու համար նույնպես պետք է անցնի ինքնությունը տեղյակ վստահված անձի միջոցով:
Բարեբախտաբար, կա հիանալի Python օրինակ python-docs-samples նմուշի ռեպո-ում IAP-ին գրառման հարցում կատարելու համար: Եթե դուք պատճենեք այդ սկրիպտը ձեր ռեպո մեջ և ստացեք ձեր հաճախորդի ID-ն՝ օգտագործելով նույն քայլերը NodeJS-ի համար (այս սկրիպտը), այն պետք է գործարկի DAG-ը ճիշտ այնպես, ինչպես NodeJS-ը: