dask groupby集約正しい使用

Question

次のコードでは、異なる動作を理解したいと思います。

これは私は、平均/最小/最大を有する上記の例では、列のグループを集約することができDASK /分散/ Ubuntuの16.04新鮮condaインストール

us=dd.read_parquet("/home/.......",["date","num_25","num_100","num_unq"]).persist() 
g=us.groupby("us.date.dt.week) 

x=g["num_25","num_100","num_unq"].mean() # Works ! 
x=client.persist(x)      # 

x=g["num_25","num_100","num_unq"].var() # NOT WORKING 
x=client.persist(x)      # 

x=g["num_25","num_100","num_unq"].std() # NOT WORKING 
x=client.persist(x)      # 

x=g.num_100.var()       # Works 
x=client.persist(x) 

を使用しています。しかしながら、例えば、 std/var私は一度に1つの列を分割して計算を行う必要があります。

それが動作しない場合には、スタックは、キー・エラーを報告（「num_25」、「num_100」、「num_unq」）

Answer 1

パンダ/ Dask.dataframeであなたはリストを渡すことで、複数の列を選択列の

df[['a', 'b', 'c']].var() # good! 
df['a', 'b', 'c'].var() # bad.