Managed Airflow (MWAA, Cloud Composer, Astronomer) - Interactive Code Practice

Practice - 5 Tasks

1fill in blank

easy

Complete the code to import the DAG class from Airflow.

Apache Airflow

from airflow.[1] import DAG

Drag options to blanks, or click blank then click option'

Amodels

Boperators

Chooks

Dsensors

Attempts:

3 left

💡 Hint

Common Mistakes

Importing DAG from operators or hooks instead of models.

The DAG class is imported from the models module in Airflow.

2fill in blank

medium

Complete the code to set the schedule interval for a DAG to run daily.

Apache Airflow

dag = DAG('example_dag', schedule_interval=[1])

Drag options to blanks, or click blank then click option'

A'@once'

B'@daily'

C'@weekly'

D'@hourly'

Attempts:

3 left

💡 Hint

Common Mistakes

Using '@hourly' or '@weekly' instead of '@daily'.

The schedule_interval set to '@daily' makes the DAG run once every day.

3fill in blank

hard

Fix the error in the task definition by completing the operator import.

Apache Airflow

from airflow.operators.[1] import BashOperator

Drag options to blanks, or click blank then click option'

Aemail

Bdummy

Cpython

Dbash

Attempts:

3 left

💡 Hint

Common Mistakes

Importing BashOperator from python or dummy modules.

The BashOperator is imported from the bash module inside operators.

4fill in blank

hard

Fill both blanks to create a task that runs a bash command in the DAG.

Apache Airflow

task1 = [1](task_id='print_date', bash_command=[2], dag=dag)

Drag options to blanks, or click blank then click option'

ABashOperator

B'date'

C'echo Hello World'

DPythonOperator

Attempts:

3 left

💡 Hint

Common Mistakes

Using PythonOperator instead of BashOperator.

Using wrong bash command string.

The task uses BashOperator and runs the 'date' command.

5fill in blank

hard

Fill all three blanks to define a DAG with default args and a Python task.

Apache Airflow

