使用笔记本对数据进行降采样
创建一个笔记本以降采样数据。降采样在指定的时间间隔内聚合或总结数据,从而减少随着时间收集的数据的整体磁盘使用量。
以下示例创建一个笔记本,从过去一小时查询Coinbase比特币价格样本数据,将数据降采样为十分钟摘要,然后将降采样的数据写入InfluxDB桶。
如果您没有现有的存储桶来写入降采样的数据,创建一个新存储桶。
从您笔记本顶部的时间范围下拉列表中选择 过去 1 小时。
在构建查询单元格中:
- In the FROM column under Sample, select Coinbase bitcoin price.
- In the next FILTER column, select _measurement from the drop-down list and select the coindesk measurement in the list of measurements.
- In the next FILTER column, select _field from the drop-down list, and select the price field from the list of fields.
- In the next FILTER column, select code from the drop-down list, and select a currency code.
在您的 构建查询 单元格之后点击 以添加一个新单元格并选择 Flux 脚本.
在Flux脚本单元中:
使用
__PREVIOUS_RESULT__将上一个笔记本单元格的输出加载到Flux脚本中。使用
aggregateWindow()将数据窗口化为十分钟的间隔,并返回每个间隔的平均值。 指定以下参数:
__PREVIOUS_RESULT__ |> aggregateWindow(every: 10m, fn: mean)点击 在你的 Flux Script 单元格之后,添加一个新单元格并选择 。从 选择存储桶 下拉列表中选择一个存储桶。
(可选) 点击 并选择 备注 来 添加一个备注以描述您的笔记本,例如, “将Coinbase比特币价格降采样到每小时的平均值。”
点击预览在左上角以验证您的笔记本运行并显示输出。
点击 运行 以运行笔记本并将下采样的数据写入您的存储桶。
持续运行一个笔记本
要持续运行您的笔记本,请将笔记本导出为任务:
点击 以添加一个新单元格,然后选择 任务。
提供以下内容:
- 每个: 任务应运行的时间间隔。
- 偏移量: (可选) 在定义的时间间隔后等待的时间以执行任务。 这允许任务捕获迟到的数据。
点击 导出为任务。