byp4a55 professor6T9

Linux SamCT211 4.4.302+ #86009 SMP Wed Nov 26 18:19:20 CST 2025 x86_64
nginx/1.23.1
192.168.4.211

File Name : logmigrate.py

#!/bin/python3
#Copyright (c) 2000-2017 Synology Inc. All rights reserved.

import logging
import glob
import sys
import os
import sqlite3
from pwd import getpwuid
from datetime import datetime

'''
    Parse all 'default-log*' which owner is DNSServer, and inserted all into SYNODNSLOGDB.

When parsing any line failed, preserve this line into legacy-log.
    After parsed, whether success or not, delete default-log.
'''

LEGACY_LOGS = "/var/packages/DNSServer/target/named/var/log/legacy-log"
DEFAULT_LOGS = glob.glob("/var/packages/DNSServer/target/named/var/log/default-log*")
DBFILE = "/var/packages/DNSServer/target/named/var/log/SYNODNSLOGDB"
OWNER = "DNSServer"

def insert_log(conn, t):
    # NOTE: if need change table field, remember to change table definition in SYNODNSLogDBSizeSet(), synodnslog.conf
    conn.execute('INSERT INTO LOGS (TIME,TAG,CATAGORY,MODULE,SEVERITY,CONTENT) VALUES (?,?,?,?,?,?)', t);

def parse_line_get_time(line):
    time_raw = line[0:20]
    millisecond = int(line[21:25])

date = datetime.strptime(time_raw, '%d-%b-%Y %X')
    return "{0:04d}/{1:02d}/{2:02d} {3:02d}:{4:02d}:{5:02d}.{6:03d}".format(date.year, date.month, date.day, date.hour, date.minute, date.second, millisecond)

def parse_line_get_catagory_and_content(line):
    i = line.find(":",25)
    catagory = line[25:i]
    content = line[i+2:len(line)-1]
    return (catagory, content)

def parse_line(line):
    time = parse_line_get_time(line)
    catagory_content = parse_line_get_catagory_and_content(line)
    return (time,'',catagory_content[0], '', -1, catagory_content[1])

def parse_log_and_insert(conn, f):
    with open(LEGACY_LOGS, "w") as legacy_logs:
        with open(f) as fh:
            for line in fh:
                try:
                    t = parse_line(line)
                    insert_log(conn, t)

except Exception as e:
                    logging.error('Failed to insert log:' + str(e))
                    #unkown error, give up this log line
                    #log into legacy_logs
                    legacy_logs.write(line);
                    continue

def migrate_log(f):
    conn = sqlite3.connect(DBFILE)
    with conn:
        parse_log_and_insert(conn, f)
    return True

def migrate_default_log():
    for f in DEFAULT_LOGS:
        if (OWNER == getpwuid(os.stat(f).st_uid).pw_name):
            migrate_log(f)
            os.remove(f)

if __name__ == "__main__":
    if (False == os.path.isfile(DBFILE)):
        logging.error("Failed, {0} does not exist.".format(DBFILE))
        sys.exit(2)

migrate_default_log()

Name	Type	Size	Owner/Group	Permission	Last Modified	Actions
.	dir	-	115492/115492	0755	2023-03-17 09:55:26
..	dir	-	115492/115492	0755	2026-03-28 01:20:21
ad_zone_list.sh	text/x-shellscript	1.01 KB	115492/115492	0755	2023-03-17 09:55:26
flushcache.sh	text/x-shellscript	1.08 KB	115492/115492	0755	2023-03-17 09:55:26
logmigrate.py	text/x-script.python	2.53 KB	115492/115492	0755	2023-03-17 09:55:26
reload.sh	text/x-shellscript	210 B	115492/115492	0755	2023-03-17 09:55:26
restart.sh	text/x-shellscript	583 B	115492/115492	0755	2023-03-17 09:55:26
status.sh	text/x-shellscript	426 B	115492/115492	0755	2023-03-17 09:55:26

Team Anon Force

https://t.me/Professor6T9x