flowchart has problem

[taroyutao]

import numpy as np import pandas as pd from adtk.data import validate_series import matplotlib.pyplot as plt from adtk.visualization import plot from adtk.transformer import DoubleRollingAggregate from adtk.detector import ThresholdAD, QuantileAD from adtk.aggregator import AndAggregator

故障检测

from adtk.pipe import Pipenet

steps = {

长窗口历史数据扫描，规避持续异常跳变

"more_step_roll_aggr": {
    "model": DoubleRollingAggregate(
        agg="max",
        window=(20, 1),
        diff="diff"
    ),
    "input": "original",
},
# 确保递增是一直持续存在
"abs_more_step_roll_aggr": {
    "model": ThresholdAD(
        high=0
    ),
    "input": "more_step_roll_aggr"
},

# 短窗口数据扫描，相对变化率(斜率)判断
"one_step_change": {
    "model": DoubleRollingAggregate(
        agg="mean",
        window=(3, 1),
        diff="rel_diff"
    ),
    "input": "original",
},
"abs_one_step_change": {
    "model": ThresholdAD(high=0.2),
    "input": "one_step_change"
},

"base_level_detect1": {
    "model": ThresholdAD(high=100),
    "input": "original"
},

"positive_level_shift": {
    "model": AndAggregator(),
    "input": ["abs_more_step_roll_aggr", "abs_one_step_change", "base_level_detect"]
}

}

pipenet = Pipenet(steps) pipenet.plot_flowchart()

plt.show()

plt.savefig('net1.png')