Faspex: Delete Package Older Than x Days

from glob import glob

from datetime import datetime, timedelta

from os import stat, path as os_path

from shutil import rmtree

from sys import path as sys_path

sys_path.insert(0, "./.")

import SQL

class RM:

def __init__(self, rqst=None, data=None):

self.connec = SQL.BDD()._connec()

self.rqst = rqst

self.data = data

self.doc_root = '/home/faspex/QNAP/ASPERA'

def __select_mysql(self):

sql = self.connec

cur = sql.cursor()

if self.data is None:

cur.execute(self.rqst)

else:

cur.execute(self.rqst % self.data)

fields = [field_md[0] for field_md in cur.description]

result = [dict(zip(fields, row)) for row in cur.fetchall()]

return result

def __write_log(self, level, msg):

with open('./remove.log', 'a') as file:

file.write(f"{[datetime.strftime(datetime.now(), '%Y-%m-%d %H:%M:%S')]} {level} {msg}\n")

return True

def remove_package_bis(self):

out_json = {}

rqst = "SELECT * FROM e_packages;"

select_older_package = RM(rqst=rqst).__select_mysql()

for x in select_older_package:

if x["updated_at"] < datetime.now() - timedelta(days=2) and x['e_package_upload_status'] != 'running':

out_json['updated_at'] = x["updated_at"]

out_json['outer_directory_name'] = x['outer_directory_name']

out_json['e_package_upload_status'] = x['e_package_upload_status']

try:

rmtree(path=f"'{os_path.join(self.doc_root, x['outer_directory_name'])}'")

RM().__write_log(level='INFO', msg=out_json)

except:

# print(f"'{os_path.join(self.doc_root, x['outer_directory_name'])}'")

pass

return True

if __name__ == "__main__":

RM().remove_package_bis()