ops/datacollect
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix bug

Browse Source
This commit is contained in:
pengtao 2019-08-19 17:13:23 +08:00
parent 4eca358f4d
commit 43959675f9
2 changed files with 10 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
real_task/tasks_base_real.py
View File

@ -2,7 +2,7 @@
from mytask.tga import GetFromTga from mytask.tga import GetFromTga
from config.config_real import influx_meas from config.config_real import influx_meas
from ops.myinflux import Myinflux from ops.myinflux import Myinflux
import pdb
class RealData(GetFromTga): class RealData(GetFromTga):
def event_user(self): def event_user(self):
@ -42,7 +42,7 @@ class RealData(GetFromTga):
try: try:
for lin in out_login: for lin in out_login:
print(f"l={lin}") pdb.set_trace()
logins, login_user, ad_channel = lin logins, login_user, ad_channel = lin
if ad_channel == "": if ad_channel == "":
ad_channel = 'all' ad_channel = 'all'
@ -79,6 +79,7 @@ class RealData(GetFromTga):
data = {} data = {}
for line in out: for line in out:
print(f"line was {line}") print(f"line was {line}")
pdb.set_trace()
try: try:
shares, share_people, ad_channel = line shares, share_people, ad_channel = line
if ad_channel == "": if ad_channel == "":

8
real_tasks.py
View File

@ -61,4 +61,10 @@ def simple_work(line):
if __name__ == "__main__": if __name__ == "__main__":
run_tasks() # 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()