diff --git a/real_task/tasks_base_real.py b/real_task/tasks_base_real.py index de65674..da04158 100644 --- a/real_task/tasks_base_real.py +++ b/real_task/tasks_base_real.py @@ -59,6 +59,7 @@ class RealData(GetFromTga): for key in data.keys(): body = [{"measurement": influx_meas, "tags": {"bengin": self.b_time, "end": self.e_time, "gameid": self.gameid, "type": "real_event_user", + "ad_channel": key, "channelid": self.channelid}, "fields": {"new_user": data[key]['new_user'], "logins": data[key]['logins'], "login_user": data[key]['login_user']}}] @@ -98,6 +99,7 @@ class RealData(GetFromTga): for key in data.keys(): body = [{"measurement": influx_meas, "tags": {"bengin": self.b_time, "end": self.e_time, "gameid": self.gameid, "type": "real_event_share", + "ad_channel": key, "channelid": self.channelid}, "fields": {"shares": data[key]['shares'], "share_people": data[key]['share_people']}}] influx = Myinflux()