如何使用python脚本包括代码执行这个德鲁伊查询？

编程问答 2022-04-28

问题描述

这是我在特定时间段内的 sql 查询（对于特定的设备/指标组合，它需要一个小时内的平均“值”）。

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;

我想使用 pydruid 的“groupby”函数从 python 脚本运行上述内容。我尝试使用下面的代码，但我不确定如何在此处输入“Avg”函数。有谁知道这是否可能？谢谢！ （除非有比使用 groupby 函数更有效的方法）

 client = pydruid('datasource website','druid/v2')  
 ts = client.groupby(
        datasource='dataset',granularity='hour',intervals='/'.join(time_range),dimensions=["__time","value"],filter=((Dimension("device") == "device_1")) &
               (Dimension("metric") == "metric_1"),aggregations={"count": doublesum("count")}
    )

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

druidpydruidpythonsqlsql