首页
›
数据工程与实时数据平台
›
005-数据流水线编排
›
《Prefect工作流编排与任务依赖开发》
VIP20
本课程属于:005-数据流水线编排
数据工程与实时数据平台 · 共 20 门相关课程,组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录
咨询 / 购买
Prefect工作流编排与任务依赖开发
📚 共计 30 章节
点击此处阅读海量试读课程:100+行业、1000+细分领域
01
Prefect初识
什么是Prefect、为什么选择Prefect、Prefect vs Airflow对比、核心概念速览。
概念
对比
02
环境搭建
Python环境准备、Prefect安装、Prefect UI启动、第一个Hello World流程。
安装
入门
03
Flow与Task基础
@flow装饰器详解、@task装饰器详解、任务依赖关系、返回值传递。
装饰器
依赖
04
Flow配置
flow名称与描述、flow版本管理、flow标签与分组、flow的调度策略。
配置
调度
05
Task配置
task重试机制、task超时设置、task缓存策略、task标签与优先级。
重试
缓存
06
参数传递
Parameters基础用法、参数类型校验、参数默认值、从外部传入参数。
参数
校验
07
任务状态管理
状态机模型、状态回调函数、自定义状态处理、状态持久化。
状态
回调
08
Flow运行控制
顺序执行、并行执行、条件分支、动态任务生成。
控制流
动态
09
子流程设计
子流程定义、子流程参数传递、子流程结果聚合、嵌套流程最佳实践。
嵌套
聚合
10
错误处理
异常捕获机制、重试策略配置、失败通知、优雅降级方案。
异常
降级
11
日志系统
Prefect日志级别、自定义日志处理器、日志持久化、日志与监控集成。
日志
监控
12
缓存机制
task缓存原理、缓存键设计、缓存过期策略、分布式缓存集成。
缓存
分布式
13
调度引擎
Cron表达式基础、Interval调度、Rrule调度、时区处理。
Cron
时区
14
事件驱动
事件监听机制、事件触发流程、Webhook集成、消息队列对接。
事件
Webhook
15
并发控制
并发限制设置、资源池管理、任务队列优先级、背压机制。
并发
背压
16
存储后端
本地文件存储、S3/GCS集成、数据库存储、自定义存储后端。
存储
S3
17
结果持久化
Result类型详解、序列化配置、结果存储策略、大结果处理。
持久化
序列化
18
通知系统
邮件通知配置、Slack集成、自定义通知渠道、通知模板。
通知
Slack
19
UI操作指南
Dashboard概览、Flow运行监控、Task执行详情、历史记录查询。
UI
监控
20
API使用
REST API概览、认证机制、流程CRUD操作、运行状态查询。
API
REST
21
Deployment管理
Deployment创建、参数化部署、版本回滚、蓝绿部署策略。
部署
回滚
22
Work Queue
队列原理、队列配置、Worker绑定、负载均衡策略。
队列
负载均衡
23
Agent机制
Agent类型介绍、Agent启动配置、Agent健康检查、Agent扩缩容。
Agent
扩缩容
24
Server模式
Prefect Server架构、数据库配置、高可用部署、性能调优。
Server
高可用
25
Cloud模式
Prefect Cloud特性、Workspace管理、团队协作、权限控制。
Cloud
协作
26
测试策略
单元测试Task、集成测试Flow、Mock外部依赖、测试覆盖率。
测试
Mock
27
性能优化
Task粒度设计、数据本地性、批处理优化、内存管理技巧。
性能
优化
28
安全实践
敏感信息管理、密钥轮换、网络隔离、审计日志。
安全
审计
29
监控告警
Prometheus集成、Grafana面板、自定义指标、告警规则配置。
监控
告警
30
实战案例
ETL数据管道、ML模型训练流程、定时报表生成、微服务编排。
实战
案例
所属VIP或分类
同VIP:Airflow-Dataset-Trigger数据驱动调度实战
同VIP:Airflow与Dagster调度体系对比及选型
同VIP:Airflow自定义Operator与插件开发