我是dask的新手，正在尝试弄清楚如何重塑从dask数据帧的单个列中获得的dask数组，但遇到了错误。想知道有没有人知道这个修复方法(不需要强行计算)？谢谢!示例：import numpy as npdf = pd.DataFramethis works, but
浏览 22提问于2018-09-07得票数 2
回答已采纳
我想使用dask作为一个非达克感知函数()，这是我可以用dask.array.map_blocks完成的。下面的示例说明了这个问题(当然，这里f可以直接使用dask数组，但pyproj.Geod.inv不能)： return (x+y,使用大小为f的数组调用函数(32, 32)。然后，函数wrap生成(32, 32, 2)数组。那些会被传回达斯克的。但与其将其重塑为(2784, 2
浏览 3提问于2019-12-10得票数 0
回答已采纳
我的目标是并行读取多个hdf5文件，提取内部的多个模糊数组，并将每个数组存储在一个dataframe的一行，准确地说是一个单元格中。我不选择熊猫df，因为我相信它会太大。不可能使用read_hdf()从用h5py创建的hdf5文件中读取。我能做些什么来用paralleL中的dask导入数千个hdf5 5文件，并访问其中的多个do数组？我想要创建一个dataframe，其中每个2d数组(从hdfs中的n个暗数组中提取)
浏览 0提问于2021-09-30得票数 1
回答已采纳
我正在使用from_pandas()函数从熊猫数据帧创建一个dask数据帧。当我尝试使用方括号[ ]从dask dataframe中选择两列时，我得到了一个KeyError。根据dask文档，dask dataframe支持像pandas dataframe一样的方括号列选择。# data is a pandas dataframe
dask_df = ddf.f
浏览 67提问于2019-10-04得票数 1
我有一个dask数据帧和一个dask数组，它们以相同的逻辑顺序具有相同的行数。数据帧行通过字符串进行索引。我正在尝试将一个数组列添加到数据帧中。我尝试了几种方法，但都以其特定的方式失败了。当结构在逻辑上兼容时，将dask数组列添加到dask数据帧的正确方法是什么？
浏览 15提问于2018-01-09得票数 8
TLDR：我从一个dask包创建了一个dataframe。dask dataframe将每个观察(事件)作为一列对待。因此，我没有为每个事件设置行数据，而是为每个事件设置了一列。为了达到我的起点，下面是将json从磁盘读入dask.bag并将其转换为dask.dataframe的代码import dask.dataframe</
浏览 7提问于2016-08-04得票数 4
回答已采纳
是否有一种方法可以获得比可用内存更大的dask数组的唯一行？理想情况下，无需将其转换为dask DataFrame?。我目前使用这种方法import dask.dataframe as dd
ddf = dd.from_dask_array(dx)
ddf = ddf.
浏览 0提问于2018-11-20得票数 5
回答已采纳
我想将一个函数应用到一个dask.DataFrame，它返回一系列可变长度。np.random.randint(100)
背景/ usecase:在我的data
浏览 3提问于2016-12-13得票数 2
回答已采纳
1回答
我有一只熊猫DataFrame，df，我把它变成了DataFrame，dask_dfimport dask.dataframe as dddask_df = dd.from_pandas(df, npartitions=1)
当我把dask_df的
浏览 1提问于2019-09-16得票数 1
在Dask中，我需要基于第三列从两列的分组值计算加权平均值。(['A', 'B']).agg({'C' : wm}).reset_index()
File "/anaconda3/lib/python3.7/site-packages/dask/dataframe/dataframe/groupby.py"
浏览 35提问于2019-08-27得票数 2
import dask.dataframe as ddfrom dask import delayed
df1 = df1.astype({'a':np.float64})
df2 = pd.DataFrame({'a': np.random.rand
浏览 2提问于2016-12-14得票数 2
回答已采纳
此代码筛选列类型为int或float的dataframe中的所有列，如果存在NaN，则填充零：df_dask = df_dask.where(df_dask.notnull(), 0) 问题是原始的data
浏览 1提问于2021-05-25得票数 0
回答已采纳
3回答
我正在使用python与dask一起创建一个逻辑回归模型，以便在培训时加快速度。from dask import dataframe as ddsd = dd.from_panda
浏览 0提问于2019-06-06得票数 1
我有一个Dask DataFrame，我想从其中按列分组，并将agg作为其他列的列表。
浏览 15提问于2019-06-06得票数 0
1回答
代码：df = dd.demo.make_timeseries('2000-01-01', '2000-12-31', freq='print df
回溯(最近一次调用)：文件"C:/Users/divya.nagandla/PycharmProjects/python/supressions1/dask.py"，第1行，
浏览 0提问于2018-05-22得票数 0
2回答
谁能告诉我应该如何使用dask在数据框中选择一列“loc”？> import dask.dataframe as dd> y = df.loc['131094
浏览 1提问于2018-08-26得票数 4
1回答
所以我对dask DataFrame.append有个问题。我从主数据中生成了许多派生特征，并将它们附加到主数据框架中。在此之后，任何一组列的dask图都会被放大。下面是一个小示例：import numpy as npimport dask.dataframe as dd
df=pd.DataFrame
浏览 3提问于2017-02-02得票数 3
回答已采纳
我对的结果感到困惑from dask_ml.preprocessing import OrdinalEncoderas DaskOrdinalEncoderimport pandas as pd
np.random.seed(1234)
[1., 2.], [1., 0.],
浏览 7提问于2021-05-07得票数 0
回答已采纳
我有一个作为Pandas DataFrame读入的.csv文件。然后，我尝试将其转换为dask dataframe，但这会导致错误'Index' object has no attribute 'is_monotonic_increasing'。import pandas as pddf = pd.read_csv('s3://my-bucket/data.csv&#x
浏览 1提问于2019-12-12得票数 1
我试图分配一个达克数组到一个达克数据，但遇到了这个奇怪的问题。示例：import dask.dataframe as dd 416 dask</e
浏览 4提问于2020-01-29得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
