def callback()

in flask/application.py [0:0]


def callback(client, userdata, message):
    global metrics_data, anomalies
    metric = str(message.topic.split('/')[2])
    data = history(dynamodb, table_name, metric, json.loads(message.payload)['ID'])
    stats = calculate_mas(metric, data, window)
    metrics_data[metric] = is_anomaly(stats)
    anomalies[metric] = metrics_data[metric][metrics_data[metric]['anomaly']]