...
|
...
|
@@ -92,12 +92,11 @@ def connect_close(): |
|
|
|
|
|
#数据入库定时器
|
|
|
def data_pull_timer(insert_data):
|
|
|
print insert_data
|
|
|
print time.time()
|
|
|
for middleware,dbs in insert_data.items():
|
|
|
for db,measurements in dbs.items():
|
|
|
for measurement,queue in measurements.items():
|
|
|
print queue
|
|
|
#data_pull(queue,'Timer')
|
|
|
data_pull(queue,'Timer')
|
|
|
Timer(Config.multi_insert_timeout,data_pull_timer,[insert_data]).start()
|
|
|
|
|
|
#数据入库
|
...
|
...
|
|