FluxTrigger

id: influxdb_trigger
namespace: company.team
tasks:
  - id: each
    type: io.kestra.plugin.core.flow.ForEach
    values: "{{ trigger.rows }}"
    tasks:
      - id: return
        type: io.kestra.plugin.core.debug.Return
        format: "{{ json(taskrun.value) }}"
triggers:
  - id: watch
    type: io.kestra.plugin.influxdb.FluxTrigger
    interval: "PT5M"
    connection:
        url: "{{ secret('INFLUXDB_URL') }}"
        token: "{{ secret('INFLUXDB_TOKEN') }}"
    org: "{{ secret('INFLUXDB_ORG') }}"
    query: |
      from(bucket: "mybucket")
        |> range(start: -1h)
        |> filter(fn: (r) => r._measurement == "cpu")
        |> filter(fn: (r) => r._field == "usage_system")
        |> filter(fn: (r) => r._value > 80.0)