加权平均的公式为：

weighted_average = sum of (value * weight) / sum of weights

由于您有时间戳，您可以使用该字段来计算每个产品的基于数量列的加权平均价格，其中窗口框架包括过去500秒内的所有行。下面是查询

查询：

with Stgquery as(
select
product,  SUM(price)  OVER  (PARTITION  BY product LIMIT  DURATION  (second, 500))  as denom,
sum(cast(price as float)  *  cast(quantity as float))  over  (PARTITION  by product LIMIT  DURATION  (second, 500))  as num
from
input)
select product,weighted_average=(num/denom)  from Stgquery

在此查询中，CTE stgquery选择product、每组product值的price列的累积和，以及每组product值的price和quantity列的乘积之和（使用SUM函数，窗口框架包括最近500秒内的所有行）。这可以根据需要进行更改）。SELECT语句选择product列，并根据quantity列为每组product值计算price列的加权平均值。通过将price和quantity列的乘积之和（存储在Stgquery CTE的num列中）除以price列的累积和（存储在Stgquery CTE的denom列中）来计算加权平均值。结果作为名为weighted_average的新列返回。

输出：

| 加权平均| weighted_average |
| --| ------------ |
| 一百| 100 |
| 两百| 200 |
| 两百| 200 |
| 204.3478| 204.3478 |
| 161.2676| 161.2676 |
| 134.9462| 134.9462 |
| 一百二十七点八九七| 127.897 |
| 175.4717| 175.4717 |
| 157.971| 157.971 |