diff --git a/taptap/tap2influxdb.py b/taptap/tap2influxdb.py index f7ef4d8..f11e046 100644 --- 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):