dask dataframe 查看数据量

Dask DataFrame 是一个由 Dask 库提供的并行计算的数据结构，它可以在分布式内存或磁盘上处理大数据集。查看 Dask DataFrame 的数据量通常涉及计算其分区的数量或者每个分区中的行数。你可以使用 `npartitions` 属性来获取分区数量，而查看每个分区的大小（行数）则需要更复杂的操作，因为它不是直接提供这个信息。

以下是如何查看 Dask DataFrame 的分区数量：

ddf = ... # 初始化你的 Dask DataFrame
n_partitions = ddf.npartitions

如果你想知道每个分区的大小（比如行数），你需要读取每个分区并计算它们的总和。这可以通过创建一个函数来实现，但是这不是Dask DataFrame内置的功能，可能会比较耗时，特别是对于非常大的数据集。这里是一个示例：

from dask.diagnostics import ProgressBar

def count_rows_per_partition(df):
    with ProgressBar():
        return df.map_partitions(len).sum()

row_counts = count_rows_per_partition(ddf)