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

fix bug

Browse Source
This commit is contained in:
pengtao 2019-08-19 17:27:34 +08:00
parent 726615f578
commit ef50e5ff97
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
real_task/tasks_base_real.py
View File

@ -59,6 +59,7 @@ class RealData(GetFromTga):
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",
"ad_channel": key,
"channelid": self.channelid}, "channelid": self.channelid},
"fields": {"new_user": data[key]['new_user'], "logins": data[key]['logins'], "fields": {"new_user": data[key]['new_user'], "logins": data[key]['logins'],
"login_user": data[key]['login_user']}}] "login_user": data[key]['login_user']}}]
@ -98,6 +99,7 @@ class RealData(GetFromTga):
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",
"ad_channel": key,
"channelid": self.channelid}, "channelid": self.channelid},
"fields": {"shares": data[key]['shares'], "share_people": data[key]['share_people']}}] "fields": {"shares": data[key]['shares'], "share_people": data[key]['share_people']}}]
influx = Myinflux() influx = Myinflux()