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

新增实时数据采集脚本

Browse Source
This commit is contained in:
pengtao 2019-08-19 17:06:44 +08:00
parent bc75abd022
commit 7cd5f09aa8
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
real_task/tasks_base_real.py
View File

@ -47,7 +47,7 @@ class RealData(GetFromTga):
data[ad_channel]['login_user'] = login_user data[ad_channel]['login_user'] = login_user
except: except:
pass pass
print(f"2 {data}")
for key in data.keys(): for key in data.keys():
body = [{"measurement": influx_meas, body = [{"measurement": influx_meas,
"tags": {"bengin": self.b_time, "end": self.e_time, "gameid": self.gameid, "type": "real_event_user", "tags": {"bengin": self.b_time, "end": self.e_time, "gameid": self.gameid, "type": "real_event_user",
@ -75,13 +75,14 @@ class RealData(GetFromTga):
out = self.tga.get_data(sql) out = self.tga.get_data(sql)
data = {} data = {}
for line in out: for line in out:
print(f"line was {line}")
try: try:
shares, share_people, ad_channel = line shares, share_people, ad_channel = line
data[ad_channel]['shares'] = shares data[ad_channel]['shares'] = shares
data[ad_channel]['share_people'] = share_people data[ad_channel]['share_people'] = share_people
except: except:
pass pass
print(f"3 {data}")
for key in data.keys(): for key in data.keys():
body = [{"measurement": influx_meas, body = [{"measurement": influx_meas,
"tags": {"bengin": self.b_time, "end": self.e_time, "gameid": self.gameid, "type": "real_event_share", "tags": {"bengin": self.b_time, "end": self.e_time, "gameid": self.gameid, "type": "real_event_share",