diff --git a/sql/2_gauge.sql b/sql/2_gauge.sql index 5b82735..f792f03 100644 --- a/sql/2_gauge.sql +++ b/sql/2_gauge.sql @@ -1,4 +1,4 @@ -CREATE TABLE mesure_gauge ( -- TODO ; revoir précudes d'injection de données pour faire la différence entre gauge et compteur +CREATE TABLE mesure_gauge ( -- TODO ; revoir procédures d'injection des données pour faire la différence entre gauge et compteur "date" TIMESTAMPTZ, id_captation INT NOT NULL, valeur float4 NOT NULL @@ -28,7 +28,7 @@ SELECT MAX(mg.valeur), MIN(mg.valeur) FROM mesure_gauge mg -GROUP BY id_captation, time_bucket(INTERVAL '1 hour', mg."date"); +GROUP BY 1, 2; SELECT add_continuous_aggregate_policy( -- On met à jour les données tt les h en relisant les données brutes entre 1 mois et 1 jour 'mesure_gauge_heure', @@ -48,7 +48,7 @@ SELECT MAX(mg.max), MIN(mg.min) FROM mesure_gauge_heure mg -GROUP BY id_captation, time_bucket(INTERVAL '1 DAY', mg."date"); +GROUP BY 1, 2; SELECT add_continuous_aggregate_policy( -- On met à jour les données tt les h en relisant les données brutes entre 1 mois et 1 jour 'mesure_gauge_jour', @@ -66,6 +66,6 @@ select average(rollup(valeur_temporelle)) AS moyenne -- rollup pour avour le concaténation des valeur_temporelle from mesure_gauge_heure mgh where mgh.id_captation = 59 -- puissance PAC -group by mgh.id_captation, time_bucket(INTERVAL '1 DAY', mgh."date") +group by 1, 2 order by "date" desc limit 1000; \ No newline at end of file diff --git a/sql/3_compteur.sql b/sql/3_compteur.sql index 5b1c7f2..6526f6f 100644 --- a/sql/3_compteur.sql +++ b/sql/3_compteur.sql @@ -1,4 +1,4 @@ -CREATE TABLE mesure_compteur ( -- TODO ; revoir précudes d'injection de données pour faire la différence entre gauge et compteur +CREATE TABLE mesure_compteur ( -- TODO ; revoir procédures d'injection des données pour faire la différence entre gauge et compteur "date" TIMESTAMPTZ, id_captation INT NOT NULL, valeur float4 NOT NULL @@ -26,9 +26,7 @@ SELECT time_bucket(INTERVAL '1 hour', mc."date") AS "date", counter_agg(mc."date", mc.valeur) AS valeur_temporelle FROM mesure_compteur mc -GROUP BY - id_captation, - time_bucket(INTERVAL '1 hour', mc."date"); +GROUP BY 1, 2; SELECT add_continuous_aggregate_policy('mesure_compteur_heure', -- On met à jour les données tt les h en relisant les données brutes entre 1 mois et 1 jour start_offset => INTERVAL '1 month', @@ -44,7 +42,7 @@ SELECT time_bucket(INTERVAL '1 DAY', mg."date") AS "date", rollup(valeur_temporelle) AS valeur_temporelle FROM mesure_compteur_heure mg -GROUP BY id_captation, time_bucket(INTERVAL '1 DAY', mg."date"); +GROUP BY 1, 2; SELECT add_continuous_aggregate_policy( -- On met à jour les données tt les h en relisant les données brutes entre 1 mois et 1 jour 'mesure_compteur_jour', @@ -66,5 +64,5 @@ SELECT last_val(rollup(mch.valeur_temporelle)) AS index_fin FROM mesure_compteur_heure mch where mch.id_captation = 89 -- HP -group by mch.id_captation, time_bucket(INTERVAL '1 DAY', mch."date") +group by 1, 2 order by "date" desc \ No newline at end of file