Storytelling with Data
import configparser
import psycopg2
# Config faylini oqish
parser = configparser.ConfigParser()
parser.read("pipeline.conf")
# Redshift ulanish malumotlarini olish
dbname = parser.get("aws_creds", "database")
user = parser.get("aws_creds", "username")
password = parser.get("aws_creds", "password")
host = parser.get("aws_creds", "host")
port = parser.get("aws_creds", "port")
# Redshiftga ulanish
rs_conn = psycopg2.connect(
"dbname=" + dbname
+ " user=" + user
+ " password=" + password
+ " host=" + host
+ " port=" + port
)
# Orders jadvalidagi songgi yangilangan sanani olish
rs_sql = """SELECT COALESCE(MAX(LastUpdated), '1900-01-01') FROM Orders;"""
rs_cursor = rs_conn.cursor()
rs_cursor.execute(rs_sql)
result = rs_cursor.fetchone()
# Natijani olish
last_updated_warehouse = result[0]
# Kursorni yopish
rs_cursor.close()
1 · 670 ·