X-Git-Url: https://gerrit.mcp.mirantis.com/gitweb?p=salt-formulas%2Finfluxdb.git;a=blobdiff_plain;f=influxdb%2Fclient.sls;h=f698a64e8e31a02b690521e2fd2b195be655fea5;hp=f3125310614d4d20a124d4be1bd4c7ebf7a2ed05;hb=a20e49917c64e9935d212fcb7d81d7a1688c63ce;hpb=1f97c70a8a80548da8e09ea0ec4aeb43f9e05d11

diff --git a/influxdb/client.sls b/influxdb/client.sls
index f312531..f698a64 100644
--- a/influxdb/client.sls
+++ b/influxdb/client.sls
@@ -80,4 +80,18 @@ influxdb_grant_{{ grant_name }}:
   {%- endif %}
 {%- endfor %}
 
+
+{# CONTINUOUS QUERIES #}
+{%- for db_name, db in client.get('database', {}).iteritems() %}
+  {%- set db_name = db.get('name', db_name) %}
+  {%- for cq_name, cq in db.get('continuous_query', {}).iteritems() %}
+    {%- set query_continuous_query = 'CONTINUOUS QUERY {} ON {} BEGIN {} END'.format(cq_name, db_name, cq ) %}
+influxdb_continuous_query_{{db_name}}_{{ cq_name }}:
+  cmd.run:
+    - name: {{ curl_command }} -s -S -POST "{{ auth_url }}" --data-urlencode "q=CREATE {{ query_continuous_query }}"|grep -v "already exists" || {{ curl_command }} -s -S -POST "{{ auth_url }}" --data-urlencode "q=ALTER {{ query_continuous_query }}"
+    - onlyif: {{ curl_command }} -s -S -POST "{{ auth_url }}" --data-urlencode "q=SHOW DATABASES" | grep {{ db_name }}
+
+  {%- endfor %}
+{%- endfor %}
+
 {%- endif %}