From 7cd5f09aa80ec7c2e50ca611cca2710dc08161f6 Mon Sep 17 00:00:00 2001 From: pengtao Date: Mon, 19 Aug 2019 17:06:44 +0800 Subject: [PATCH] =?UTF-8?q?=20=E6=96=B0=E5=A2=9E=E5=AE=9E=E6=97=B6?= =?UTF-8?q?=E6=95=B0=E6=8D=AE=E9=87=87=E9=9B=86=E8=84=9A=E6=9C=AC?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- real_task/tasks_base_real.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/real_task/tasks_base_real.py b/real_task/tasks_base_real.py index c63c4d6..50e42b4 100644 --- a/real_task/tasks_base_real.py +++ b/real_task/tasks_base_real.py @@ -47,7 +47,7 @@ class RealData(GetFromTga): data[ad_channel]['login_user'] = login_user except: pass - + print(f"2 {data}") 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", @@ -75,13 +75,14 @@ class RealData(GetFromTga): out = self.tga.get_data(sql) data = {} for line in out: + print(f"line was {line}") try: shares, share_people, ad_channel = line data[ad_channel]['shares'] = shares data[ad_channel]['share_people'] = share_people except: pass - + print(f"3 {data}") 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",