📁
prefect.docs
  • 介绍
  • 入门
    • 安装
    • Task和Flow
    • 触发器、关联task和信号
    • 为什么是Prefect
    • 为什么不是Airflow
  • 初级教程
    • ETL介绍
    • Prefect实现ETL
    • 使用Parameters
    • 失败处理
    • 调度执行
    • 水平扩展
    • task更多特性
  • 核心概念
    • Task.任务
    • Flow.流
    • Parameter.参数
    • State.状态
    • Engine.引擎
    • Execution.执行
    • Logging.日志
    • Mapping.映射
    • 通知和状态处理器
    • 持久化缓存
    • 结果对象和结果处理器
    • Schedule.调度计划
    • Secret.秘钥
    • Configuration.配置
    • 最佳实践
    • 常见问题
  • task库
    • Airtable
    • AWS.亚马逊云
    • Azure.微软云
    • Azure ML Service.微软云机器学习
    • Collection.集合
    • Constant.常量
    • Control Flow.控制流
    • Docker
    • Dropbox
    • Email
    • Function.函数
    • GCP.谷歌云
    • GitHub
    • Kubernetes
    • Operators.运算符
    • Postgres
    • Redis
    • RSS
    • Shell
    • Slack
    • Snowflake
    • SQLite
    • Strings.字符串
    • Twitter
  • 进阶教程
    • task映射并行和Prefect参数的高级特性
    • Prefect算子
    • 日志部署
    • Dask部署
    • ETL
    • 本地调试
    • Slack通知
    • Prefect Task剖析
    • 动态DAG和Task循环
    • 结果处理器
    • 工作流可视化
  • 样例
    • 概览
    • Airflow DAG
    • Task缓存
    • 按日收集github状态
    • ETL工作流
    • 工作流状态可视化
    • Docker Pipeline的函数式API
    • Github双周发布周期
    • Docker Pipeline的命令式API
    • 简易Map/Reduce
    • 参数化条件
    • 重试和映射
    • spaCy自然语言处理
    • 状态处理日志
    • Task循环
    • 发数据表至Airtable
  • 开发Issues
    • 内容提要
    • PIN-1:PINs介绍
    • PIN-2:数据处理器和元数据
    • PIN-3:执行环境
    • PIN-4:结果对象
    • PIN-5:组合Tasks
    • PIN-6:删除常量Tasks
    • PIN-7:存储和执行
    • PIN-8:事件驱动工作流
    • PIN-9:Prefect命令行
    • PIN 10:弹性调度计划
    • PIN 11:Task循环
    • PIN 12:环境回调
    • PIN 13:云部署
    • PIN-14:进阶事件驱动工作流
    • PIN-15:丢弃状态和信号
    • PIN-16:结果和目标
  • 开发规范
    • 概览
    • 编码风格
    • 文档注释
    • 测试
    • 贡献代码
    • 版本更新列表
    • 突破
  • 常见疑问
  • 开源社区
  • 代码贡献指南
Powered by GitBook
On this page
  • If/Else
  • Switch
  • Merge
  • FilterTask

Was this helpful?

  1. task库

Control Flow.控制流

PreviousConstant.常量NextDocker

Last updated 5 years ago

Was this helpful?

用于实现控制流结构(如分支和重新加入flow)的task和实用工具。

If/Else

在工作流中建立条件分支。

如果条件评估为True(ish),则将运行true_task。如果它评估为False(ish),则将运行false_task。Skipped状态的task被跳过不执行,以及未设置skip_on_upstream_skip=False的所有下游task都会跳过。

Switch

SWITCH是一个条件task,会被添加到工作流。

条件task会计算结果,并将结果与case的键进行比较。匹配case键对应的task运行,其他所有task都将被跳过。除非将跳过的task下游的任何task设置为skip_on_upstream_skip=False,否则它们也会被跳过。

Merge

Merge是一个合并task,将条件分支合并在一起。

flow中的条件分支会导致一个或多个task继续进行,而一个或多个task会被跳过。将那些分支合并回单个结果通常很方便。此语义是实现该目标的简单方法。

合并task将返回遇到的第一个实际结果,或者None。如果多个task可能返回结果,则将它们与列表分组。

FilterTask

筛选结果列表的task。

默认的过滤器是过滤NoResult和Exception以过滤出映射结果。注意此task的默认触发器为all_finished,并且skip_on_upstream_skip=False。

API参考文档
API参考文档
API参考文档
API参考文档
Prefect官网
英版原文
联系译者