我在 dask groupby 上工作,我在這里面臨一些問題我已經(jīng)定義了我的custom_max,它在沒有dask的情況下工作得很好。import dask.dataframe as ddfrom something import custom_maxdf.head() Date Time productID some_id some_name ... 133192 26/10/2015 22:50:57 16037492655230761375561 12345 rahul ...133186 26/10/2015 22:50:48 16037492655330761377104 12345 rahul ...27323 26/10/2015 22:50:36 16037483834140761373004 3456 rajesh ...27322 26/10/2014 22:50:33 16037483834150761373390 3564 suresh ...133191 26/10/2014 22:50:33 16037492655330761377107 3456 rajesh ...new_grouped = dd.from_pandas(df, npartitions=10).groupby(["some_id"])new_groupedagg_meta = {'some_name': NamedAgg(column='some_name', aggfunc=<function custom_max at 0x7fe6f5c16e18>)}<dask.dataframe.groupby.DataFrameGroupBy object at 0x7fe6f5441978>agg_df = new_grouped.agg(**agg_meta).compute()TypeError: agg() got an unexpected keyword argument 'some_name'任何人都可以指導(dǎo)我我犯了什么錯(cuò)誤嗎?我正在使用 pandas 0.25.3 和 dask 2.9.0提前致謝
1 回答

慕婉清6462132
TA貢獻(xiàn)1804條經(jīng)驗(yàn) 獲得超2個(gè)贊
在方法中傳遞整個(gè)字典,agg
不帶 **。
agg_df = new_grouped.agg(agg_meta).compute()
添加回答
舉報(bào)
0/150
提交
取消