编写 Python,交付 Python。

专为 Python 设计的工作流编排框架。只需一个装饰器,即可从脚本实现规模化生产。

每月 1020 万+ 次下载
2.19 万+ 星标
676+ 位贡献者
1 天前发布新版本

生产环境的信赖之选

Cash App
Washington Nationals
WHOOP
Cisco
1Password
Dutch
NASA
CoinList
Ashby
Square
Meta
Eight Sleep

Python 编排

只需添加一个装饰器。

按原样运行您现有的 Python 代码。无需僵化的 DAG 结构,无需自定义 DSL——Prefect 完美契合您现有的工作方式。

查看运作方式
etl_pipeline.py
def process_data()
data = extract()
transform(data)
load(data)
状态--:--
等待中
状态追踪
自动重试
制品 (Artifacts)

持久化执行

无需重播,直接恢复。

从故障中即时恢复,无需重新运行高昂的计算任务。Prefect 将结果持久化,确保任意 Python 代码都能实现“恰好一次”的执行——无需重写代码。

了解持久化执行
工作流恢复
运行 1
extract()
transform(data)
load(data)
重试 1
extract()
transform(data)
load(data)
重试 2
extract()
transform(data)
load(data)

默认可观测

用全景地图调试,而非手电筒

平铺的日志无法呈现全局。在时间轴中精准定位任务失败位置,并即时访问相关日志——无需使用 grep 搜索。

探索可观测性
运行中
striped-pelican
get-directory
install-deps
clone-repo
build-project
0s
运行日志
正在初始化运行环境...

事件驱动的自动化

响应一切

从 Webhook、云事件或状态变更触发工作流。Prefect 的主动事件总线实时检测发生的(或未发生的)事件,让您告别轮询,开启主动响应。

探索自动化功能

工作池 (Work Pools)

默认可移植

工作池将您的代码与运行环境解耦。从 Docker 到 Kubernetes 再到 Serverless,无需更改工作流代码。

了解工作池
Docker
Kubernetes
ECS
Google Cloud Run
Azure ACI
Modal
Docker
Kubernetes
ECS
Google Cloud Run
Azure ACI
Modal
Docker
Kubernetes
ECS
Google Cloud Run
Azure ACI
Modal
pipeline.py
1@flow
2
def pipeline():
3data = extract()
4transform(data)
5load(data)
无需变更

为何团队转向 Prefect

保留 Python 习惯,削减编排开销,实现更快的交付。

看看 Snorkel AI 是如何做到的

客户案例

Snorkel AI 如何在 Prefect 开源版上每小时运行 1000+ 个工作流

在 Kubernetes 上自托管
增量迁移
消除了自定义基础设施
阅读完整案例研究 →

完全自由

Apache 2.0 协议,无需担忧。

随意 Fork、修改或构建商业产品。Prefect 引擎采用 Apache 2.0 协议——这是您的团队所需要的永远的自由。

阅读完整许可协议
Apache 许可协议
2.0 版本,2004 年 1 月
许可权限
✓ 商业使用
✓ 修改
✓ 分发
✓ 专利使用
✓ 私人使用

部署 Prefect 的最快方式

Prefect Cloud 是 Prefect 开源版的高可用托管版本。同样的开发者体验,即开即用的数据平台。