Skip to content

angelinauesato/airflow

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

5 Commits
 
 
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

Studies with Airflow

created a docker-compose file with services: Airflow, PostgreSQL, MinIO.
Using Admin -> Connections -> Add Connection (Here I can use to create a connection between Airflow and other services [PostgreSQL, MinIO (AWS Service), Databricks])
1_postgres_connection

Folders:

dags/airflow_connect_db

Screenshot 2026-01-14 at 12 11 19 AM 2_dag_execute_sql

Dag will create a table in Postgres and insert data, all the sql files will be stored in: sql/ directory.

dags/tutorial_load_data/

  1. test_minio_dag
Screenshot 2026-01-14 at 12 16 32 AM Screenshot 2026-01-14 at 12 16 27 AM
Dag will test the connection from Airflow to MinIO, as the button test was failing in the Airflow API.

Screenshot 2026-01-14 at 12 19 02 AM
2. ny_covid_data
Screenshot 2026-01-14 at 12 20 58 AM Screenshot 2026-01-14 at 12 21 02 AM
Dag will read json file from a url, upload the file in MinIO (but, it will check if the file is already in the bucket) and execute some validation with the data.

dags/first_sensor/

  1. dag_s3
    Screenshot 2026-01-14 at 12 25 34 AM Screenshot 2026-01-14 at 12 25 38 AM
    Dag will check if a file arrived inside the bucket.

About

Studies with Apache Airflow. BashOperator, BranchPythonOperator , PythonOperator , PostgresOperator and S3KeySensor

Topics

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

 
 
 

Contributors

Languages