Search⌘ K

مثال على خط أنابيب ETL: التحميل

تعلم كيفية إضافة وظيفة التحميل إلى Airflow DAG.

كتابةload وظيفة فيhelper.py

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

ال ...