GPU 加速的数据处理工具包,用于构建可重复的流水线,对大规模文本、图像、视频和音频数据做过滤、去重和转换,服务于 AI 训练。
OpenDCAI/DataFlow
一个基于可组合算子和流水线的 Python 框架,用于生成、清洗和准备大模型训练数据,并提供可视化 WebUI。
- Star
- 8,249
- Fork
- 1,200
- 未关闭 Issue
- 30
- 最近提交
- 3天前
这是什么?
DataFlow 是面向大语言模型的数据准备系统,可将 PDF、纯文本和质量较低的问答对等原始数据,处理成适用于预训练、监督微调、强化学习或 RAG 的高质量数据集。整体以算子为基本单位,每个算子完成生成、评估、过滤或精炼等一个处理步骤,多个算子组合成可复用、可分享的流水线。
项目内置文本问答挖掘、推理增强、Text2SQL、知识库清洗和 Agentic RAG 数据等流水线,并提供能够基于已有或新编写算子自动组装流水线的智能体。算子支持 JSON、JSONL 和 CSV 输入,既可调用 API 形式的大模型,也可通过 vLLM 进行本地推理。安装方式包括 pip(open-dataflow)、Docker 和 Google Colab,执行 dataflow webui 即可启动浏览器中的可视化流水线编辑器。
仓库还包含用该框架生成的 DataFlow-Instruct-10K 指令数据集,以及模型在该数据集与其他数据集上微调后的对比基准结果。
核心功能
- 01基于算子的设计,每个处理步骤都是可复用单元,可串联成流水线。
- 02内置文本问答挖掘、推理增强、Text2SQL、知识库清洗和 Agentic RAG 等流水线。
- 03支持 JSON、JSONL 和 CSV 格式的输入与输出。
- 04既可调用 API 形式的大模型,也可通过 vLLM 进行本地推理。
- 05通过 dataflow webui 命令启动浏览器可视化界面。
- 06自定义算子可打包,并通过 GitHub 或 PyPI 分发。
适用场景
- 将原始 PDF 或网页文本转换为用于监督微调的问答对。
- 生成并过滤用于模型训练的指令或推理数据集。
- 构建包含 schema 上下文和解释的 Text2SQL 训练数据。
- 为检索增强生成(RAG)整理清洗后的知识库条目。
快速上手
- 1
从 PyPI 安装 open-dataflow 包
- 2
启动可视化流水线 WebUI
dataflow webui
使用前须知
- 许多算子需要调用 LLM API 或大模型,因此运行前需要具备模型访问条件。
标签
常见问题
- DataFlow 是什么?
- 一个基于可组合算子和流水线的 Python 框架,用于生成、清洗和准备大模型训练数据,并提供可视化 WebUI。 DataFlow 是面向大语言模型的数据准备系统,可将 PDF、纯文本和质量较低的问答对等原始数据,处理成适用于预训练、监督微调、强化学习或 RAG 的高质量数据集。整体以算子为基本单位,每个算子完成生成、评估、过滤或精炼等一个处理步骤,多个算子组合成可复用、可分享的流水线。
- DataFlow 可以免费使用吗?用的什么许可证?
- DataFlow 以 Apache-2.0 许可证开源。用于商业产品前,请先确认许可证条款。
- DataFlow 还在维护吗?
- 活跃维护中。DataFlow 最近一次提交是在 2026年10月19日。
- DataFlow 适合用来做什么?
- 将原始 PDF 或网页文本转换为用于监督微调的问答对。 生成并过滤用于模型训练的指令或推理数据集。 构建包含 schema 上下文和解释的 Text2SQL 训练数据。 为检索增强生成(RAG)整理清洗后的知识库条目。
- DataFlow 怎么安装和运行?
- 从 PyPI 安装 open-dataflow 包 启动可视化流水线 WebUI: dataflow webui
- 在哪里获取 DataFlow?
- 源代码和安装说明在 GitHub 上:https://github.com/OpenDCAI/DataFlow
概要由 AI 根据项目 README 生成;GitHub 数据每日更新。
相关项目
面向基础模型的数据处理系统,提供 200 多种可组合算子,用于清洗、过滤、去重和合成文本、图像、音频与视频数据。
基于 LLM 的 Python 数据处理与 ETL 系统,用自然语言描述操作,对大量结构化与非结构化数据做 map-reduce 处理。
声明式、代码优先的数据集成引擎,基于 Singer 的 tap 与 target 构建 ELT 数据管道。
用于构建 RAG、智能体和文档处理应用的 Python 框架,帮助 LLM 连接私有数据。
将任意 Agent Skill 转换为 Harbor 格式、可用于强化学习的终端任务。