git.rot13.org Git - air-quality/blob - dsm501.pl

   1 #!/usr/bin/perl
   2 use warnings;
   3 use strict;
   4 # sudo apt install libdevice-serialport-perl libdata-dump-perl
   5 use Device::SerialPort;
   6 use Time::HiRes;
   7 use Data::Dump qw(dump);
   8
   9 my $port = shift @ARGV || '/dev/serial/by-path/platform-3f980000.usb-usb-0:1.3:1.0-port0';
  10 my $influx_url = shift @ARGV || 'http://10.13.37.92:8086/write?consistency=any&db=rot13';
  11 my $measurement = $ENV{MEASUREMENT} || 'dsm501';
  12
  13 my $s = new Device::SerialPort( $port ) || die $!;
  14 $s->baudrate(115200);
  15 $s->databits(8);
  16 $s->parity('none');
  17 $s->stopbits(1);
  18 $s->handshake('none');
  19 $s->read_char_time(0); # don't wait for each char
  20 $s->read_const_time(200); # ms for complete read
  21
  22
  23 while (1) {
  24
  25         my ($len, $string) = $s->read(128);
  26         my $t = int( Time::HiRes::time() * 1_000_000_000 );
  27         die $! if ! defined($len);
  28         if ( $len > 0 ) {
  29                 #warn "# len=$len ",dump($string);
  30                 if ( $string !~ m/^#/ ) {
  31                         $string =~ s/[\r\n]+$//;
  32                         $string =~ s/\s/,/g;
  33                         my $influx = "$measurement,dc=trnjanska $string $t";
  34                         print "$influx\n";
  35                         system "curl --silent -XPOST '$influx_url' --data-binary '$influx'"
  36                 } else {
  37                         warn "SKIP: $string\n";
  38                 }
  39         }
  40
  41 };
  42
  43
  44 $s->close;