用Dask DataFram更改列值

Question

我有一个巨大的数据库，我需要根据特定的条件更改列的值。你知道吗

在Pandas中，我执行以下代码来完成我想要的：

df.loc[
        (df['ID_CRITERIO_APURACAO'] == TipoDestinatario.RESIDENCIAL.value) &
        (df['CODG_GRUPO_TENSAO'] == 8) &
        (df['CONSUMO'].between(0, 30)),
        'DESCONTO'
    ] = 35

我怎样才能在达斯克做类似的事情？你知道吗

Answer 1

Dask不支持原地突变。试试这个：

condition = (df['ID_CRITERIO_APURACAO'] == TipoDestinatario.RESIDENCIAL.value) &
    (df['CODG_GRUPO_TENSAO'] == 8) &
    (df['CONSUMO'].between(0, 30))

desconto = df.where(condition, 35)
df['DESCONTO'] = desconto