如何使用“时间序列”从 pydruid 运行这个 Druid SQL 查询？答案

【问题标题】：How to run this Druid SQL query from pydruid using "timeseries"?如何使用“时间序列”从 pydruid 运行这个 Druid SQL 查询？
【发布时间】：2021-08-22 04:08:38
【问题描述】：

以下是 Druid SQL 中的代码。我的目标是从 Python 运行这段代码。我可以使用 DB API 来做到这一点，但我想知道是否有一种方法可以使用 hydroid 函数“timeseries”来做到这一点，因为我的其余代码会更好。我一直无法得到结果，因为我不确定如何将“Avg”函数实现到时间序列中。

谢谢！

  SELECT TIME_FLOOR(__time, 'PT1h') AS "__time_time_floor",
       AVG("value"), COUNT(*) AS "Count"
FROM "database"
WHERE "__time" >= CURRENT_TIMESTAMP - INTERVAL '1' DAY AND "device" = 'device_1'AND
      "metric"='metric_1'
GROUP BY 1
ORDER BY "__time_time_floor" DESC;

【问题讨论】：

标签： python sql database druid pydruid

【解决方案1】：

druid_host = "localhost"
druid_port = 8888
druid_path = "/druid/v2/sql"
druid_scheme = "http"
druid_query = """SELECT * FROM wikipedia LIMIT 10"""    
druid_connection = connect(host=druid_host, port=druid_port, path=druid_path, scheme=druid_scheme)
druid_cursor= druid_connection.cursor()
df = pd.DataFrame(druid_cursor.execute(druid_query))

【讨论】：