可运行示例

鲁棒批处理数据流水线

使用标准库实现具备错误隔离、类型校验与批处理统计的鲁棒数据流水线。

Beginner10–15 min自动化Python 3.11+ · Standard library only

问题

批处理任务收到的半结构化输入中,一条坏记录不应让整批任务失败。韧性流水线会隔离失败、校验字段类型,并生成结构化的成功与失败汇总。

任务契约

  1. 隔离单条记录的失败,一条坏记录绝不中止整批。
  2. 处理前校验字段类型并收集结构化错误。
  3. 生成结构化的成功与失败统计汇总而不崩溃。

本地验证

FlyPython 仓库根目录下,先复现 starter 的失败,再验证审校过的 solution:

python examples/structured-pipeline/verify.py starter --expect-failure
python examples/structured-pipeline/verify.py solution

交给 coding agent

  1. 克隆仓库,用上面的命令复现 starter 失败。
  2. 任务契约 ↗交给你的 coding agent,只允许修改 starter/pipeline.py
  3. 运行 python examples/structured-pipeline/verify.py starter,任何失败都视为未完成。
  4. 参考实现 ↗对比补丁——目标是同样的契约配最小可读的 diff,而不是相同的语法。

继续

这个示例在学习路线中的位置。

审校日期 2026-09-02 · 仓库内容版本 1。可以继续阅读对应学习路径、浏览仓库目录,或阅读 MCP 迁移指南了解规范背景。