讲师中心 微信公众号

工具推荐

视频效率加速
Seko
Seko

AI短剧一键生成成片

updream

一键生成高质量推广成片

Laper
Laper

剧本策划到成片协作

AniShort
AniShort

AI短剧协同制作平台

C# Polars/DataFrame操作文件 C#如何使用DataFrame库高效读写CSV/Parquet

轻婷酱_5672

轻婷酱_5672

发布时间:2026-02-28 11:42:10

|

641人浏览过

|

来源于php中文网

原创

Polars.NET处理CSV乱码需先用GBK解码字节再转内存流;字段截断应设hasHeader:true+inferSchemaLength:null;Parquet写入推荐Lz4Raw压缩并用SinkParquet;取列数据优先用Values.Span而非ToPandas();并发写Parquet须分片避免冲突。

c# polars/dataframe操作文件 c#如何使用dataframe库高效读写csv/parquet

Polars.NET 读 CSV 时中文乱码或字段截断怎么办

默认用 UTF-8 读取,但 Windows 上很多 CSV 是 GBK/GB2312 编码,Polars.NET 当前(v0.19)不支持直接传 Encoding 参数。硬指定编码会抛 System.NotSupportedException: Encoding not supported。

实操建议:

  • 先用 File.ReadAllBytes(path) 读原始字节,再用 Encoding.GetEncoding("GBK").GetString(bytes) 转字符串,写入内存流后交给 LazyFrame.ScanCsv() —— 注意必须用 Stream 构造,不能用路径字符串
  • 字段截断常见于含换行符的 CSV 字段(没加引号),改用 hasHeader: true + inferSchemaLength: null 强制全量推断类型,避免早期采样误判为 Utf8 后截断
  • 若列名含空格或特殊字符,务必设 hasHeader: true 并配合 separator: ',' 显式声明,否则首行可能被当数据

Parquet 写入报错 “Could not write to file” 或性能极低

Polars.NET 底层调用的是 Rust Polars,Windows 上写 Parquet 默认用 Snappy 压缩,但 .NET 运行时若没装对应原生依赖(如 libsnappy.dll),就会静默 fallback 到未压缩,导致磁盘 I/O 暴增、文件巨大,甚至因临时缓冲区溢出报错。

实操建议:

  • 显式指定压缩算法:写入时传 new ParquetOptions { Compression = ParquetCompression.Lz4Raw }(LZ4 在 .NET 环境兼容性最好)
  • 避免直接 df.WriteParquet(path),改用 df.SinkParquet(path, options) —— 前者是 eager 模式,会强制 materialize 全量数据;后者走 lazy pipeline,内存更稳
  • 分区写入用 SinkParquet 配合 GroupBy().MapGroups(),别用 Filter() 循环写,否则每轮都重算整个 DataFrame

从 DataFrame 提取 List 或单列数组太慢?别用 ToPandas()

ToPandas() 是调试用的桥接方法,本质是把所有数据序列化成 Python 对象再反解回 .NET,中间经历两次跨语言拷贝,10 万行以上基本卡死。

Csv Brain
Csv Brain

加载CSV文件,使用自然语言(英文)提问。通过Anthropic、OpenAI或本地Ollama实现AI驱动的自然语言查询,无需SQL。

下载

实操建议:

  • 取单列值:用 df.GetColumn("col_name").Cast<arrowarray>().Values</arrowarray> 直接拿底层 Span<t></t>,比如 Int64Array 的 ValueBuffer.Span
  • 转 List<string></string>:优先 column.Chunk(0).As<stringarray>().GetValues()</stringarray>,比遍历 GetValue(i) 快 5–10 倍
  • 需要强类型对象列表?用 df.ToRows() + Span<t>.ToArray()</t> 批量映射,别用 LINQ Select(x => new Foo { ... }) —— 每次 x 都是 boxed object,GC 压力大

多线程写同一个 Parquet 文件会崩溃

Polars.NET 的 SinkParquet 不是线程安全的,多个 Task 并发调用同一路径会触发底层 Rust 的文件锁冲突,报 IOError: The process cannot access the file because it is being used by another process。

实操建议:

  • 绝对不要并发写同一文件。合并策略只有两种:先用 LazyFrame 合并逻辑(Concat() / Join()),再单次写出;或按业务维度分片写不同路径,最后用 ScanParquet("folder/*.parquet") 统一读
  • 如果必须并行处理,用 Parallel.ForEach(partitions, p => { ... df.SinkParquet($"{path}_{i}.parquet") ... }),写完再用 pl.Concat(...) 加载全部分片
  • 注意 ScanParquet 读目录时,子目录里不能有隐藏文件(如 .DS_Store 或 _SUCCESS),否则解析失败 —— 读前先 Directory.GetFiles(dir, "*.parquet", SearchOption.AllDirectories) 过滤一遍

真正卡住人的往往不是语法,而是底层 Arrow 内存模型和 .NET GC 的交互方式:比如 StringArray 的 ValueBuffer 是 unmanaged memory,GetValues() 返回的 string[] 是托管堆分配,频繁调用等于在做隐式深拷贝。能用 Span<char></char> 就别碰 string。

热门AI工具

更多
VibeKnow
VibeKnow Hot

