log2iso_init.py

import sys
from configparser import ConfigParser
from sqlalchemy import create_engine
from opensipkd.views.models import Conf
from ..log_models import Base
from .common import (
    my_registry,
    append_csv,
    create_session,
    get_module_object,
    )


def main(argv=sys.argv[1:]):
    conf_file = argv[0]
    conf = ConfigParser()
    conf.read(conf_file)
    cf = dict(conf.items('main'))
    db_url = cf['report_db_url']
    my_registry['db_session'] = db_session = create_session(db_url, True)
    Conf.metadata.create_all(db_session.bind)
    append_csv(Conf, 'conf_log2iso.csv', ['nama'])
    db_session.commit()
    if 'models' in cf:
        models = get_module_object(cf['models'])
    db_url = conf.get('main', 'db_url')
    engine = create_engine(db_url, echo=True)
    Base.metadata.create_all(engine)