添加tap 2 influxdb脚本

2019-11-27 11:49:44 +08:00 · 2019-11-27 11:49:44 +08:00 · d1b1039feb
commit d1b1039feb
parent 9bc68a58f4
1 changed files with 7 additions and 5 deletions
--- a/taptap/tap2influxdb.py
+++ b/taptap/tap2influxdb.py
@ -54,11 +54,13 @@ class TAP2Influx:
                    body.append(temp)
            except Exception:
                log.error(f"split data failed ,{line}", exc_info=True)
-        try:
-            print(body)
-            self.influx.write_points(body)
-        except Exception:
-            log.error(f"write 2 influx failed,data={body}", exc_info=True)
+            try:
+                print(body)
+                self.influx.write_points(body)
+            except Exception:
+                log.error(f"write 2 influx failed,data={body}", exc_info=True)
+        else:
+            print(f"sql={sql}")


    def run(self):