Data Engineering'e Giriş
Vincent Vankrunkelsven
Data Engineer, DataCamp
Analitik

Uygulamalar

Analitik

Uygulamalar

Yoğun Paralel İşlem (MPP) Veritabanları

Dosyadan sütunlu depolama biçimine yükle
# Pandas .to_parquet() method
df.to_parquet("s3://path/to/bucket/customer.parquet")
# PySpark .write.parquet() method
df.write.parquet("s3://path/to/bucket/customer.parquet")
COPY customer
FROM 's3://path/to/bucket/customer.parquet'
FORMAT as parquet
...
pandas.to_sql()
# Veride dönüşüm
recommendations = transform_find_recommendatins(ratings_df)
# PostgreSQL veritabanına yükle
recommendations.to_sql("recommendations",
db_engine,
schema="store",
if_exists="replace")
Data Engineering'e Giriş