Skip to content

Instantly share code, notes, and snippets.

View Kamparia's full-sized avatar
Working from home

Olaoye Anthony Somide Kamparia

Working from home
View GitHub Profile
Kamparia /
Last active December 15, 2020 22:30
Data Pipeline With Apache Airflow
import requests
from datetime import datetime, timedelta
from airflow import DAG
from airflow.models import Variable
from airflow.operators.python_operator import PythonOperator
from airflow.operators.postgres_operator import PostgresOperator
from airflow.hooks.postgres_hook import PostgresHook
from airflow.contrib.operators.slack_webhook_operator import SlackWebhookOperator