Membangun fungsi untuk mengekstrak data
Penting untuk memodularisasi kode saat membangun pipeline data. Ini membantu membuat pipeline lebih mudah dibaca dan digunakan kembali, serta dapat mempercepat upaya penelusuran masalah. Membuat dan menggunakan fungsi untuk operasi yang berbeda dalam sebuah pipeline juga dapat membantu saat memulai proyek baru dengan menyediakan kerangka kerja untuk memulai pengembangan.
pandas telah diimpor sebagai pd, dan sqlalchemy siap digunakan.
Latihan ini adalah bagian dari kursus
ETL dan ELT di Python
Latihan interaktif praktis
Cobalah latihan ini dengan menyelesaikan kode contoh berikut.
def extract():
# Create a connection URI and connection engine
connection_uri = "postgresql+psycopg2://repl:password@localhost:____/____"
db_engine = sqlalchemy.____(connection_uri)