diff --git a/taptap/tap2influxdb.py b/taptap/tap2influxdb.py index 3327e4f..d648add 100644 --- a/taptap/tap2influxdb.py +++ b/taptap/tap2influxdb.py @@ -19,7 +19,7 @@ class TAP2Influx: self.tga = FromTga(url=url, token=api_secret) self.day = day self.influx = InfluxDBClient('10.10.3.19', '8086', 'miles', 'aspect', 'tap_data') - self.measurement = "tapdata" + self.measurement = "tapdata_new" def get_tga_data(self): sql = f"""SELECT @@ -47,9 +47,10 @@ class TAP2Influx: try: for line in data: gameid, catename, cate, title, score, tag, reserve, watch, download, sell, review, topic, createdat = line - tags = {"gameid": int(gameid), "catename": catename, "cate": cate, "catedat": createdat} + tags = {"gameid": int(gameid), "catename": catename} fields = {"title": title, "score": score, "tag": tag, "reserve": reserve, "watch": watch, - "download": download, "sell": sell, "review": review, "topic": topic} + "download": download, "sell": sell, "review": review, "topic": topic, "cate": cate, + "catedat": createdat} temp = {"measurement": self.measurement, "tags": tags, "fields": fields} body.append(temp) except Exception: