Getting Started with Airflow for Beginners

Sdílet
Vložit
  • čas přidán 18. 05. 2024
  • Getting Started with Airflow for Beginners.
    At the end of this video, you will be able to:
    ✅ Identify the different ways of installing and running Airflow in local
    ✅ Create a local dev environment with Airflow following best practices
    ✅ Create data pipelines using Variables, XComs, and the Taskflow API
    ✅ Share data between tasks
    ✅ Trigger and monitor data pipelines
    and more.
    🏆 BECOME A PRO WITH AIRFLOW: www.udemy.com/course/the-comp...
    If you're entirely new to Apache Airflow, take a look at those videos first:
    1️⃣ Why Airflow? The Top 5 reasons to use it: • Why Airflow? The Top 5...
    2️⃣ What is Apache Airflow?: • What is Apache Airflow...
    00:00 Introduction
    00:28 Install and setup Airflow in local
    00:38 Pip install
    00:57 The docker-compose file
    01:51 The Astro CLI
    03:46 Airflowctl
    04:17 Reminder of the basics
    04:30 The DAG you will create
    05:00 Create the DAG
    07:08 Create the first task
    08:55 Create the second task
    09:24 Airflow variables
    10:55 Create the last task
    11:15 Define task dependencies
    12:35 The final DAG
    13:05 Run it!
    13:33 Use the UI to monitor and manage your DAGs
    With that, you have all the keys to getting started with Airflow!

Komentáře • 12

  • @kirillfedorov7595
    @kirillfedorov7595 Před 7 měsíci +2

    Today I watched the entire playlist without a break, you have a talent for explaining! Thank you. Also, perhaps the last two videos would be better placed at the beginning of the playlist.

  • @buddhabob359
    @buddhabob359 Před 7 měsíci +1

    Many thanks for the video ; great tutorial !
    I have a question regarding Airflow though ; I keep seeing DAG file where task functions are defined directly into the DAG file.
    What if I want to import functions from python scripts from other Repositories ? How can I call them in my DAG file ?
    I plan to use Airflow to run many scripts I have deployed on various Git repositories.
    I don't want to recreate those already existing functions into my DAG file but just call those scripts with their functions in my Airflow repository.
    Any idea how can I achieve that ?
    Many thanks and keep up making great videos ! ;)

    • @joshualobo220
      @joshualobo220 Před 3 měsíci

      I think you would need to import the functions (defined in the external repositories )and decorate them with the "@task" decorator to make them tasks within your dag

  • @sophialawal7306
    @sophialawal7306 Před 6 měsíci

    Thank you the video is really help full

  • @2998sebastian
    @2998sebastian Před 7 měsíci

    Great video Marc! But why doesn't Visual Studio Code recognize the Airflow library even though I'm running my containers correctly? I've noticed that you're experiencing the same issue because the 'airflow.decorators' library is underlined in yellow. Is there a way to fix this?

    • @MarcLamberti
      @MarcLamberti  Před 7 měsíci +2

      Yup, will make a video about that but you need to connect VS to your containers running Airflow 🥹

  • @0kazaki
    @0kazaki Před 7 měsíci

    Using tempfile module from python, can I create a temporay directory associated with a DAG RUN that will be automatically deleted at the end of a DAG RUN regardless if the DAG RUN was successful or failure or otherwise?

    • @MarcLamberti
      @MarcLamberti  Před 7 měsíci +1

      Yes, two options:
      - trigger rules
      - setup and teardown tasks (this one better)

    • @0kazaki
      @0kazaki Před 7 měsíci

      @@MarcLamberti can I set teardown to only run on dag failure?

  • @Incomingsign
    @Incomingsign Před 7 měsíci +1

    i have setup airflow with docker using astro cli. how to make code suggestion work in vscode?