دوره آموزشی یادگیری Apache Airflow
2 ساعت 54 دقیقهپیشرفته2026-06-16
مدرسین
Janani Ravi
Certified Google Cloud Architect and Data Engineer
جزئیات دوره
در این دوره، جنانی راوی (Janani Ravi)، معمار ابری گوگل و مهندس داده، شما را با Apache Airflow آشنا میکند؛ یکی از محبوبترین پلتفرمهای متنباز برای طراحی، زمانبندی و مانیتورینگ گردشکارهای داده و پردازشهای دستهای (Batch Workflows).
Apache Airflow به شما امکان میدهد وظایف مختلف یک فرآیند پردازشی را بهصورت برنامهنویسیشده در Python تعریف کنید، وابستگی بین آنها را مشخص نمایید و اجرای کل فرآیند را بهصورت خودکار مدیریت کنید.
در این دوره یاد میگیرید چگونه Workflowها را در Airflow ایجاد و اجرا کنید، وظایف (Tasks) مختلف را تعریف نمایید و روابط وابستگی میان آنها را مدیریت کنید. همچنین با اپراتورهای Python و SQLite آشنا میشوید و نحوه استفاده از آنها در ساخت Pipelineهای داده را فرا میگیرید.
علاوه بر این، مفاهیم مهمی مانند Conditional Branching برای تصمیمگیری در مسیر اجرای Workflowها و همچنین قابلیتهای Catchup و Backfill برای اجرای دادههای گذشته و بازیابی پردازشهای از دست رفته را یاد خواهید گرفت.
این دوره برای مهندسان داده، متخصصان ETL، مهندسان DevOps، تحلیلگران داده و افرادی که قصد ورود به حوزه Data Engineering را دارند بسیار مناسب است.
🎯 اهداف یادگیری
آشنایی با معماری و مفاهیم Apache Airflow
درک نقش Airflow در مهندسی داده و اتوماسیون Workflowها
ایجاد و اجرای Workflow در Apache Airflow
تعریف Taskها در Airflow
مدیریت وابستگیها میان وظایف مختلف
استفاده از Python برای تعریف Pipelineها
کار با Python Operator در Airflow
کار با SQLite Operator در Airflow
طراحی و مدیریت Data Pipelineها
زمانبندی اجرای فرآیندها
مانیتورینگ و نظارت بر Workflowها
مدیریت اجرای خودکار وظایف
پیادهسازی Conditional Branching
طراحی مسیرهای اجرایی شرطی
درک مفهوم DAG در Airflow
مدیریت اجرای Workflowهای پیچیده
استفاده از قابلیت Catchup
استفاده از قابلیت Backfill
بازیابی پردازشهای از دست رفته
مدیریت گردشکارهای داده در محیطهای واقعی
Apache Airflow به شما امکان میدهد وظایف مختلف یک فرآیند پردازشی را بهصورت برنامهنویسیشده در Python تعریف کنید، وابستگی بین آنها را مشخص نمایید و اجرای کل فرآیند را بهصورت خودکار مدیریت کنید.
در این دوره یاد میگیرید چگونه Workflowها را در Airflow ایجاد و اجرا کنید، وظایف (Tasks) مختلف را تعریف نمایید و روابط وابستگی میان آنها را مدیریت کنید. همچنین با اپراتورهای Python و SQLite آشنا میشوید و نحوه استفاده از آنها در ساخت Pipelineهای داده را فرا میگیرید.
علاوه بر این، مفاهیم مهمی مانند Conditional Branching برای تصمیمگیری در مسیر اجرای Workflowها و همچنین قابلیتهای Catchup و Backfill برای اجرای دادههای گذشته و بازیابی پردازشهای از دست رفته را یاد خواهید گرفت.
این دوره برای مهندسان داده، متخصصان ETL، مهندسان DevOps، تحلیلگران داده و افرادی که قصد ورود به حوزه Data Engineering را دارند بسیار مناسب است.
🎯 اهداف یادگیری
آشنایی با معماری و مفاهیم Apache Airflow
درک نقش Airflow در مهندسی داده و اتوماسیون Workflowها
ایجاد و اجرای Workflow در Apache Airflow
تعریف Taskها در Airflow
مدیریت وابستگیها میان وظایف مختلف
استفاده از Python برای تعریف Pipelineها
کار با Python Operator در Airflow
کار با SQLite Operator در Airflow
طراحی و مدیریت Data Pipelineها
زمانبندی اجرای فرآیندها
مانیتورینگ و نظارت بر Workflowها
مدیریت اجرای خودکار وظایف
پیادهسازی Conditional Branching
طراحی مسیرهای اجرایی شرطی
درک مفهوم DAG در Airflow
مدیریت اجرای Workflowهای پیچیده
استفاده از قابلیت Catchup
استفاده از قابلیت Backfill
بازیابی پردازشهای از دست رفته
مدیریت گردشکارهای داده در محیطهای واقعی
سرفصل ها
مقدمه
- مروری بر Apache Airflow
معرفی آپاچی ایرفلو
- مفاهیم جریان هوای آپاچی
- معماری جریان هوا
- کاربران ویندوز - نصب WSL2
- کاربران ویندوز و macOS - نصب Airflow
- اجرای جریان هوا به صورت مستقل
اجرای گردشهای کاری روی جریان هوا
- پیمایش و کاوش در رابط کاربری Airflow
- اجرای یک نمونه DAG
- ایجاد اولین DAG شما
- اجرای اولین DAG شما
- ایجاد یک DAG با استفاده از کلمه کلیدی with
تعریف وظایف و وابستگیها
- تعیین وابستگیهای وظایف
- استفاده از عملگر bitshift برای تعیین وابستگی
- استفاده از اسکریپتهای bash در DAG
- پاک کردن وضعیت وظیفه برای اجرای مجدد وظایف
اجرای وظایف مبتنی بر پایتون
- معرفی عملگر پایتون
- عملگرها و وابستگیهای پایتون
- ارسال پارامترها به توابع قابل فراخوانی پایتون
- تزریق زمینه وظیفه
- معرفی ایکسکام
- دسترسی به مقادیر در XCom
- دسترسی به مقادیر در XCom با استفاده از کلیدهای سفارشی
- پیادهسازی خط لوله DAG تبدیل داده - بخش اول
- پیادهسازی خط لوله DAG تبدیل داده - بخش دوم
اجرای کوئریهای SQL در وظایف
- راهاندازی پایگاه داده SQLite و اتصال
- معرفی SQLExecuteQueryOperator
- پیادهسازی خط لوله DAG مبتنی بر SQL بخش اول
- پیادهسازی خط لوله DAG مبتنی بر SQL بخش دوم
شاخهبندی شرطی و گروههای کاری
- معرفی شاخهبندی
- شاخهبندی شرطی با متغیرها
- گروههای کاری و برچسبهای لبه
تنظیمات Catch Up، Backfill، CRON Expressions و Trigger
- به تمام برنامههای از پیش تعیینشدهی خود برسید
- اجرای برنامه ریزی شده خاکریزی
- پیکربندی تاریخهای منطقی
- فاصله زمانی دادهها و پیکربندی اجرا
نتیجهگیری
- خلاصه و مراحل بعدی