projects
/
air-quality
/ commitdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
| commitdiff |
tree
raw
|
patch
|
inline
| side by side (parent:
198bb15
)
dev MEASUREMENT for any data from serial port
author
Dobrica Pavlinusic
<dpavlin@rot13.org>
Sun, 5 Jan 2020 19:22:01 +0000
(20:22 +0100)
committer
Dobrica Pavlinusic
<dpavlin@rot13.org>
Sun, 5 Jan 2020 19:22:22 +0000
(20:22 +0100)
dsm501.pl
patch
|
blob
|
history
diff --git
a/dsm501.pl
b/dsm501.pl
index
41578a5
..
8e183c8
100755
(executable)
--- a/
dsm501.pl
+++ b/
dsm501.pl
@@
-9,6
+9,7
@@
use Data::Dump qw(dump);
my $port = shift @ARGV || '/dev/ttyUSB2';
my $influx_url = shift @ARGV || 'http://10.13.37.229:8186/write?db=telegraf';
$influx_url = 'http://10.13.37.92:8086/write?db=rot13';
my $port = shift @ARGV || '/dev/ttyUSB2';
my $influx_url = shift @ARGV || 'http://10.13.37.229:8186/write?db=telegraf';
$influx_url = 'http://10.13.37.92:8086/write?db=rot13';
+my $measurement = $ENV{MEASUREMENT} || 'dsm501';
my $s = new Device::SerialPort( $port ) || die $!;
$s->baudrate(115200);
my $s = new Device::SerialPort( $port ) || die $!;
$s->baudrate(115200);
@@
-16,8
+17,8
@@
$s->databits(8);
$s->parity('none');
$s->stopbits(1);
$s->handshake('none');
$s->parity('none');
$s->stopbits(1);
$s->handshake('none');
-$s->read_char_time(
5);
-$s->read_const_time(
10);
+$s->read_char_time(
0); # don't wait for each char
+$s->read_const_time(
200); # ms for complete read
while (1) {
while (1) {
@@
-30,7
+31,7
@@
while (1) {
if ( $string !~ m/^#/ ) {
$string =~ s/[\r\n]+$//;
$string =~ s/\s/,/g;
if ( $string !~ m/^#/ ) {
$string =~ s/[\r\n]+$//;
$string =~ s/\s/,/g;
- my $influx = "
dsm501
,dc=trnjanska $string $t";
+ my $influx = "
$measurement
,dc=trnjanska $string $t";
print "$influx\n";
system "curl --silent -XPOST '$influx_url' --data-binary '$influx'"
} else {
print "$influx\n";
system "curl --silent -XPOST '$influx_url' --data-binary '$influx'"
} else {