Тёмный

Dynamically Generating DAGs in Airflow 

Astronomer
Подписаться 5 тыс.
Просмотров 13 тыс.
50% 1

Since the release of dynamic task mapping in Airflow 2.3, many of the concepts in this webinar have been changed and improved upon. Please check out our newer Dynamic Tasks in Airflow webinar for the latest dynamic dag best practices, including how dynamic tasks can accomplish many of the same use cases more efficiently.
The simplest way of creating an Airflow DAG is to write it as a static Python file. However, sometimes manually writing DAGs isn't practical.
Maybe you have hundreds or thousands of DAGs that do similar things, with just a parameter changing between them. Or maybe you need a set of DAGs to load tables, but don't want to manually update DAGs every time those tables change. In these cases, and others, it can make more sense to dynamically generate DAGs. Because everything in Airflow is code, you can dynamically generate DAGs using Python alone.
In this webinar, we'll talk about when you might want to dynamically generate your DAGs, show a couple of methods for doing so, and discuss problems that can arise when implementing dynamic generation at scale.
In this webinar we cover:
- How Airflow identifies a DAG
- Use cases for dynamically generating DAGs
- Commonly used methods for dynamic generation
- Pitfalls and common issues with dynamic generation
Want to become an airflow expert? Check out our guide: www.astronomer.io/guides
#learnwithastronomer #dags #dynamicdags

Опубликовано:

 

5 июл 2024

Поделиться:

Ссылка:

Скачать:

Готовим ссылку...

Добавить в:

Мой плейлист
Посмотреть позже
Комментарии : 14   
@magicgoku
@magicgoku Год назад
Finally dynamic DAG creation made simple in this video! Thank you!
@Astronomer
@Astronomer Год назад
Glad it was helpful!
@talnagar
@talnagar 3 года назад
thanks for the great talk. We'll be happy to hear more about dynamic tasks creation, especially ones that are effected from the results of previous tasks in the DAG.
@joshuaisland501
@joshuaisland501 2 года назад
Really useful and very clearly explained. Thanks!
@mobeenmehdi8722
@mobeenmehdi8722 2 года назад
Thanks for this great content. Much Appreciated :)
@felipegsantos
@felipegsantos 2 года назад
Thanks for the talk, great content.
@jayeshprimomahajan6787
@jayeshprimomahajan6787 2 года назад
This was helpful. Thanks
@Astronomer
@Astronomer Год назад
Glad it was helpful!
@397rohit
@397rohit 3 года назад
Thank you so much This is what i was looking for Can we have more sessions like these?
@TheKaluve
@TheKaluve 2 года назад
thank you for this tutorial ! I followed the 1st method of generating the DAGs (single file) and I see the DAGs being generated on the UI but when I try to run it, I see an error from the executor which says "airflow.exceptions.AirflowException: dag_id could not be found: . Either the dag did not exist or it failed to parse." Even though the code below adds the dag to the global scope, I am wondering why it is NOT able to find the dag that has been generated when I try to run it: globals()[dag_id] = create_dag(dag_id, schedule, dag_number, default_args) I am not able to figure out why the executor is NOT able to find the dag that has been generated.
@akshaymonga
@akshaymonga 3 года назад
thank you
@shiva_310r6
@shiva_310r6 2 года назад
Is there any wat to get list of dag id using python ?
@fanzhang8823
@fanzhang8823 Год назад
I saved all dags, each dag has multiple tasks with dependency definition into a single config file, each dag has its own scheduler, each task has this own customer handler. I could dynamically all dags pretty well. Only challenge is my tasks in dags are queued even I put None or @once for schedule_interval
@Astronomer
@Astronomer Год назад
Hmmmm, are you manually triggering the dags?
Далее
Best Practices For Writing DAGs In Airflow 2
46:24
Просмотров 9 тыс.
Intro To Data Orchestration With Airflow
53:56
Просмотров 8 тыс.
你们会选择哪一辆呢#short #angel #clown
00:20
HOW DID SHE WIN??
00:49
Просмотров 15 млн
Лайфхак с колой не рабочий
00:16
Просмотров 604 тыс.
Getting Started With the Official Airflow Helm Chart
1:00:19
Dynamic Tasks in Airflow
53:56
Просмотров 8 тыс.
TaskFlow API in Airflow 2.0
56:27
Просмотров 11 тыс.
Scheduling in Airflow
54:23
Просмотров 10 тыс.
Deep dive in to the Airflow scheduler
43:06
Просмотров 13 тыс.
DAG Writing Best Practices in Apache Airflow
56:45
Просмотров 11 тыс.
Airflow 101: Essential Tips For Beginners
52:12
Просмотров 6 тыс.
你们会选择哪一辆呢#short #angel #clown
00:20