anomaly detect: add api (delete record)

Change-Id: I0422e02137f55346f2695d977c71fd92e9bb68d3
This commit is contained in:
inspurericzhang 2023-07-25 10:53:49 +00:00
parent fc3732231e
commit 6f6770dd6b
4 changed files with 19 additions and 0 deletions

View File

@ -126,3 +126,8 @@ class APIRouter(venus.api.openstack.APIRouter):
controller=anomaly_detect_resource,
action='get_record_list',
conditions={'method': ['GET']})
mapper.connect("delete_record", "/anomaly/record/{id}",
controller=anomaly_detect_resource,
action='delete_record',
conditions={'method': ['DELETE']})

View File

@ -43,3 +43,7 @@ class AnomalyDetectCore(object):
def get_record_list(self, params):
res = self.sql.get_record_list(self, params)
return res
def delete_record(self, id):
res = self.sql.delete_record(id)
return res

View File

@ -130,3 +130,8 @@ class AnomalyDetectSql(object):
query = query.limit(page_size).offset((page_num - 1) * page_num)
res = query.all()
return res
def delete_record(self, id):
session = get_session()
with session.begin():
session.query(models.AnomalyRecords).filter_by(id=id).delete()

View File

@ -123,6 +123,11 @@ class AnomalyDetectController(wsgi.Controller):
return {"code": 0, "msg": "OK", "rules": records}
@wsgi.wrap_check_policy
def delete_record(self, req, id):
self.api.delete_record(id)
return {"code": 0, "msg": "OK"}
def create_resource(ext_mgr):
return wsgi.Resource(AnomalyDetectController(ext_mgr))