freifunk_node: change influxdb schema
This commit is contained in:
parent
1e77ecffa9
commit
0b43530561
|
@ -42,18 +42,32 @@ def recurse(data, values, prefix='')
|
||||||
end
|
end
|
||||||
else
|
else
|
||||||
if data[0] =~ /^\d+$/
|
if data[0] =~ /^\d+$/
|
||||||
values[prefix] = data[0].to_i
|
values[prefix] = data[0].to_f
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
elsif data.kind_of? Integer or data.kind_of? Float
|
elsif data.kind_of? Integer or data.kind_of? Float
|
||||||
values[prefix] = data
|
values[prefix] = data.to_f
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|
||||||
node_id = data['data']['common']['node']
|
node_id = data['data']['common']['node']
|
||||||
|
node_name = data['data']['contact']['name']
|
||||||
recurse data['data'], values
|
recurse data['data'], values
|
||||||
|
|
||||||
|
points = values.map do |k, v|
|
||||||
|
{ series: 'node',
|
||||||
|
tags: {
|
||||||
|
node_id: node_id,
|
||||||
|
node_name: node_name,
|
||||||
|
},
|
||||||
|
values: {
|
||||||
|
key: k,
|
||||||
|
value: v,
|
||||||
|
},
|
||||||
|
}
|
||||||
|
end
|
||||||
|
|
||||||
db = InfluxDB::Client.new(url: "http://grafana.hq.c3d2.de:8086/freifunk")
|
db = InfluxDB::Client.new(url: "http://grafana.hq.c3d2.de:8086/freifunk")
|
||||||
db.write_point 'node', { values: values, tags: { node_id: node_id } }
|
db.write_points points
|
||||||
|
|
Loading…
Reference in New Issue
Block a user