一款AI视频创作工具,主要用于全球首个AI知识视频创作平台,文档、文章、网页,一键生成视频,适合需要提升相关任务效率的用户。

花生AI
花生AI Hot

一款AI视频创作工具,主要用于B站推出的AI视频创作工具,适合需要提升相关任务效率的用户。

豆包大模型

豆包大模型是一款由字节跳动推出的企业级大语言模型服务平台。

WorkBuddy

一款AI办公效率工具,主要用于腾讯云推出的AI原生桌面智能体工作台,适合需要提升相关任务效率的用户。

Loomy
Loomy Hot

一款AI工具,主要用于科大讯飞发布的桌面级 AI 助理,比 OpenClaw 更易用、更安全!,适合需要提升相关任务效率的用户。

DeepSeek

DeepSeek是一款面向对话、写作、编程和推理场景的AI大模型工具。

火山引擎

火山引擎是一款面向企业的云计算与AI服务平台。

讯飞智作

讯飞智作是一款AI视频创作工具,AI文本配音工具,数字人课程、营销视频制作。

Laper
Laper Hot

Laper是专为编剧、导演和制片人推出的 AI 原生剧本创作工具。

相关专题

更多
C++系统编程内存管理_C++系统编程怎么与Rust竞争内存安全
C++系统编程内存管理_C++系统编程怎么与Rust竞争内存安全

C++系统编程中的内存管理是指 对程序运行时内存的申请、使用和释放进行精细控制的机制,涵盖了栈、堆、静态区等不同区域,开发者需要通过new/delete、智能指针或内存池等方式管理动态内存,以避免内存泄漏、野指针等问题,确保程序高效稳定运行。它核心在于开发者对低层内存有完全控制权,带来灵活性,但也伴随高责任,是C++性能优化的关键。

106

2025.12.22

Rust异步编程与Tokio运行时实战
Rust异步编程与Tokio运行时实战

本专题聚焦 Rust 语言的异步编程模型,深入讲解 async/await 机制与 Tokio 运行时的核心原理。内容包括异步任务调度、Future 执行模型、并发安全、网络 IO 编程以及高并发场景下的性能优化。通过实战示例,帮助开发者使用 Rust 构建高性能、低延迟的后端服务与网络应用。

278

2026.02.11

Rust内存安全机制与所有权模型深度实践
Rust内存安全机制与所有权模型深度实践

本专题围绕 Rust 语言核心特性展开,深入讲解所有权机制、借用规则、生命周期管理以及智能指针等关键概念。通过系统级开发案例,分析内存安全保障原理与零成本抽象优势,并结合并发场景讲解 Send 与 Sync 特性实现机制。帮助开发者真正理解 Rust 的设计哲学,掌握在高性能与安全性并重场景中的工程实践能力。

642

2026.03.05

Rust 系统编程入门与实战
Rust 系统编程入门与实战

统讲解近年最受关注的系统级编程语言 Rust 的核心知识体系,涵盖 Rust 的安装与 Cargo 项目管理、变量绑定与不可变性设计哲学、所有权(Ownership)/ 借用(Borrowing)/ 生命周期(Lifetime)三大核心概念、结构体/枚举与模式匹配(match)、Trait 特征系统与泛型编程、错误处理(Result/Option)、智能指针(Box/Rc/Arc)、并发编程的无畏并发(Fearless Concurre

497

2026.05.29

Rust异步网络服务与Tokio Runtime深度实践
Rust异步网络服务与Tokio Runtime深度实践

本专题围绕 Rust 在高并发网络服务中的应用展开,系统讲解 Tokio 异步运行时、任务调度模型、Future 执行机制以及高性能网络编程方式。结合实际服务端案例,帮助开发者构建低延迟、高可靠的异步服务架构。

296

2026.06.29

string转int
string转int

在编程中,我们经常会遇到需要将字符串(str)转换为整数(int)的情况。这可能是因为我们需要对字符串进行数值计算,或者需要将用户输入的字符串转换为整数进行处理。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

7299

2023.08.02

c语言中null和NULL的区别
c语言中null和NULL的区别

c语言中null和NULL的区别是:null是C语言中的一个宏定义,通常用来表示一个空指针,可以用于初始化指针变量,或者在条件语句中判断指针是否为空;NULL是C语言中的一个预定义常量,通常用来表示一个空值,用于表示一个空的指针、空的指针数组或者空的结构体指针。

549

2023.09.22

java中null的用法
java中null的用法

在Java中,null表示一个引用类型的变量不指向任何对象。可以将null赋值给任何引用类型的变量,包括类、接口、数组、字符串等。想了解更多null的相关内容,可以阅读本专题下面的文章。

1698

2024.03.01

Postman身份认证怎么配置
Postman身份认证怎么配置

本专题从实际API接口调试场景出发,讲解Postman身份认证的完整配置流程,包括常见认证协议介绍、授权参数设置、访问令牌填写、OAuth 2.0授权及认证失败排查,帮助用户正确完成接口授权与访问验证。

40

2026.11.06

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
C++ Core Guidelines
C++ Core Guidelines

共0课时 | 0人学习

C++ Reference
C++ Reference

共0课时 | 0人学习

C++ 官方标准说明
C++ 官方标准说明

共0课时 | 0人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn