summaryrefslogtreecommitdiffstats
path: root/makefu/2configs/stats/telegraf/airsensor.nix
diff options
context:
space:
mode:
authorlassulus <lassulus@lassul.us>2017-12-31 03:02:48 +0100
committerlassulus <lassulus@lassul.us>2017-12-31 03:02:48 +0100
commitf2fe825333854ba8f07a95200c67194aeae0fb5f (patch)
tree3fb255c276a0d0bc305f619a944b8204a64bc702 /makefu/2configs/stats/telegraf/airsensor.nix
parentd5a69ce257d44c804d1edb679e5667eae6a71853 (diff)
parent181bd547f370848df1a49f886355e6fe8853c02f (diff)
Merge remote-tracking branch 'gum/master'
Diffstat (limited to 'makefu/2configs/stats/telegraf/airsensor.nix')
-rw-r--r--makefu/2configs/stats/telegraf/airsensor.nix36
1 files changed, 33 insertions, 3 deletions
diff --git a/makefu/2configs/stats/telegraf/airsensor.nix b/makefu/2configs/stats/telegraf/airsensor.nix
index 09d23e7d4..9d481000f 100644
--- a/makefu/2configs/stats/telegraf/airsensor.nix
+++ b/makefu/2configs/stats/telegraf/airsensor.nix
@@ -1,11 +1,36 @@
{ pkgs, ...}:
-
-{
+let
+ genTopic = name: topic: tags: {
+ servers = [ "tcp://localhost:1883" ];
+ qos = 0;
+ connection_timeout = "30s";
+ topics = [ topic ];
+ tags = tags;
+ persistent_session = false;
+ name_override = name;
+ data_format = "value";
+ data_type = "float";
+ };
+ bamStat = stat: # Temperature or Humidity
+ host: # easy{1-4}
+ sensor: # dht11, dht22, ds18
+ (genTopic stat
+ "/bam/${host}/${sensor}/${stat}"
+ {"host" = host;
+ "scope" = "bam";
+ "sensor" = sensor;
+ } );
+ dht22 = host: [(bamStat "Temperature" host "dht22")
+ (bamStat "Humidity" host "dht22")];
+ dht11 = host: [(bamStat "Temperature" host "dht11")
+ (bamStat "Humidity" host "dht11")];
+ ds18 = host: [(bamStat "Temperature" host "ds18")];
+in {
services.udev.extraRules = ''
SUBSYSTEMS=="usb", ATTRS{product}=="iAQ Stick", GROUP="input"
'';
users.users.telegraf.extraGroups = [ "input" ];
- services.telegraf.extraConfig.inputs.exec = [
+ services.telegraf.extraConfig.inputs.exec = [
{
commands = [ "${pkgs.airsensor-py}/bin/airsensor-py"];
timeout = "10s";
@@ -16,4 +41,9 @@
tags.unit="VOC";
}
];
+ services.telegraf.extraConfig.inputs.mqtt_consumer =
+ (dht22 "easy1")
+ ++ (dht22 "easy2")
+ ++ (dht11 "easy3")
+ ++ (ds18 "easy3");
}