Postgres重新采样时间序列数据

Question

我在 Postgres 中以 1 分钟为增量存储了 OHLCV 股票数据。

我正在尝试将数据重新采样为 5 分钟间隔。我已使用此answer 生成以下 SQL 查询。

这是生成的 SQL 查询：

SELECT 
avg('open') AS open, 
avg('high') AS high, 
avg('low') AS low, 
avg('close') AS close, 
avg('volume') AS volume, 
avg('open_interest') AS open_interest, 
to_timestamp(floor(EXTRACT(epoch FROM 'timestamp') / 300) * 300) AS interval_alias 
WHERE 'symbol'='IRFC-N8' GROUP BY interval_alias

我收到此错误：

sqlalchemy.exc.ProgrammingError: (psycopg2.ProgrammingError) function avg(unknown) is not unique
LINE 1: SELECT avg('open') AS open, avg('high') AS high, avg('low') ...
               ^
HINT:  Could not choose a best candidate function. You might need to add explicit type casts.

你能告诉我出了什么问题吗？

编辑 1：为更好地呈现而格式化的代码。

编辑 2：根据下面的答案，我需要在 avg 函数的参数周围使用双引号。我正在使用 sqlalchemy 生成表达式，它正在创建单引号字符串。这是生成平均查询的代码部分：

    cols = list()
    cols.append(func.avg(self.p.open).label(self.p.open))
    cols.append(func.avg(self.p.high).label(self.p.high))
    cols.append(func.avg(self.p.low).label(self.p.low))
    cols.append(func.avg(self.p.close).label(self.p.close))
    cols.append(func.avg(self.p.volume).label(self.p.volume))
    cols.append(func.avg(self.p.openinterest).label(self.p.openinterest))
    seconds = self._get_seconds()
    cols.append(func.to_timestamp(func.floor(func.extract("epoch", "timestamp") / seconds) * seconds).label("interval_alias"))

SqlAlchemy 应该知道更好地使用双引号，但它会生成单引号。

Answer 1

db<>fiddle

您的错误是在您的 AVG() 调用中使用了单引号 ' 而不是双引号 "。单引号标记文本，但您想为平均值命名列。因此，您需要双引号或者可以保留它们（两种变体都显示在 db fiddle 中）。

编辑（真正的问题）： self.p.columnname 似乎只给出了列的名称，而不是列本身。在 SQLAlchemy 上，对特定列的引用是 table.c.columnname 用于引用特定列。请使用p 而不是c。

注意： 如果您平均所有数据，您可能会丢失重要数据作为真正的最小值和最大值。您可能希望与MIN 或MAX 等其他函数聚合。也许WITHIN GROUP 函数可以帮助你。

https://www.postgresql.org/docs/current/static/functions-aggregate.html

https://www.postgresql.org/docs/9.5/static/functions-aggregate.html#FUNCTIONS-ORDEREDSET-TABLE