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