دوره آموزشی مدیریت پایپلاینهای مهندسی داده با Apache Airflow
2 ساعت 52 دقیقهمتوسط2026-07-20
مدرسین
Janani Ravi
Certified Google Cloud Architect and Data Engineer
جزئیات دوره
مدیریت و ارکستراسیون Pipelineهای داده (Data Engineering Pipelines) یکی از مهمترین مهارتها در مهندسی داده مدرن است؛ جایی که سازمانها برای پردازش حجم گستردهای از اطلاعات، به Workflowهای قابل اعتماد، مقیاسپذیر و خودکار نیاز دارند. Apache Airflow بهعنوان یکی از محبوبترین پلتفرمهای مدیریت گردشکار داده (Data Workflow Orchestration)، به تیمهای مهندسی داده امکان میدهد فرآیندهای پیچیده پردازش، انتقال و زمانبندی داده را به شکل ساختاریافته مدیریت کنند.
این دوره یک مسیر جامع برای یادگیری مدیریت حرفهای Pipelineهای داده با Apache Airflow ارائه میدهد و شما را با قابلیتهای پیشرفته این ابزار برای طراحی، ایمنسازی و مقیاسدهی Workflowهای داده آشنا میکند. در طول دوره، یاد میگیرید چگونه دسترسی کاربران را با استفاده از کنترل دسترسی مبتنی بر نقش (Role-Based Access Control - RBAC) مدیریت کنید تا عملیات Pipelineها بهصورت امن و کنترلشده انجام شوند.
در این دوره، مفاهیم مهمی مانند مدیریت زمان اجرای وظایف (Execution Timeouts)، کنترل Deadlineها و بهینهسازی زمانبندی Workflowها بررسی میشوند تا بتوانید Pipelineهایی سریعتر، دقیقتر و قابل اطمینانتر ایجاد کنید. همچنین با روشهای زمانبندی گرافهای جهتدار بدون دور (Directed Acyclic Graphs - DAGs) بر اساس تغییرات و بهروزرسانی داراییهای داده (Data Assets) آشنا خواهید شد تا واکنشپذیری Pipelineها را افزایش دهید.
یکی دیگر از بخشهای کاربردی دوره، شخصیسازی Apache Airflow با استفاده از Pluginها است. شما یاد میگیرید چگونه رابط کاربری Airflow را برای نیازهای سازمانی بهبود دهید و تجربه مدیریت Workflowها را کارآمدتر کنید. همچنین نحوه کنترل همزمانی اجرای Taskها با استفاده از Poolها و روش مقیاسدهی Airflow با Celery Executor برای پردازش توزیعشده (Distributed Processing) آموزش داده میشود.
این دوره برای متخصصان مهندسی داده (Data Engineers) طراحی شده است که میخواهند توانایی خود در مدیریت Pipelineهای پیچیده، بهینهسازی Workflowها و ساخت معماریهای دادهای مقیاسپذیر را ارتقا دهند.
پس از پایان این دوره، مهارت لازم برای طراحی، مدیریت، ایمنسازی و مقیاسدهی Workflowهای پیچیده داده با Apache Airflow را به دست خواهید آورد و میتوانید Pipelineهای سازمانی را با دقت، اطمینان و بهرهوری بیشتری مدیریت کنید.
🎯 اهداف یادگیری
مدیریت دسترسی کاربران در Apache Airflow با استفاده از کنترل دسترسی مبتنی بر نقش (RBAC)
طراحی و مدیریت Pipelineهای داده برای اجرای امن و کارآمد Workflowهای مهندسی داده
تنظیم Execution Timeout و Deadline Management برای بهبود زمانبندی فرآیندهای داده
زمانبندی DAGها (Directed Acyclic Graphs) بر اساس تغییرات و بهروزرسانی Data Assets
استفاده از Pluginهای Apache Airflow برای شخصیسازی و بهبود رابط کاربری
مدیریت همزمانی اجرای Taskها با استفاده از Airflow Pools
پیادهسازی پردازش توزیعشده با استفاده از Celery Executor برای مقیاسدهی Airflow
بهینهسازی عملکرد Workflowها برای اجرای سریعتر و قابل اعتمادتر Pipelineهای داده
طراحی معماریهای مقیاسپذیر برای مدیریت Data Workflowهای پیچیده سازمانی
افزایش توانایی ارکستراسیون و مدیریت Pipelineهای داده با استفاده از قابلیتهای پیشرفته Apache Airflow
این دوره یک مسیر جامع برای یادگیری مدیریت حرفهای Pipelineهای داده با Apache Airflow ارائه میدهد و شما را با قابلیتهای پیشرفته این ابزار برای طراحی، ایمنسازی و مقیاسدهی Workflowهای داده آشنا میکند. در طول دوره، یاد میگیرید چگونه دسترسی کاربران را با استفاده از کنترل دسترسی مبتنی بر نقش (Role-Based Access Control - RBAC) مدیریت کنید تا عملیات Pipelineها بهصورت امن و کنترلشده انجام شوند.
در این دوره، مفاهیم مهمی مانند مدیریت زمان اجرای وظایف (Execution Timeouts)، کنترل Deadlineها و بهینهسازی زمانبندی Workflowها بررسی میشوند تا بتوانید Pipelineهایی سریعتر، دقیقتر و قابل اطمینانتر ایجاد کنید. همچنین با روشهای زمانبندی گرافهای جهتدار بدون دور (Directed Acyclic Graphs - DAGs) بر اساس تغییرات و بهروزرسانی داراییهای داده (Data Assets) آشنا خواهید شد تا واکنشپذیری Pipelineها را افزایش دهید.
یکی دیگر از بخشهای کاربردی دوره، شخصیسازی Apache Airflow با استفاده از Pluginها است. شما یاد میگیرید چگونه رابط کاربری Airflow را برای نیازهای سازمانی بهبود دهید و تجربه مدیریت Workflowها را کارآمدتر کنید. همچنین نحوه کنترل همزمانی اجرای Taskها با استفاده از Poolها و روش مقیاسدهی Airflow با Celery Executor برای پردازش توزیعشده (Distributed Processing) آموزش داده میشود.
این دوره برای متخصصان مهندسی داده (Data Engineers) طراحی شده است که میخواهند توانایی خود در مدیریت Pipelineهای پیچیده، بهینهسازی Workflowها و ساخت معماریهای دادهای مقیاسپذیر را ارتقا دهند.
پس از پایان این دوره، مهارت لازم برای طراحی، مدیریت، ایمنسازی و مقیاسدهی Workflowهای پیچیده داده با Apache Airflow را به دست خواهید آورد و میتوانید Pipelineهای سازمانی را با دقت، اطمینان و بهرهوری بیشتری مدیریت کنید.
🎯 اهداف یادگیری
مدیریت دسترسی کاربران در Apache Airflow با استفاده از کنترل دسترسی مبتنی بر نقش (RBAC)
طراحی و مدیریت Pipelineهای داده برای اجرای امن و کارآمد Workflowهای مهندسی داده
تنظیم Execution Timeout و Deadline Management برای بهبود زمانبندی فرآیندهای داده
زمانبندی DAGها (Directed Acyclic Graphs) بر اساس تغییرات و بهروزرسانی Data Assets
استفاده از Pluginهای Apache Airflow برای شخصیسازی و بهبود رابط کاربری
مدیریت همزمانی اجرای Taskها با استفاده از Airflow Pools
پیادهسازی پردازش توزیعشده با استفاده از Celery Executor برای مقیاسدهی Airflow
بهینهسازی عملکرد Workflowها برای اجرای سریعتر و قابل اعتمادتر Pipelineهای داده
طراحی معماریهای مقیاسپذیر برای مدیریت Data Workflowهای پیچیده سازمانی
افزایش توانایی ارکستراسیون و مدیریت Pipelineهای داده با استفاده از قابلیتهای پیشرفته Apache Airflow
سرفصل ها
مقدمه
- ویژگیهایی برای مدیریت خط لوله مهندسی داده
- پیش نیازها
- مرور کلی نصب سریع
احراز هویت پیشفرض با Simple Auth Manager
- مدیریت احراز هویت و کنترل دسترسی مبتنی بر نقش
- پیکربندی کاربران در Simple Auth Manager
- مدیریت احراز هویت ساده - نقشهای مدیر، اپراتور، کاربر و بیننده
- پیکربندی چند تیم در Simple Auth Manager
- منابع را با تیمهای مختلف مرتبط کنید
- جداسازی منابع با استفاده از تیمها
کنترل دسترسی مبتنی بر نقش با FAB Auth Manager
- پیکربندی مدیر احراز هویت FAB
- بررسی نقشهای از پیش تعریف شده در FAB Auth Manager
- ایجاد کاربران با نقشهای مختلف
- اجرای یک DAG شاخهبندی ساده
- اجرای یک SQL DAG ساده
- نقشهای عمومی و بیننده
- نقش کاربر
- نقش اپراتور
- اقدامات، منابع و مجوزها
- افزودن مجوزها به نقش عمومی
- ایجاد و پیکربندی یک نقش سفارشی
مدیریت مهلت اجرا و زمان اتمام
- مدیریت مهلتها
- پیکربندی اعلانهای ایمیل برای زمان اتمام اجرا
- پیکربندی زمانهای اجرای سطح وظیفه
- پیکربندی تلاش مجدد برای انجام وظیفه و تأخیر در تلاش مجدد
- پیکربندی هشدارهای مهلت برای اجرای DAG
- پیکربندی فراخوانیهای ناموفق برای اجرای DAG
زمانبندی DAGها با داراییها
- زمانبندی آگاه از دارایی
- خط تولید دارایی
- خط لوله مصرفکننده دارایی
- پیادهسازی زمانبندی آگاه از داراییها
- خرید خط تولید و پیوستن به خط تولید مصرفکننده
- زمانبندی آگاه از دارایی با چندین دارایی و چندین DAG
سفارشیسازی رابط کاربری با افزونهها
- افزونهها
- معرفی افزونهها
- افزودن آیتمهای منو با استفاده از افزونهها
- افزونهی CSV Reader در عمل
- مروری بر افزونهی CSV Reader
- مروری بر قالبهای افزونه Jinja
مدیریت همزمانی با Poolها
- همزمانی و استخرها
- اجرای وظایف در مخزن پیشفرض
- محدود کردن همزمانی با استفاده از poolها
- پیکربندی اسلاتهای Pool برای وظایف با منابع فشرده
- پیکربندی همزمانی برای چندین DAG
تنظیم جریان هوا با کرفس
- مقیاسبندی جریان هوای آپاچی
- نصب ارائه دهنده Celery
- DAG برای خط لوله تبدیل
- اجرای RabbitMQ روی یک کانتینر Docker
- تنظیم یک کاربر ادمین برای RabbitMQ
- پیکربندی Celery Executor برای جریان هوا
- اجرای وظایف روی یک کارگر Celery
- اجرای وظایف روی چندین کارگر Celery
- اختصاص وظایف به صفها
نتیجهگیری
- خلاصه و مراحل بعدی