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

新增实时数据采集脚本

Browse Source
This commit is contained in:
pengtao 2019-08-19 16:57:50 +08:00
parent 8f695fe463
commit 4affcbee08
2 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
real_task/tasks_base_real.py
View File

@ -93,11 +93,13 @@ class RealData(FromTga):
def real_event_user(kwargs): def real_event_user(kwargs):
# new_user,active_user,login_user # new_user,active_user,login_user
print(f"2 {kwargs}")
rd = RealData(**kwargs) rd = RealData(**kwargs)
rd.event_user() rd.event_user()
def real_event_share(kwargs): def real_event_share(kwargs):
# share_by_people,share_nums # share_by_people,share_nums
print(f"3 {kwargs}")
rd = RealData(**kwargs) rd = RealData(**kwargs)
rd.event_share() rd.event_share()

5
real_tasks.py
View File

@ -46,6 +46,7 @@ class CollectGameData():
kwargs['date'] = self.times kwargs['date'] = self.times
kwargs['b_time'] = self.b_time kwargs['b_time'] = self.b_time
kwargs['e_time'] = self.e_time kwargs['e_time'] = self.e_time
#print(f"1 {kwargs}")
func = f"real_event_{kwargs['event_type']}(kwargs)" func = f"real_event_{kwargs['event_type']}(kwargs)"
log.info(f"run {func} kwargs={kwargs}!") log.info(f"run {func} kwargs={kwargs}!")
eval(func) eval(func)
@ -53,8 +54,8 @@ class CollectGameData():
def simple_work(line): def simple_work(line):
times = (datetime.date.today() - datetime.timedelta(days=1)).strftime('%Y-%m-%d') times = (datetime.date.today() - datetime.timedelta(days=1)).strftime('%Y-%m-%d')
b_time = (datetime.date.today() - datetime.timedelta(minutes=1)).strftime('%Y-%m-%d %H:%M:%S') b_time = (datetime.datetime.now() - datetime.timedelta(minutes=1)).strftime('%Y-%m-%d %H:%M:%S')
e_time = datetime.date.today().strftime('%Y-%m-%d %H:%M:%S') e_time = datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S')
cc = CollectGameData(times, b_time, e_time) cc = CollectGameData(times, b_time, e_time)
cc.workflow(line) cc.workflow(line)