如何通过python读取30G parquet文件

Posted

技术标签:

【中文标题】如何通过python读取30G parquet文件【英文标题】:How to read a 30G parquet file by python 【发布时间】:2021-10-15 20:11:33 【问题描述】:

我正在尝试从 30G 的大型 parquet 文件中读取数据。我的内存不支持在python中使用fastparquet默认读取,所以不知道应该怎么做才能降低读取过程的内存使用率。

【问题讨论】:

【参考方案1】:

您可以使用 pyarrow 的 iter_batches 以增量方式读取行块。

【讨论】:

以上是关于如何通过python读取30G parquet文件的主要内容,如果未能解决你的问题,请参考以下文章

在不读取文件的情况下使用 parquet 文件统计信息

使用 AWS Lambda (Python 3) 读取存储在 S3 中的 Parquet 文件

如何使用 Parquet.net 从 Parquet 文件中仅读取列的一部分?

在 Python Pandas 中使用 read_parquet 从 AWS S3 读取镶木地板文件时出现分段错误

读取parquet文件后和其它表join后回写问题

如何将 Parquet 文件读入 Pandas DataFrame?