ereshzealous

from(bucket: "local")
|> range(start: -30d, stop: now())
|> filter(fn: (r) => r["_measurement"] == "ticks")
|> filter(fn: (r) => r["_field"] == "price")
|> filter(fn: (r) => r["product"] == "AGUX/USD")

|> window(period: 1h)
|> first()
|> yield(name: "first")

ereshzealous

data = from(bucket: "daily-aggregate")
|> range(start: -30d)
|> filter(fn: (r) => r["_measurement"] == "ticks")
|> filter(fn: (r) => r["_field"] == "price")
|> filter(fn: (r) => r["product"] == "AGUX/USD")
|> window(every: 1w) min = data

|> min()
|> set(key: "type", value: "min" ) max = data

ereshzealous

data = from(bucket: "local")
|> range(start: -30d)
|> filter(fn: (r) => r["_measurement"] == "ticks")
|> filter(fn: (r) => r["_field"] == "price")
|> filter(fn: (r) => r["product"] == "AGUX/USD")
|> window(every: 1w) min = data

|> min()
|> set(key: "type", value: "min" ) max = data

ereshzealous

option task = {name: "daily_aggregate", every: 1d}

max = from(bucket: "local")
|> range(start: -1y)
|> filter(fn: (r) =>
(r["_measurement"] == "ticks"))
|> filter(fn: (r) =>
(r["_field"] == "price"))
|> aggregateWindow(every: 1d, fn: max, createEmpty: false)

ereshzealous

data = from(bucket: "daily-aggregate")
|> range(start: -1d) |> filter(fn: (r) => r["_measurement"] == "ticks") |> filter(fn: (r) => r["product"] == "AGUX/USD") |> window(every: 1d) max = data
|> filter(fn: (r) => r["_field"] == "max") |> max()
|> set(key: "type", value: "max" ) min = data
|> filter(fn: (r) => r["_field"] == "min") |> min()
|> set(key: "type", value: "min" ) union(tables: [min, max])
|> group(columns:["type"], mode: "by")
|> yield()

ereshzealous

data = from(bucket: "local")

|> range(start: -1d) |> filter(fn: (r) => r["_measurement"] == "ticks") |> filter(fn: (r) => r["product"] == "AGUX/USD") |> window(every: 1d) max = data

|> filter(fn: (r) => r["_field"] == "max") |> max()

|> set(key: "type", value: "max" ) min = data

|> filter(fn: (r) => r["_field"] == "min") |> min()

ereshzealous

from(bucket: "local")
|> range(start: -1d)
|> filter(fn: (r) => r["_measurement"] == "ticks")
|> filter(fn: (r) => r["_field"] == "price")
|> filter(fn: (r) => r["product"] == "AGUX/USD")
|> aggregateWindow(every: 1d, fn: max, createEmpty: false)
|> yield(name: "max")
from(bucket: "local")
|> range(start: -1d)
|> filter(fn: (r) => r["_measurement"] == "ticks")

ereshzealous

version: "3"

services:

  influxdb:
    hostname: influxdb
    image: quay.io/influxdb/influxdb:v2.0.3
    container_name: influxdb
    ports:
      - '8099:8086'

ereshzealous

{
  "tableName": "MovieRating",
  "tableType": "REALTIME",
  "segmentsConfig": {
    "replication": 1,
    "timeColumnName": "ratedOn",
    "timeType": "DAYS",
    "retentionTimeUnit": "DAYS",
    "retentionTimeValue": 5,
    "schemaName": "MovieRatingSchema",

ereshzealous

{
  "schemaName": "MovieRatingSchema",
  "dimensionFieldSpecs": [
    {
      "name": "id",
      "dataType": "STRING"
    },
    {
      "name": "userId",
      "dataType": "STRING"