- # rmr send 30003(TS_ANOMALY_UPDATE), should trigger registered callback
- result = json.loads(db_df.to_json(orient='records'))
- val = json.dumps(result).encode()
+ Return
+ ......
+ val: anomalus sample info(UEID, DUID, TimeStamp, Degradation type)
+ """
+ pred = ad_predict(df)
+ df['Anomaly'] = pred
+ df['Degradation'] = ''
+ val = None
+ if 1 in pred:
+ deg = cp.cause(df)
+ if deg:
+ df['Degradation'] = deg
+ db_df = df[['du-id', 'ue-id', 'measTimeStampRf', 'Degradation']]
+
+ # rmr send 30003(TS_ANOMALY_UPDATE), should trigger registered callback
+ result = json.loads(db_df.to_json(orient='records'))
+ val = json.dumps(result).encode()
+ df.loc[db_df.index, 'Degradation'] = db_df['Degradation']
+ df.index = df.measTimeStampRf
+ result = json.loads(df.to_json(orient='records'))
+
+ df = df.drop('measTimeStampRf', axis=1)
+ db.write_anomaly(df, 'AD')