Flux OHLCV query

gistfile1.txt

base = from(bucket: "stocks")
        |> range(start: _start)
        |> filter(fn: (r) => r._measurement == "stock" and r.symbol == _symbol)

get = (field, fn) =>
    base
        |> filter(fn: (r) => r._field == field)
        |> aggregateWindow(every: _every, fn: fn, createEmpty: true)

union(tables: [
    get(field: "o", fn: first),
    get(field: "h", fn: max),
    get(field: "l", fn: min),
    get(field: "c", fn: last),
    get(field: "v", fn: sum)
])
    |> group()
    |> pivot(
        rowKey: ["_time"],
        columnKey: ["_field"],
        valueColumn: "_value"
    )