NicholasTurner23

#!/usr/bin/env/python

import psycopg2
import os
from io import StringIO
import pandas as pd

# Get a database connection
dsn = os.environ.get('DB_DSN')  # Use ENV vars: keep it secret, keep it safe
conn = psycopg2.connect(dsn)

NicholasTurner23

from datetime import timedelta

# The DAG object; we'll need this to instantiate a DAG
from airflow import DAG
# Operators; we need this to operate!
from airflow.operators.bash_operator import BashOperator
from airflow.utils.dates import days_ago