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ükleme
# Pandas .to_parquet() yöntemi
df.to_parquet("./s3://path/to/bucket/customer.parquet")
# PySpark .write.parquet() yöntemi
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ükleme
recommendations.to_sql("recommendations",
db_engine,
schema="store",
if_exists="replace")
Data Engineering'e Giriş