在使用 DuckDB Python 客户端进行数据分析时，经常需要遍历 SQL 查询返回的结果。直接使用 for 循环迭代 duckdb.DuckDBPyRelation 对象可能无法达到预期的效果。本文将介绍如何使用 fetchmany 方法以批处理方式遍历查询结果，提高效率并降低内存占用。
DuckDB 提供了一个 fetchmany 方法，允许你从查询结果中一次性获取指定数量的行。这对于处理大型数据集特别有用，因为它可以避免一次性将所有数据加载到内存中。
以下是一个使用 fetchmany 方法遍历查询结果的示例：
import duckdb
# 定义批处理大小
batch_size = 10
# 执行 SQL 查询
handle = duckdb.sql("select * from 'employees.csv'")
# 循环遍历结果集，每次获取 batch_size 行
while batch := handle.fetchmany(batch_size):
# 处理当前批次的数据
print(batch)
# 在这里可以对 batch 中的每一行数据进行进一步处理
# 例如，将数据写入文件、进行数据分析等代码解释：
立即学习“Python免费学习笔记（深入）”；
- import duckdb: 导入 DuckDB Python 客户端。
- batch_size = 10: 定义每次获取的行数。可以根据实际情况调整这个值。如果内存充足，可以适当增大 batch_size 以减少循环次数，提高效率。如果内存有限，则需要减小 batch_size。
- *`handle = duckdb.sql("select from 'employees.csv'")**: 执行 SQL 查询，并将结果存储在handle变量中。请确保'employees.csv'` 文件存在且路径正确。
- while batch := handle.fetchmany(batch_size):: 这是一个循环，每次调用 handle.fetchmany(batch_size) 方法获取 batch_size 行数据，并将其赋值给 batch 变量。当 fetchmany 返回空列表时，循环结束，表示已经遍历完所有数据。
- print(batch): 打印当前批次的数据。在这里可以替换成你自己的数据处理逻辑。
注意事项：
- 确保 CSV 文件存在且 DuckDB 能够访问。
- batch_size 的选择需要根据数据集大小和可用内存进行权衡。
- fetchmany 返回的是一个列表，其中每个元素代表一行数据。
- 如果 CSV 文件包含标题行，需要在使用 SQL 查询时进行处理，例如使用 OFFSET 1 跳过第一行。
总结：
通过使用 fetchmany 方法，可以有效地以批处理方式遍历 DuckDB 查询结果，从而避免一次性加载所有数据带来的内存压力。这对于处理大型数据集非常有用。在实际应用中，可以根据具体需求调整 batch_size 的大小，并根据需要对每个批次的数据进行进一步处理。
