Cost optimization for cloud resources in Apache Airflow - Step-by-Step Execution

Process Flow - Cost optimization for cloud resources

Identify Cloud Resources

↓

Analyze Usage & Costs

↓

Find Idle/Underused Resources

↓

Apply Optimization Actions

↓

Monitor & Repeat

This flow shows how to optimize cloud costs by identifying resources, analyzing usage, finding waste, applying fixes, and monitoring continuously.

Execution Sample

Apache Airflow

from airflow import DAG
from airflow.operators.python import PythonOperator
from datetime import datetime

def optimize_costs():
    print('Checking idle resources and shutting down...')

with DAG('cost_optimization', start_date=datetime(2024,1,1), schedule_interval='@daily') as dag:
    task = PythonOperator(task_id='optimize', python_callable=optimize_costs)

This Airflow DAG runs daily to check and optimize cloud resource costs by shutting down idle resources.

Process Table

Step	Action	Evaluation	Result
1	DAG starts at scheduled time	Current time matches schedule	DAG triggered
2	Run optimize_costs function	Check cloud resources usage	Idle resources found: 2 VMs
3	Shut down idle VMs	Send shutdown commands	2 VMs stopped
4	Log optimization result	Print confirmation	Output: 'Checking idle resources and shutting down...'
5	DAG run completes	All tasks done	DAG success

💡 All idle resources processed, DAG run ends successfully

Status Tracker

Variable	Start	After Step 2	After Step 3	Final
idle_resources	None	2 VMs identified	0 (after shutdown)	0

Key Moments - 2 Insights

Why do we check for idle resources before shutting down?

Because shutting down active resources would disrupt services. The execution_table step 2 shows we identify idle resources first to avoid this.

What happens if no idle resources are found?

The shutdown step would skip or do nothing. The DAG would still complete successfully as shown in the exit_note.

Visual Quiz - 3 Questions

Look at the execution_table, what is the output printed during the DAG run?

A 'Starting cloud resource analysis'

B 'No idle resources found'

C 'Checking idle resources and shutting down...'

D 'DAG failed due to error'

💡 Hint

Check execution_table row 4 for the printed output

At which step are idle resources identified?

A Step 2

B Step 1

C Step 3

D Step 5

💡 Hint

Look at execution_table row 2 where idle resources are found

If no idle VMs were found, what would be the value of 'idle_resources' after step 2 in variable_tracker?

A 2 VMs identified

B 0

C None

D Error

💡 Hint

Variable_tracker shows 'idle_resources' after step 2; if none found, it would be zero

Concept Snapshot

Cost optimization for cloud resources in Airflow:
- Schedule DAG to run regularly
- Identify idle or underused resources
- Shut down or resize these resources
- Log actions for audit
- Monitor continuously for savings

Full Transcript

This visual execution shows how an Airflow DAG can help optimize cloud costs. The DAG runs daily, checks for idle cloud resources like virtual machines, and shuts them down to save money. We track variables like idle_resources to see how many are found and stopped. Key moments include why we identify idle resources first to avoid stopping active ones, and what happens if no idle resources exist. The quiz tests understanding of the steps and variable changes. This approach helps keep cloud spending efficient by automating cleanup tasks.