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