Skip to content

Parametrized flux queries against influxdb cloud #82

@syed-imam

Description

@syed-imam

Missing support for parametrized flux queries which influxdb api supports

We should ideally be able to write a parametrized flux query like below:

  query = """
  from(bucket: params.bucket)
  |> range(start: #{range.from}T04:00:00.000Z, stop: #{range.to}T03:59:00.000Z)
  |> filter(fn: (r) => r._measurement == params.series)
  |> pivot(rowKey:["_time"], columnKey: ["_field"], valueColumn: "_value")
  |> group()
  |> map(fn: (r) => ({ r with _value: 1 }))
  |> count()
  """

InfluxConnection.query(query, params: %{bucket: "test", series: "series"})

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions