influxdb/query.sls

{%- from "influxdb/map.jinja" import client with context %}

{%- if client.get('enabled') %}
{# CUSTOM QUERIES, intended to be called by salt_id #}

{%- set mconf = pillar.salt.minion.get('config', {}).get('influxdb') %}

{%- for db_name,db in client.get('database', {}).iteritems() %}
{%- set db_name = db.get('name', db_name) %}
{%- for qr_name,qr in db.get('query', {}).iteritems() %}

{%- if qr is string %}
{%- set query = { 'query': qr } %}
{%- endif %}

influxdb_query_{{ db_name }}_{{ qr_name }}:
  module.run:
    influxdb.query:
      - database: {{ db_name }}
      - query: {{ query }}
      - host: {{ mconf.host }}
      - port: {{ mconf.port }}
      {%- if qr.user is defined OR mconf.password is defined %}
      - user: {{ qr.get('user', mconf.user) }}
      {%- endif %}
      {%- if qr.password is defined OR mconf.password is defined %}
      - password: {{ qr.get('password', mconf.password) }}
      {%- endif %}
{%- endfor %}
{%- endfor %}