在1列中计算多个聚合值并计算其最终总和

import tencentcloud.serverless as scf

def map_function(event, context):
    # 获取输入数据
    data = event['data']
    
    # 初始化聚合值
    sum1 = 0
    sum2 = 0
    
    # 计算聚合值
    for item in data:
        sum1 += item['value1']
        sum2 += item['value2']
    
    # 返回键值对
    return [{'key': 'sum1', 'value': sum1}, {'key': 'sum2', 'value': sum2}]

def reduce_function(event, context):
    # 获取输入数据
    data = event['data']
    
    # 初始化总和
    total_sum = 0
    
    # 计算总和
    for item in data:
        total_sum += item['value']
    
    # 返回总和
    return total_sum

# 创建SCF实例
scf_client = scf.Client()

# 定义输入数据
input_data = [
    {'value1': 10, 'value2': 20},
    {'value1': 30, 'value2': 40},
    {'value1': 50, 'value2': 60}
]

# 定义Map任务
map_task = scf.Task().set_handler(map_function).set_input({'data': input_data})

# 定义Reduce任务
reduce_task = scf.Task().set_handler(reduce_function)

# 执行MapReduce任务
result = scf_client.invoke(map_task).map(reduce_task).wait()

# 输出结果
print(result.get_output())