我如何从一个简单的数据框转换为一个期货列表？ [英] How do I convert from a dask dataframe to a list of futures?

问题描述

我有一个如下所示的dask数据帧：

I have a dask dataframe like the following:

import dask.dataframe as dd
df = dd.read_csv('s3://...')

我如何从中获取期货清单

How do I get a list of futures from this dataframe?

推荐答案

您可以使用。to_delayed 方法，可将dask数据框转换为 dask.delayed 对象

You can use the the .to_delayed method to convert from a dask dataframe to a list of dask.delayed objects

L = df.to_delayed()

然后您可以使用 client.compute 方法。

from dask.distributed import Client
client = Client()

futures = client.compute(L)

这篇关于我如何从一个简单的数据框转换为一个期货列表？的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！