from datetime import datetime
default_args = {'owner': [1], 'start_date': [2]
dag = DAG('my_dag', default_args=default_args, schedule_interval='@daily')
def my_task():
    print('Hello Airflow')
task = [3](task_id='print_hello', python_callable=my_task, dag=dag)

Drag options to blanks, or click blank then click option'

A'airflow_user'

Bdatetime(2023, 1, 1)

CPythonOperator

DBashOperator

Attempts:

3 left

💡 Hint

Common Mistakes

Using BashOperator for a Python task.

Wrong format for start_date.

Owner not a string.

The owner is a string, the start_date is a datetime object, and the task uses PythonOperator to run Python code.

Practice

1. What is the main advantage of using a managed Airflow service like AWS MWAA or Google Cloud Composer?

easy

A. You don't need to manage the Airflow servers yourself.

B. You write DAGs in a new proprietary language.

C. You must manually install Airflow updates.

D. You cannot customize your workflows.

Solution

1. Step 1: Understand managed Airflow services

   Managed Airflow services handle the infrastructure and server management for you.

2. Step 2: Compare options

   The other options are incorrect because managed services still use Python DAGs, handle updates automatically, and allow workflow customization.

3. Final Answer:

   You don't need to manage the Airflow servers yourself. -> Option A

4. Quick Check:

   Managed Airflow = No server management [OK]

Hint: Managed means no server setup needed [OK]

Common Mistakes:

• Thinking you must manage Airflow servers manually
• Believing DAGs use a new language
• Assuming no workflow customization is possible

2. Which of the following is the correct way to upload your DAGs to AWS MWAA?

easy

A. Upload DAG files to an S3 bucket linked to MWAA.

B. SSH into the MWAA server and copy DAG files.

C. Use FTP to transfer DAG files to MWAA.

D. Email DAG files to AWS support.

Solution

1. Step 1: Identify MWAA DAG upload method

   AWS MWAA uses an S3 bucket to store DAG files that it reads automatically.

2. Step 2: Eliminate incorrect methods

   SSH and FTP are not supported because MWAA is fully managed and does not expose servers. Emailing files is not a valid method.

3. Final Answer:

   Upload DAG files to an S3 bucket linked to MWAA. -> Option A

4. Quick Check:

   MWAA DAGs stored in S3 bucket [OK]

Hint: MWAA DAGs live in S3 buckets [OK]

Common Mistakes:

• Trying to SSH into MWAA servers
• Using FTP which is unsupported
• Thinking AWS support manages DAG uploads

3. Given this snippet of a DAG uploaded to Google Cloud Composer, what will happen when the DAG runs?

from airflow import DAG
from airflow.operators.bash import BashOperator
from datetime import datetime
with DAG('example_dag', start_date=datetime(2024, 1, 1), schedule_interval='@daily') as dag:
    task1 = BashOperator(task_id='print_date', bash_command='date')
    task2 = BashOperator(task_id='sleep', bash_command='sleep 5')
    task1 >> task2

medium

A. The DAG runs once and fails due to syntax error.

B. The DAG runs daily but skips the sleep task.

C. The DAG runs daily but tasks run in parallel.

D. The DAG runs daily, printing the date then sleeping for 5 seconds.

Solution

1. Step 1: Analyze DAG schedule and tasks

   The DAG is scheduled daily starting Jan 1, 2024. It has two tasks: print_date and sleep.

2. Step 2: Understand task dependencies

   task1 >> task2 means task1 runs before task2. So print_date runs first, then sleep runs for 5 seconds.

3. Final Answer:

   The DAG runs daily, printing the date then sleeping for 5 seconds. -> Option D

4. Quick Check:

   schedule=@daily; task1 >> task2 [OK]

Hint: >> means run first task before second [OK]

Common Mistakes:

• Assuming tasks run in parallel
• Thinking the DAG has syntax errors
• Believing the sleep task is skipped

4. You deployed a DAG to Astronomer but it does not appear in the Airflow UI. What is the most likely cause?

medium

A. Astronomer does not support Python DAGs.

B. The DAG file has a syntax error preventing it from loading.

C. You need to restart the Astronomer platform manually.

D. The DAG file is too large to upload.

Solution

1. Step 1: Check DAG loading requirements

   Astronomer runs standard Airflow and requires valid Python DAG files to load and show in UI.

2. Step 2: Identify common loading issues

   If the DAG has syntax errors, Airflow will skip loading it, so it won't appear in the UI.

3. Final Answer:

   The DAG file has a syntax error preventing it from loading. -> Option B

4. Quick Check:

   Syntax errors block DAG loading [OK]

Hint: Syntax errors hide DAGs in UI [OK]

Common Mistakes:

• Thinking Astronomer doesn't support Python DAGs
• Assuming manual restart is needed
• Believing file size blocks upload

5. You want to ensure your DAG in AWS MWAA uses a custom Python package not included by default. What is the best way to add this package?

hard

A. Include the package code inside your DAG Python file.

B. Manually install the package on the MWAA server via SSH.

C. Create a requirements.txt file with the package and upload it to the MWAA environment.

D. Request AWS support to install the package for you.

Solution

1. Step 1: Understand MWAA custom package installation

   MWAA allows adding Python packages by uploading a requirements.txt file listing them.

2. Step 2: Eliminate incorrect options

   SSH access is not allowed, embedding package code in DAG is bad practice, and AWS support does not install packages on demand.

3. Final Answer:

   Create a requirements.txt file with the package and upload it to the MWAA environment. -> Option C

4. Quick Check:

   requirements.txt is standard for MWAA packages [OK]

Hint: Use requirements.txt to add packages in MWAA [OK]

Common Mistakes:

• Trying to SSH into MWAA servers
• Embedding package code inside DAG files
• Expecting AWS support to install packages