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

add

Browse Source
This commit is contained in:
root 2019-09-03 16:15:45 +08:00
parent fa47f19cec
commit 74f6343dc3
1 changed files with 4 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
gather_new_user.py
View File

@ -28,9 +28,9 @@ def get_last_time(gameid, channelid, ad_channel):
data = mydb.query(sql)
try:
if not data:
last_time = "2019-09-02 00:00:00"
last_time = "2019-08-30 00:00:00"
else:
last_time = data[0][0]
last_time = data[0][0].strftime("%Y-%m-%d %H:%M:%S")
except Exception:
log.info("get last time form db failed!", exc_info=True)
last_time = None
@ -109,11 +109,8 @@ def gather_data(last_time, gameid, channelid, ad_channel):
def run(gameid, channelid, ad_channel):
now = datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S")
last_time = get_last_time(gameid, channelid, ad_channel)
try:
last_time = last_time.strftime("%Y-%m-%d %H:%M:%S")
except:
log.error(f"split times error ,{last_time}", exc_info=True)
raise Exception(f"split times error ,{last_time}")
if not last_time:
raise Except("last_time get failed")
while comp_datetime(now, last_time):
gather_data(last_time, gameid, channelid, ad_channel)
last_time = (datetime.datetime.strptime(last_time, "%Y-%m-%d %H:%M:%S") + datetime.timedelta(minutes=TimeDelay)).strftime("%Y-%m-%d %H:%M:%S")