golang 如何按 ParseDuration 来resample timeseries

可以使用 Go 的 time 包来解析时间间隔并重采样时间序列。以下是一个示例代码，假设原始时间序列在一个名为 "data" 的结构体中，该结构体包含一个时间戳字段和一个值字段：

import (
    "time"
)

type Data struct {
    Timestamp time.Time
    Value     float64
}

func resample(data []Data, durationString string) []Data {
    duration, err := time.ParseDuration(durationString)
    if err != nil {
        panic(err)
    }

    var resampled []Data
    var currentBucketStart time.Time
    var currentBucketSum float64
    var currentBucketCount int

    for _, d := range data {
        if currentBucketStart.IsZero() {
            currentBucketStart = d.Timestamp.Truncate(duration)
        }

        if d.Timestamp.Before(currentBucketStart.Add(duration)) {
            currentBucketSum += d.Value
            currentBucketCount++
        } else {
            resampled = append(resampled, Data{
                Timestamp: currentBucketStart.Add(duration / 2),
                Value:     currentBucketSum / float64(currentBucketCount),
            })

            currentBucketStart = currentBucketStart.Add(duration)
            currentBucketSum = d.Value
            currentBucketCount = 1
        }
    }

    if currentBucketCount > 0 {
        resampled = append(resampled, Data{
            Timestamp: currentBucketStart.Add(duration / 2),
            Value:     currentBucketSum / float64(currentBucketCount),
        })
    }

    return resampled
}

在上面的代码中，我们首先使用 ParseDuration 函数将输入的时间间隔字符串解析为一个 Duration 对象。然后，我们遍历每个数据点，将它们添加到当前时间桶中。如果下一个数据点的时间戳超出了当前时间桶，则表示当前时间桶已满，我们计算当前时间桶的平均值，并将其添加到输出序列中。最后，我们返回重采样后的时间序列。

使用此函数，您可以按任意时间间隔对时间序列进行重采样。例如，您可以按每小时、每天或每月对数据进行重采样。只需将所需的时间间隔字符串作为第二个参数传递给 resample 函数即可。例如：

resampled := resample(data, "1h") // 每小时重采样