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

编程问答 2022-04-28

问题描述

以下是德鲁伊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;

解决方法

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))
databasedatabasedatabasedruidpydruidpythonsqlsql