Skip to content

Instantly share code, notes, and snippets.

View DDSNA's full-sized avatar

Dan DDSNA

View GitHub Profile
from datetime import datetime
from airflow import DAG
from airflow.decorators import dag, task
from sqlalchemy import create_engine, select
import pandas as pd
import psycopg2
import openpyxl as xl
from openpyxl.chart import BarChart, reference
def process_workbook(filename):
wb = xl.load_workbook(filename)
sheet = wb["Sheet1"]
for row in range (2, sheet.max_row +1):
cell=sheet.cell(row, 3)
corrected_price = cell.value*0.9