consolidator

1
import sqlalchemy as sa
2
import json
3
from MyConfig import MyConfig
4

5
if __name__=="__main__":
6
    try:
7
        mysql_prod= "mariadb+pymysql://uupadmin:uupadmin@vsys01775:3306"
8
        engine = sa.create_engine(mysql_prod)
9
        sql = sa.text("SELECT name, code FROM consolidation.handlers")
10
        cfg = MyConfig("consolidation.json")
11
        hdict:dict = cfg.get("level2 handlers",None)
12
        with engine.connect() as conn:
13
            for rec in conn.execute(sql):
14
                rdict = rec._asdict()
15
                with open(f"handlers2\\{hdict[rdict['name']]}.py",mode="w",encoding="utf-8") as f:
16
                    f.write(rdict["code"])
17
                    f.flush()
18
                    f.close()
19
                print(f"{rdict['name']} : {hdict[rdict['name']]} - done")
20
            conn.close()
21
    except Exception as exp:
22
        print(f"error: {exp}")
23