Power Query中用梯形法实现流量Q的离散积分求累积体积V

针对你的需求，直接用List.Accumulate实现一次遍历的累加计算，避免重复求和导致的内存溢出问题，同时解决之前的语法错误。以下是适配你列名（Q为流量列、Time为时间列，上一步查询名为previousStep）的完整M代码：

let
    Source = previousStep,
    // 添加索引，方便关联前后行
    AddedIndex = Table.AddIndexColumn(Source, "Index", 0, 1, Int64.Type),
    // 将表转为记录列表，保留索引、Q、Time信息
    RecordList = Table.ToRecords(AddedIndex),
    // 使用List.Accumulate遍历计算，同时跟踪前一行的Q、Time和当前累积值
    Accumulated = List.Accumulate(
        RecordList,
        // 初始状态：累积值=0，前一行Q=null，前一行Time=null
        [CumulativeV = 0, PrevQ = null, PrevTime = null],
        (state, current) => 
            if current[Index] = 0 then
                // 首行累积值为0，更新前一行信息
                [CumulativeV = 0, PrevQ = current[Q], PrevTime = current[Time]]
            else
                let
                    // 计算时间差（秒）
                    DeltaT = Duration.TotalSeconds(current[Time] - state[PrevTime]),
                    // 梯形法计算当前段的体积增量
                    Increment = 0.5 * (current[Q] + state[PrevQ]) * DeltaT,
                    // 累积值更新
                    NewCumulative = state[CumulativeV] + Increment
                in
                    [CumulativeV = NewCumulative, PrevQ = current[Q], PrevTime = current[Time]]
    ),
    // 提取所有累积值并转为列表
    CumulativeList = List.Transform(RecordList, (x) => Accumulated[x[Index]][CumulativeV]),
    // 将累积列添加回原表
    AddedCumulativeV = Table.FromColumns(
        Table.ToColumns(Source) & {CumulativeList},
        Table.ColumnNames(Source) & {"V"}
    ),
    // 移除临时索引列（如果不需要的话）
    RemovedIndex = Table.RemoveColumns(AddedCumulativeV, {"Index"})
in
    RemovedIndex

错误原因解析 #

1. 最初代码的语法/逻辑错误：

   • List.Accumulate遍历的是Q列表，无法直接访问行上下文的Time列，所以[#"CA-27.Time"]会报未知标识符错误。
   • 缺少乘法运算符，current和Duration.TotalSeconds(...)之间没有*，同时语法结构混乱导致逗号缺失报错。

2. 后续代码的内存溢出问题：

   • 使用List.Sum(List.FirstN(#"Added Index"[Custom],[IndexDT]+1))时，每一行都要重新计算前N项的和，数据量较大时会产生O(n²)的时间复杂度，重复计算大量数据导致内存耗尽。

方案优势 #

• 仅需一次遍历即可完成所有计算，时间复杂度为O(n)，大幅提升效率并避免内存溢出。
• 直接在原表结构上添加累积列，保留所有原始数据，无需额外处理冗余列。

内容的提问来源于stack exchange，提问作者DanGitR