可运行示例
鲁棒批处理数据流水线
使用标准库实现具备错误隔离、类型校验与批处理统计的鲁棒数据流水线。
问题
批处理任务收到的半结构化输入中,一条坏记录不应让整批任务失败。韧性流水线会隔离失败、校验字段类型,并生成结构化的成功与失败汇总。
任务契约
- 隔离单条记录的失败,一条坏记录绝不中止整批。
- 处理前校验字段类型并收集结构化错误。
- 生成结构化的成功与失败统计汇总而不崩溃。
本地验证
在 FlyPython 仓库根目录下,先复现 starter 的失败,再验证审校过的 solution:
python examples/structured-pipeline/verify.py starter --expect-failurepython examples/structured-pipeline/verify.py solution交给 coding agent
继续
这个示例在学习路线中的位置。
审校日期 2026-09-02 · 仓库内容版本 1。可以继续阅读对应学习路径、浏览仓库目录,或阅读 MCP 迁移指南了解规范背景。