添加调试信息

@@ -75,6 +75,9 @@ while True:
             measurement = Config.info_channel+time.strftime('_%Y%m%d')
             measurement = Config.info_channel+time.strftime('_%Y%m%d')
 
 
             json_body = dict(data['data'],**data['tags'])
             json_body = dict(data['data'],**data['tags'])
+
+            if json_body['message'] == 'sdhfsodifjoisdfsoi':
+                print json_body
             
             
             middleware = 'mongodb'
             middleware = 'mongodb'
 
 

@@ -93,6 +93,7 @@ def connect_close():
 #数据入库定时器
 #数据入库定时器
 def data_pull_timer(queue):
 def data_pull_timer(queue):
     data_pull(queue,'Timer')
     data_pull(queue,'Timer')
+    print 'new Timer'
     Timer(Config.multi_insert_timeout,data_pull_timer,[queue]).start()
     Timer(Config.multi_insert_timeout,data_pull_timer,[queue]).start()
 
 
 #数据入库
 #数据入库