Changeset 9627 in ntrip

Timestamp:

Feb 21, 2022, 10:07:55 AM (3 years ago)

Author:

wiese

Message:

add bncLogstash script

Location:

trunk/BNC/scripts

Files:

• Common.pm (modified) (1 diff)
• bncLogstash.pl (added)

trunk/BNC/scripts/Common.pm

@@ -205 +205 @@
 }
 
+# toLineProtocol($rcd)
+# @brief  converts $rcd to InfluxDB line protocol
+# @see    https://docs.influxdata.com/influxdb/v2.1/reference/syntax/line-protocol/
+sub toLineProtocol {
+    my ($rcd) = @_;
+
+    my $err = 0;
+    my $str = $rcd->{'measurement'} . ',';
+
+    # Tags (sort by key (in lexicographic order) for performance reasons)
+    foreach ( sort { lc ($a) cmp lc ($b) } keys %{ $rcd->{'tags'} } ) {
+        if ( !exists $rcd->{'tags'}->{$_} ) {
+            $err++;
+            #next; # ?
+        }
+        $str .= $_ . "=" . $rcd->{'tags'}->{$_} . ",";
+    }
+    chop $str;
+    $str .= " ";
+
+    # Fields
+    while ( my ( $k, $v ) = each %{ $rcd->{'fields'} } ) {
+        if ( !defined $v ) {
+            $err++;
+        }
+        $str .= $k . "=" . $v . ",";
+    }
+    chop $str;
+    $str .= " " . $rcd->{'time'};    # prec=s
+    if ($err) {
+        return 0;
+    }
+    return $str;
+}
+
 #** @function rms ($numbers)
 # @brief  Compute the Root mean square.