ops/datacollect
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

添加tap 2 influxdb脚本

Browse Source
This commit is contained in:
pengtao 2019-11-27 11:45:24 +08:00
parent b65a1bcdb1
commit afade09004
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
taptap/tap2influxdb.py
View File

@ -43,12 +43,11 @@ class TAP2Influx:
body = list() body = list()
data = self.tga.get_data(sql) data = self.tga.get_data(sql)
pdb.set_trace()
if data: if data:
try: try:
for line in data: for line in data:
gameid, catename, cate, title, score, tag, reserve, watch, download, sell, review, topic, createdat = line gameid, catename, cate, title, score, tag, reserve, watch, download, sell, review, topic, createdat = line
tags = {"gameid": str(gameid), "catename": catename, "cate": cate, "catedat": createdat} tags = {"gameid": int(gameid), "catename": catename, "cate": cate, "catedat": createdat}
fields = {"title": title, "score": score, "tag": tag, "reserve": reserve, "watch": watch, 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}
temp = {"measurement": self.measurement, "tags": tags, "fields": fields} temp = {"measurement": self.measurement, "tags": tags, "fields": fields}