如何使用"timeseries“从pydruid运行这个Druid SQL查询？

Question

以下是Druid SQL中的代码。我的目标是从Python运行这段代码。我可以使用DB API来做到这一点，但我想知道是否有一种方法可以使用would函数"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;

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