首页 > 解决方案 > GCP DataPrep-移动窗口

问题描述

我有一个以下格式的 CSV 文件,我正试图与 GCP dataprep 争吵。

   Timestamp                 Tag           Value
   2018-05-01 09:00:00     Temperature     40.1
   2018-05-01 09:00:00     Humidity        80
   2018-05-01 09:05:00     Temperature     40.2
   2018-05-01 09:05:00     Humidity        80
   2018-05-01 09:10:00     Temperature     40.0
   2018-05-01 09:10:00     Humidity        82

数据以 5 分钟间隔延长 2 周。我想对其进行转换,以便在每 10 分钟间隔显示前 10 分钟的平均值(或最小值/最大值/中值)并对其进行旋转,这样我得到的最终结果如下:

  Timestamp             Temperature    Humidity
 2018-05-01 09:10:00      40.1         80.06

所以本质上,09:10 的值是 09:00、09:05 和 09:10 的平均值。

09:25 的值将是 09:15,09:20,09:25 的平均值。

我已经尝试过窗口函数和聚合,但似乎无法让它工作。

谢谢您的意见!

标签: google-cloud-platformgoogle-cloud-dataprep

解决方案



推荐阅读