From ef50e5ff97cd09fd0d896947f8b8f2cfeb7d47af Mon Sep 17 00:00:00 2001
From: pengtao <pengtao@kingsome.cn>
Date: Mon, 19 Aug 2019 17:27:34 +0800
Subject: [PATCH] fix bug

---
 real_task/tasks_base_real.py | 2 ++
 1 file changed, 2 insertions(+)

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()