|
...
|
...
|
@@ -133,7 +133,7 @@ while True: |
|
|
|
if queue.is_was_time():
|
|
|
|
json_bodys = queue.get_all()
|
|
|
|
if middleware == 'mongodb':
|
|
|
|
r
|
|
|
|
r = mongodb_insert(db, measurement, json_bodys)
|
|
|
|
elif middleware == 'influxdb':
|
|
|
|
r = influxdb_insert(db, measurement, json_bodys)
|
|
|
|
if r:
|
...
|
...
|
|
