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

jc_show 日志拆分脚本

Browse Source
This commit is contained in:
pengtao 2019-09-20 16:27:31 +08:00
parent f50f629b52
commit c620312229
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
jc_show_rewrite.py
View File

@ -32,6 +32,7 @@ class JcShowInit:
def get_data(self): def get_data(self):
sql = f"""SELECT sql = f"""SELECT
"#account_id", "#account_id",
"#server_time",
button_param button_param
FROM FROM
v_event_{self.suffix} v_event_{self.suffix}
@ -67,11 +68,12 @@ class JcShowInit:
"""6001_1004_oQmL74ij2oq3SyvO6QriuD0EJSjE """6001_1004_oQmL74ij2oq3SyvO6QriuD0EJSjE
{"ad_id":["1039","1035","1037","1036","1038","1040"],"pos":"1,0,5,0,0","ad_channel":["wxdb103a128e118619","wxf4b70c770560c2fe","wx7d84fae7fe8796d7","wx1dd2f605f4f8496b","wx2f6ebc0586e24d61","wx0e14c9f4c4a06870"]}""" {"ad_id":["1039","1035","1037","1036","1038","1040"],"pos":"1,0,5,0,0","ad_channel":["wxdb103a128e118619","wxf4b70c770560c2fe","wx7d84fae7fe8796d7","wx1dd2f605f4f8496b","wx2f6ebc0586e24d61","wx0e14c9f4c4a06870"]}"""
for line in data: for line in data:
account, data_all = line account, show_time, data_all = line
data_dict = json.loads(data_all) data_dict = json.loads(data_all)
temp = {} temp = {}
temp['account_id'] = account temp['account_id'] = account
temp['location'] = data_dict['pos'] temp['location'] = data_dict['pos']
temp['show_time'] = show_time
if data_dict['ad_channel']: if data_dict['ad_channel']:
for ad_channel in data_dict['ad_channel']: for ad_channel in data_dict['ad_channel']:
temp['ad_channel'] = ad_channel temp['ad_channel'] = ad_channel