时间戳

首页 > 解决方案 > 在mysql中添加列移动平均线

python - 在mysql中添加列移动平均线

问题描述

我目前正在将加密市场数据添加到我的 mysql 数据库中。我每分钟有以下数据：

Open time 
Close time
Highest price
Lowest price 
Number of trades

我想将不同时间段的简单移动平均值添加到 mysql 数据库中。我尝试在 python 中进行此计算，但这需要很长时间。因此，我使用以下查询计算了 50 天时间段的 SMA。

mycursor.execute(
    """select 
           open_date,
           avg(close) over(rows between 49 preceding and current row) 
       from {}""".format(use_table)
)

但是，除了进行查询之外，我还想直接更新数据库中 SMA 的结果。最好是，我想要一个能够更新所有尚未计算的 SMA 的查询。因为我每天更新一次数据库。

由于我是使用 SQL 的新手，因此有关如何使用 SMA 更新列的任何建议都会非常有帮助。

标签： pythonmysqlsqlsql-updatemoving-average

解决方案

可以将您的SELECT查询转换为UPDATE. AVG(...) OVER(...)诀窍是在 suquery中调用窗口函数 ( )。您可以使用WHERE子句仅更新尚未计算的记录。

UPDATE mytable trg
INNER JOIN (
    SELECT
        open_date,
        AVG(close) OVER(ROWS BETWEEN 49 PRECEDING AND CURRENT ROW) sma
    FROM mytable
) src ON trg.id = src.id
SET trg.sma = src.sma
WHERE trg.sma IS NULL;

推荐阅读