diff --git a/ops/myinflux.py b/ops/myinflux.py index 00aee9b..0216d88 100644 --- a/ops/myinflux.py +++ b/ops/myinflux.py @@ -15,9 +15,8 @@ class Myinflux: def _write(self, body): try: - pdb.set_trace() self.influxdb.write_points(body) - print(f"write {body} 2 influx!") + #print(f"write {body} 2 influx!") return True except exceptions.InfluxDBClientError: log.error(f"write {body} to influx failed!", exc_info=True) diff --git a/real_task/tasks_base_real.py b/real_task/tasks_base_real.py index 64971f9..f4f148b 100644 --- a/real_task/tasks_base_real.py +++ b/real_task/tasks_base_real.py @@ -52,7 +52,6 @@ class RealData(GetFromTga): data[ad_channel].update(item) 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", @@ -81,7 +80,6 @@ class RealData(GetFromTga): out = self.tga.get_data(sql) data = {} for line in out: - print(f"line was {line}") try: share, share_people, ad_channel = line @@ -91,7 +89,6 @@ class RealData(GetFromTga): data[ad_channel] = item 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", @@ -104,13 +101,11 @@ class RealData(GetFromTga): def real_event_user(kwargs): # new_user,active_user,login_user - print(f"2 {kwargs}") rd = RealData(**kwargs) rd.event_user() def real_event_share(kwargs): # share_by_people,share_nums - print(f"3 {kwargs}") rd = RealData(**kwargs) rd.event_share() diff --git a/real_tasks.py b/real_tasks.py index c70689f..922474d 100644 --- a/real_tasks.py +++ b/real_tasks.py @@ -61,10 +61,10 @@ def simple_work(line): if __name__ == "__main__": - # run_tasks() - times = (datetime.date.today() - datetime.timedelta(days=1)).strftime('%Y-%m-%d') - b_time = (datetime.datetime.now() - datetime.timedelta(minutes=120)).strftime('%Y-%m-%d %H:%M:%S') - e_time = datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S') - for item in ((1004, 6001, 'user'), (1016, 6001, 'share')): - cc = CollectGameData(times, b_time, e_time) - cc.workflow() + run_tasks() + # times = (datetime.date.today() - datetime.timedelta(days=1)).strftime('%Y-%m-%d') + # b_time = (datetime.datetime.now() - datetime.timedelta(minutes=120)).strftime('%Y-%m-%d %H:%M:%S') + # e_time = datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S') + # for item in ((1004, 6001, 'user'), (1016, 6001, 'share')): + # cc = CollectGameData(times, b_time, e_time) + # cc.workflow()