|
@@ -7,9 +7,16 @@ def post_data(field, keys, value):
|
|
|
headers = {'Content-Type': 'application/octet-stream'}
|
|
headers = {'Content-Type': 'application/octet-stream'}
|
|
|
tmpkeys = ",".join(["%s=%s" % (k, v) for k, v in keys.items()])
|
|
tmpkeys = ",".join(["%s=%s" % (k, v) for k, v in keys.items()])
|
|
|
if len(keys) > 0:
|
|
if len(keys) > 0:
|
|
|
- data = "%s,%s value=%s" % (field, tmpkeys, value)
|
|
|
|
|
|
|
+ data = "%s,%s" % (field, tmpkeys)
|
|
|
else:
|
|
else:
|
|
|
- data = "%s value=%s" % (field, value)
|
|
|
|
|
|
|
+ data = "%s" % field
|
|
|
|
|
+
|
|
|
|
|
+ if type(value) == dict:
|
|
|
|
|
+ values = ",".join(["%s=%s" % (k, v) for k, v in value.items()])
|
|
|
|
|
+ data = "%s %s" % (data, values)
|
|
|
|
|
+ else:
|
|
|
|
|
+ data = "%s value=%s" % (data, value)
|
|
|
|
|
+
|
|
|
print(data)
|
|
print(data)
|
|
|
try:
|
|
try:
|
|
|
ret = requests.post(influx_host, data=data, headers=headers)
|
|
ret = requests.post(influx_host, data=data, headers=headers)
|
|
@@ -32,4 +39,4 @@ if __name__ == '__main__':
|
|
|
for d in d.get_sources_with_count():
|
|
for d in d.get_sources_with_count():
|
|
|
val = d['_id'].replace(" ", r"\ ")
|
|
val = d['_id'].replace(" ", r"\ ")
|
|
|
post_data('totals', {'source': '%s' % val},
|
|
post_data('totals', {'source': '%s' % val},
|
|
|
- '%d,weight=%f' % (d['count'], d['weight']))
|
|
|
|
|
|
|
+ {'value': d['count'], 'weight': d['weight']})
|
