Skip to content

chuyphun/AirflowDataPipeline

 
 

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

12 Commits
 
 
 
 
 
 
 
 
 
 

Repository files navigation

Origin

This repo is an adaptation from this blog post.

The major changes are

  1. Instead of OpenWeatherMap API, we have chosen Taiwan's Central Weather Bureau's (abbr. CWB) API because in this case we do not need to register credit card information in order to use the API. For more info on CWB, cf.
  2. Python3 and airflow==2.6.3

How to Use This Repo?

Installation

  1. Create a new virtual environment (or use an existing one). Activate it.
    • If you use Miniconda, you can create and activate one such virtual env by
      $ conda create --name airflow_practice python=3.10
      $ conda activate airflow_practice
      The Python version could be anything from 3.7 to 3.11
  2. Install Airflow by copying and pasting the commands below into a terminal
    AIRFLOW_VERSION=2.6.3
    PYTHON_VERSION="$(python --version | cut -d " " -f 2 | cut -d "." -f 1-2)"
    CONSTRAINT_URL="https://raw.githubusercontent.com/apache/airflow/constraints-${AIRFLOW_VERSION}/constraints-${PYTHON_VERSION}.txt"
    pip install "apache-airflow[postgres]==${AIRFLOW_VERSION}" --constraint "${CONSTRAINT_URL}"
  3. Install the remaining packages by
    (airflow_practice) $ pip install -r requirements.txt

About

Example of an ETL Pipeline using Airflow

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages

  • Python 100.0%