不能,php无法直接读写polars数据,需通过中间格式(如csv/json lines)和外部进程(polars cli或python脚本)桥接,避免使用parquet直读。

PHP 能直接读写 Polars 数据吗?不能,得绕道
Polars 是 Rust 写的高性能 DataFrame 库,没有官方 PHP 绑定,也没有 polars 扩展。PHP 进程无法直接加载或操作 Polars 的内存结构(比如 LazyFrame 或 DataFrame)。想让 PHP 和 Polars 协同工作,唯一可行路径是「数据落地为中间格式 + 外部进程调用」。
推荐方案:用 Polars CLI 或 Python 脚本做转换桥接
最稳定的做法是把 Polars 当作外部数据处理服务:PHP 负责准备输入(如 CSV/JSON/Parquet 文件),用 shell_exec() 或 proc_open() 调起 Polars(通过 polars CLI)或轻量 Python 脚本,再读取输出结果。
- Polars CLI 需要提前安装:
pip install polars-cli(注意:它只支持基础操作,不支持lazy模式或自定义逻辑) - 更灵活的方式是写一个
process.py:用polars.read_parquet()读、df.write_json()或df.write_csv()写,然后 PHP 执行python3 process.py input.parquet output.json - 务必设置超时和错误捕获:
proc_open()的stderr管道必须读取,否则子进程可能卡死;Polars 报错如ColumnNotFoundError会直接出现在 stderr 里 - 避免在 PHP 中拼接用户输入进命令行——用临时文件路径代替参数传值,防止 shell 注入
读 Parquet / 写 JSON:PHP 侧的关键代码片段
假设你已用 Polars 脚本把数据转成 JSON Lines(每行一个对象),PHP 只需流式解析,不全量加载:
file_put_contents('/tmp/input.csv', $csv_data);
$output = shell_exec('python3 /path/to/transform.py /tmp/input.csv /tmp/output.json 2>&1');
if (strpos($output, 'Error') !== false) {
throw new RuntimeException("Polars step failed: {$output}");
}
$fp = fopen('/tmp/output.json', 'r');
while (($line = fgets($fp)) !== false) {
$row = json_decode($line, true);
// 处理单行
}
fclose($fp);
注意:polars.write_json() 默认是数组格式,但大文件容易爆内存;改用 write_ndjson=True(即 JSON Lines)才能配合 PHP 流式读取。
为什么别碰 Parquet 直读?PHP 缺少原生支持
虽然有 parquet-php 这类第三方库,但它只支持极简 schema(无嵌套、无 timestamp_tz、不兼容 Polars 的物理编码方式),且维护停滞。真实场景中,Polars 输出的 Parquet 常含 dictionary 编码或 BYTE_STREAM_SPLIT,PHP 库一读就抛 InvalidParquetFileException 或字段全 null。
真正省事的做法是:让 Polars 输出成 CSV 或 JSON Lines,这两种格式 PHP 原生处理毫无压力,性能损耗可接受,也避开了二进制解析的所有坑。
php免费学习视频:立即使用
踏上前端学习之旅,开启通往精通之路!从前端基础到项目实战,循序渐进,一步一个脚印,迈向巅峰!











