مثال على خط أنابيب ETL: التحميل
تعلم كيفية إضافة وظيفة التحميل إلى Airflow DAG.
سنغطي ما يلي...
سنغطي ما يلي...
كتابةload
وظيفة فيhelper.py
الآن وقد أصبح لدينا ملف CSV نظيف ومُحوّل، يُمكننا التركيز على مرحلة تحميل خط أنابيب ETL. كالعادة، سنكتب دالة تُسمىload
فيhelper.py
الملف. لاحقًا، سنستخدم هذه الوظيفة كجزء من DAG.
ال ...