import asyncio
from collections import OrderedDict
from time import time
+from osm_lcm.data_utils.database.database import Database
+from osm_lcm.data_utils.filesystem.filesystem import Filesystem
+
# from osm_common.dbbase import DbException
__author__ = "Alfonso Tierno"
class LcmBase:
- def __init__(self, db, msg, fs, logger):
+ def __init__(self, msg, logger):
"""
:param db: database connection
"""
- self.db = db
+ self.db = Database().instance.db
self.msg = msg
- self.fs = fs
+ self.fs = Filesystem().instance.fs
self.logger = logger
def update_db_2(self, item, _id, _desc):
# NS/NSI: "services" VIM/WIM/SDN: "accounts"
topic_service_list = ['ns', 'nsi']
- topic_account_list = ['vim', 'wim', 'sdn', 'k8scluster', 'k8srepo']
+ topic_account_list = ['vim', 'wim', 'sdn', 'k8scluster', 'vca', 'k8srepo']
# Map topic to InstanceID
topic2instid_dict = {
'wim': 'wim_accounts',
'sdn': 'sdns',
'k8scluster': 'k8sclusters',
+ 'vca': 'vca',
'k8srepo': 'k8srepos'}
- def __init__(self, worker_id=None, db=None, logger=None):
+ def __init__(self, worker_id=None, logger=None):
self.task_registry = {
"ns": {},
"nsi": {},
"wim_account": {},
"sdn": {},
"k8scluster": {},
+ "vca": {},
"k8srepo": {},
}
self.worker_id = worker_id
- self.db = db
+ self.db = Database().instance.db
self.logger = logger
def register(self, topic, _id, op_id, task_name, task):