Python Windrose在处理大型数据集时挂起，不会崩溃或产生结果

import pandas as pd
from windrose import WindroseAxes
import matplotlib.pyplot as plt

def process_chunk(chunk):
    ax = WindroseAxes.from_ax()
    ax.bar(chunk['direction'], chunk['speed'], normed=True, opening=0.8, edgecolor='white')
    plt.title('Windrose for Chunk')
    plt.show()

# 假设df是一个非常大的DataFrame
chunk_size = 100000
for chunk in pd.read_csv('large_dataset.csv', chunksize=chunk_size):
    process_chunk(chunk)

import dask.dataframe as dd
from windrose import WindroseAxes
import matplotlib.pyplot as plt

df = dd.read_csv('large_dataset.csv')

def process_chunk(chunk):
    ax = WindroseAxes.from_ax()
    ax.bar(chunk['direction'], chunk['speed'], normed=True, opening=0.8, edgecolor='white')
    plt.title('Windrose for Chunk')
    plt.show()

df.map_partitions(process_chunk).compute()

# 使用更快的文件格式，如Parquet
df.to_parquet('large_dataset.parquet')
df = pd.read_parquet('large_dataset.parquet')