How to add a column in a dask dataframe包含基于其他列中的值的相似性的一列的值的平均值

import dask.dataframe as dd
import dask.array as da

df = dd.from_pandas(pandas_df, npartitions=n)  # pandas_df是一个Pandas DataFrame，n是分区数

similarity_column = df['similarity_column']  # 假设'similarity_column'是相似性列的名称

average_value = da.mean(similarity_column).compute()  # 使用Dask Array计算平均值

df['new_column'] = average_value  # 'new_column'是新列的名称

import dask.dataframe as dd
import dask.array as da

# 创建Dask DataFrame
df = dd.from_pandas(pandas_df, npartitions=n)

# 计算相似性列的值
similarity_column = df['similarity_column']

# 计算相似性列的值的平均值
average_value = da.mean(similarity_column).compute()

# 添加新列到Dask DataFrame
df['new_column'] = average_value