我正在构建一个FastAPI应用程序,该应用程序将为Dask的块提供服务。我想把和结合起来。下面是一个mcve,它演示了我试图在应用程序的服务器和客户端做什么:import time
import numpy as npfrom dask.distributed import Client# create aimport requests
from
我有Dask系列的Dask数据帧。但是,使用loc[0]会导致另一个dask系列。使用to_frame也不起作用,因为结果是"Dask系列Dask数据帧的Dask数据帧“。下面是一个使用Dask系列Pandas数据帧的最小示例(不完全相同,但说明了问题):import dask.dataframe as dd
pdf
我是dask的新手,正在尝试弄清楚如何重塑从dask数据帧的单个列中获得的dask数组,但遇到了错误。想知道有没有人知道这个修复方法(不需要强行计算)?谢谢!示例:import numpy as npdf = pd.DataFramethis works, but requires a compute
ddf['x'].values.compute().reshape(