1

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)