如何在pyspark中动态聚合列

from pyspark.sql import SparkSession
from pyspark.sql.functions import col, sum

# 创建SparkSession
spark = SparkSession.builder.getOrCreate()

# 创建示例数据
data = [("Alice", 1, 100),
        ("Bob", 2, 200),
        ("Alice", 3, 300),
        ("Bob", 4, 400)]

df = spark.createDataFrame(data, ["Name", "ID", "Value"])

# 动态聚合列的列名
aggregated_column_name = "AggregatedValue"

# 动态列聚合
grouped_df = df.groupBy("Name").agg(*[
    sum(col("Value")).alias(aggregated_column_name)
])

grouped_df.show()