diff --git a/real_task/tasks_base_real.py b/real_task/tasks_base_real.py index cde0446..3633363 100644 --- a/real_task/tasks_base_real.py +++ b/real_task/tasks_base_real.py @@ -2,7 +2,7 @@ from mytask.tga import GetFromTga from config.config_real import influx_meas from ops.myinflux import Myinflux - +import pdb class RealData(GetFromTga): def event_user(self): @@ -42,7 +42,7 @@ class RealData(GetFromTga): try: for lin in out_login: - print(f"l={lin}") + pdb.set_trace() logins, login_user, ad_channel = lin if ad_channel == "": ad_channel = 'all' @@ -79,6 +79,7 @@ class RealData(GetFromTga): data = {} for line in out: print(f"line was {line}") + pdb.set_trace() try: shares, share_people, ad_channel = line if ad_channel == "": diff --git a/real_tasks.py b/real_tasks.py index f6298db..c70689f 100644 --- a/real_tasks.py +++ b/real_tasks.py @@ -61,4 +61,10 @@ def simple_work(line): if __name__ == "__main__": - run_tasks() \ No newline at end of file + # 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()