mahlon/netdata-timescale-relay
1
0
Fork 0
Code Issues Pull requests Activity

Lowercase all hostnames before sending to the database.

Browse source
This commit is contained in:
Mahlon E. Smith 2018-06-26 09:47:23 -07:00
parent 68f253d460
commit d3e020362c
1 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

6
netdata_tsrelay.nim
View file

@ -44,7 +44,7 @@ import
const const
VERSION = "v0.1.0" VERSION = "v0.1.1"
USAGE = """ USAGE = """
./netdata_tsrelay [-q][-v][-h] --dbopts="[PostgreSQL connection string]" --listen-port=14866 --listen-addr=0.0.0.0 ./netdata_tsrelay [-q][-v][-h] --dbopts="[PostgreSQL connection string]" --listen-port=14866 --listen-addr=0.0.0.0
@ -130,7 +130,7 @@ proc parse_data( data: string ): seq[ JsonNode ] =
# #
var pivot: JsonNode var pivot: JsonNode
try: try:
let key = parsed["timestamp"].get_num let key = parsed[ "timestamp" ].get_num
if pivoted_data.has_key( key ): if pivoted_data.has_key( key ):
pivot = pivoted_data[ key ] pivot = pivoted_data[ key ]
@ -160,7 +160,7 @@ proc write_to_database( samples: seq[ JsonNode ] ): void =
for sample in samples: for sample in samples:
var var
timestamp = sample[ "timestamp" ].get_num timestamp = sample[ "timestamp" ].get_num
host = sample[ "hostname" ].get_str host = sample[ "hostname" ].get_str.to_lowerascii
sample.delete( "timestamp" ) sample.delete( "timestamp" )
sample.delete( "hostname" ) sample.delete( "hostname" )
db.exec sql( conf.insertsql ), timestamp, host, sample db.exec sql( conf.insertsql ), timestamp, host, sample