view service/rdf_to_mqtt/config.n3 @ 1745:d90cb7c06f15

try to crash if mqtt doesn't connect
author drewp@bigasterisk.com
date Thu, 09 Nov 2023 17:21:59 -0800
parents fdddbdaf07b5
children
line wrap: on
line source

@prefix : <http://projects.bigasterisk.com/room/> .
@prefix rdfs: <http://www.w3.org/2000/01/rdf-schema#> .
@prefix fr: <http://bigasterisk.com/foaf/> .

:kitchenSkylight a :Device;
  :mqttTopicHead ("h801_skylight" "light");
  :convertedAttr [
    :deviceAttr :white;
    :mqttTopicTail ("kit_w1" "command");
    :valueConversion :to8Bit;
    :message '{"state":"ON","brightness":%value%}'
  ],
  :convertedAttr [
    :deviceAttr :color;
    :mqttTopicTail ("kit_r" "command");
    :valueConversion :extractRed8Bit;
    :message '{"state":"ON","brightness":%value%}'
   ],
  :convertedAttr [
    :deviceAttr :color;
    :mqttTopicTail ("kit_g" "command");
    :valueConversion :extractGreen8Bit;
    :message '{"state":"ON","brightness":%value%}'
   ],
  :convertedAttr [
    :deviceAttr :color;
    :mqttTopicTail ("kit_r" "command");
    :valueConversion :extractBlue8Bit;
    :message '{"state":"ON","brightness":%value%}'
   ],

:nightlightAriTemperature a :ExportedMeasurement;
  :mqttTopicHead ("nightlight_ari" "sensor" "temperature" "state");

  :missingAfterSec 150;
  :ignoreInputValueBelow -999;

  :valueProcess [
    :conversion :celsiusToFarenheit; #and round(x,2)
    ];

  :graphStatements [
    :outputPredicate :temperatureF;  
    :statementLifetime :untilReplaced;

    # is this just another valueProcess?
    :outputRecentPredicate :recentLowTemperatureF; :recentPeriodSec 30;
  ],
  
  :influxMeasurement [
    :measurement "temperatureF";
    :predicate :temperatureF;
    :tag [:key "host"; :value "nightlight_ari"],
         [:key "location"; :value "ariRoom"]] .