| |
| |
| |
| |
| |
| import glob |
| import os |
| import re |
| import shutil |
| import sys |
| import time |
|
|
| os.chdir("/www/server/panel") |
| sys.path.append('class/') |
| import public |
|
|
| print('==================================================================') |
| print('★[' + time.strftime("%Y/%m/%d %H:%M:%S") + ']，切割日志') |
| print('==================================================================') |
| print('|--当前保留最新的[' + sys.argv[2] + ']份') |
|
|
| logsPath = '/www/wwwlogs/' |
| is_gzip = not os.path.exists('/www/server/panel/data/log_not_gzip.pl') |
|
|
|
|
| def split_log(siteName, num): |
| global logsPath, is_gzip |
| res = public.M('sites').where('name=?', (siteName,)).select()[0]['project_type'].lower() |
| if res == 'php': |
| res = '' |
| else: |
| res = res + '_' |
| |
| directory = '/etc/init.d/' |
| files = os.listdir(directory) |
| file_list = list(files) |
| print('|-正在处理网站: {}'.format(siteName)) |
| if 'nginx' in file_list: |
| config_path = '/www/server/panel/vhost/nginx/{}.conf'.format(res + siteName) |
| config = public.readFile(config_path) |
| if not config: |
| print('|-正在处理网站:未检测到{}站点的日志'.format(siteName)) |
| return |
| logsPath = re.findall('access_log\s+([^;]+){}\.log;'.format(siteName), config)[0] |
| elif 'httpd' in file_list: |
| config_path = '/www/server/panel/vhost/apache/{}.conf'.format(res + siteName) |
| config = public.readFile(config_path) |
| if not config: |
| print('|-正在处理网站:未检测到{}站点的日志'.format(siteName)) |
| return |
| logsPath = re.findall('ErrorLog "(.*){}-error_log'.format(siteName), config)[0] |
| |
| |
| log_path = os.path.join(logsPath, 'history_backups', siteName) |
| if not os.path.exists(log_path): os.makedirs(log_path, 384) |
| logs = sorted(glob.glob(log_path + '/' + siteName + "_access_*")) |
| old_logs = sorted(glob.glob(logsPath + '/' + siteName + "*log_*.log")) |
| count = len(logs) |
| remove_num = count - num |
| |
| old_list = old_logs[:remove_num] |
| for i in old_list: |
| if os.path.exists(i): |
| os.remove(old_logs[i]) |
| print('|---多余日志[' + i + ']已删除!') |
| remove_num = remove_num - len(old_list) |
| for i in logs[:remove_num]: |
| if os.path.exists(i): |
| os.remove(i) |
| print('|---多余日志[' + i + ']已删除!') |
| err_file = i.replace('access', 'error') |
| if os.path.exists(err_file): |
| os.remove(err_file) |
| print('|---多余日志[' + err_file + ']已删除!') |
|
|
| his_date = time.strftime("%Y-%m-%d_%H%M%S") |
| ngx_access_log = os.path.join(logsPath, siteName + '.log') |
| ngx_error_log = os.path.join(logsPath, siteName + '.error.log') |
| if os.path.exists(ngx_access_log): |
| history_log_file = log_path + '/' + siteName + '_access_' + his_date + '.log' |
| shutil.move(ngx_access_log, history_log_file) |
| if is_gzip: |
| os.system('gzip {}'.format(history_log_file)) |
| print('|---已切割日志到:' + history_log_file + '.gz') |
| else: |
| print('|---已切割日志到:' + history_log_file + '.gz') |
| if os.path.exists(ngx_error_log): |
| history_log_file = log_path + '/' + siteName + '_error_' + his_date + '.log' |
| shutil.move(ngx_error_log, history_log_file) |
| if is_gzip: |
| os.system('gzip {}'.format(history_log_file)) |
| print('|---已切割日志到:' + history_log_file + '.gz') |
| else: |
| print('|---已切割日志到:' + history_log_file + '.gz') |
|
|
| httpd_access_log = os.path.join(logsPath, siteName + '-access_log') |
| httpd_error_log = os.path.join(logsPath, siteName + '-error_log') |
| if os.path.exists(httpd_access_log): |
| history_log_file = log_path + '/' + siteName + '_access_' + his_date + '.log' |
| if not os.path.exists(history_log_file): |
| shutil.move(httpd_access_log, history_log_file) |
| if is_gzip: |
| os.system('gzip {}'.format(history_log_file)) |
| print('|---已切割日志到:' + history_log_file + '.gz') |
| else: |
| print('|---已切割日志到:' + history_log_file + '.gz') |
| if os.path.exists(httpd_error_log): |
| history_log_file = log_path + '/' + siteName + '_error_' + his_date + '.log' |
| if not os.path.exists(history_log_file): |
| shutil.move(httpd_error_log, history_log_file) |
| if is_gzip: |
| os.system('gzip {}'.format(history_log_file)) |
| print('|---已切割日志到:' + history_log_file + '.gz') |
| else: |
| print('|---已切割日志到:' + history_log_file + '.gz') |
|
|
|
|
| def split_all(save): |
| sites = public.M('sites').field('name').select() |
| for site in sites: |
| split_log(site['name'], save) |
|
|
|
|
| if __name__ == '__main__': |
| num = int(sys.argv[2]) |
| if sys.argv[1].find('ALL') == 0: |
| split_all(num) |
| else: |
| siteName = sys.argv[1] |
| split_log(sys.argv[1], num) |
|
|
| public.serviceReload() |
|
|
