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

كتابة دالة load في helper.py

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

تعمل وظيفة ...