threshold: int,
operation: str,
statistic: str = "AVERAGE",
+ action: str = '',
):
cor_id = random.randint(1, 10e7)
msg = self._build_create_alarm_payload(
threshold,
statistic,
operation,
+ action,
)
log.debug("Sending create_alarm_request %s", msg)
producer = AIOKafkaProducer(
threshold: int,
statistic: str,
operation: str,
+ action: str,
):
alarm_create_request = {
"severity": "critical",
"threshold_value": threshold,
"statistic": statistic,
+ "action": action,
"tags": {
"ns_id": ns_id,
"vdu_name": vdu_name,