From f44b67d5857bb667ee8ed2d6070ddbbf0bdee92c Mon Sep 17 00:00:00 2001 From: wuaho Date: Sat, 14 Aug 2021 15:16:28 +0800 Subject: [PATCH] 1 --- clear_up.py => clear_up.py.template | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) rename clear_up.py => clear_up.py.template (91%) diff --git a/clear_up.py b/clear_up.py.template similarity index 91% rename from clear_up.py rename to clear_up.py.template index a39bea0..66d8b89 100644 --- a/clear_up.py +++ b/clear_up.py.template @@ -2,7 +2,9 @@ import json from settings import settings -game = 'xiangsu' +game = '' +db = settings.GAME + server_list_url = f'http://gametools.legu.cc/?app=api&act=getServerList&game={game}' import pandas as pd @@ -15,7 +17,7 @@ df = df[~df['hostname'].isin(['119.3.89.14', '119.3.105.109'])] serverid = tuple((str(i) for i in df['serverid'].to_list())) sql = f"""select `#account_id`, `#event_time`, `#event_name`,`#os`,`svrindex`, count() as n -from {game}.event +from {db}.event where lower(`#os`) = 'windows' or svrindex not in {serverid} @@ -34,7 +36,7 @@ data_df = pd.DataFrame( data_df.drop('n', axis=1, inplace=True) data_df['sign'] = -1 data_df['#event_time'] = data_df['#event_time'].apply(lambda x: x.strftime('%Y-%m-%d %H:%M:%S')) -insert_sql = f'INSERT INTO {game}.event FORMAT JSONEachRow ' +insert_sql = f'INSERT INTO {db}.event FORMAT JSONEachRow ' insert_sql = insert_sql + '\n'.join([json.dumps(item) for item in data_df.T.to_dict().values()]) client.execute(insert_sql)