1、累计用户添加ad_channel为空的数据 2、新增用户统计脚本
This commit is contained in:
parent
910db730b3
commit
aae626461c
@ -34,6 +34,7 @@ class InitFirstAD():
|
|||||||
def run(self):
|
def run(self):
|
||||||
users = self.get_new_user()
|
users = self.get_new_user()
|
||||||
mark_users = self.hide_user(users)
|
mark_users = self.hide_user(users)
|
||||||
|
log.info(f"write {len(mark_users)} to mysql!")
|
||||||
table_name = "newuser"
|
table_name = "newuser"
|
||||||
if mark_users:
|
if mark_users:
|
||||||
for line in mark_users:
|
for line in mark_users:
|
||||||
@ -45,8 +46,6 @@ class InitFirstAD():
|
|||||||
self.mysql.insert(table_name, temp)
|
self.mysql.insert(table_name, temp)
|
||||||
except Exception:
|
except Exception:
|
||||||
log.error(f"insert {line} to mysql Failed !", exc_info=True)
|
log.error(f"insert {line} to mysql Failed !", exc_info=True)
|
||||||
log.info(f"write {len(mark_users)} to mysql!")
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
def hide_user(self, data):
|
def hide_user(self, data):
|
||||||
|
Loading…
x
Reference in New Issue
Block a user