from osm_mon.core import database
from osm_mon.core.common_db import CommonDbClient
from osm_mon.core.config import Config
-from osm_mon.core.database import AlarmRepository, Alarm
+from osm_mon.core.database import AlarmRepository, Alarm, AlarmTagRepository
log = logging.getLogger(__name__)
severity: str,
statistic: str,
metric_name: str,
- vdur_name: str,
- vnf_member_index: str,
- nsr_id: str) -> Alarm:
+ tags: dict) -> Alarm:
database.db.connect()
try:
with database.db.atomic():
- return AlarmRepository.create(
+ alarm = AlarmRepository.create(
uuid=str(uuid.uuid4()),
name=name,
threshold=threshold,
operation=operation.lower(),
severity=severity.lower(),
statistic=statistic.lower(),
- monitoring_param=metric_name,
- vdur_name=vdur_name,
- vnf_member_index=vnf_member_index,
- nsr_id=nsr_id
+ metric=metric_name
)
+ for k, v in tags.items():
+ AlarmTagRepository.create(
+ name=k,
+ value=v,
+ alarm=alarm
+ )
+ return alarm
finally:
database.db.close()