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
Kamparia / usgs_harvester_dag.py
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