Processor: Periodic Average
One number is created on output for each input. Each <period>, the output is set to the average of the input over the last <period>. This is not a weighted average.
Graph queries can optionally be used to fetch data from arbitrary nodes in the graph, such as property set nodes, and parametrize the probe.
Parameter | Description |
---|---|
Input Types | Table (number) |
Output Types | Table (number) |
Period | Size of the averaging period. (time in seconds, integer, or an expression that evaluates to time in seconds integer value) |
Graph Query (graph_query) |
One or more queries on graph specified as strings, or a list of such queries. (String will be deprecated in a future release.) Multiple queries should provide all the named nodes referenced by the expression fields (including additional_properties). Graph query is executed on the "operation" graph. Results of the queries can be accessed using the "query_result" variable with the appropriate index. For example, if querying property set nodes under name "ps", the result will be available as "query_result[0]["ps"]". In collector processors ( In other processors it is used for general parameterization and it is only supported as a list of queries. graph_query: "node("system", role="leaf", name="system"). out("hosted_interfaces"). node("interface", name="iface").out("link"). node("link", role="spine_leaf")" graph_query: ["node("system", role="leaf", name="system")", "node("system", role="spine", name="system")"] Non-collector processors containing the
graph_query: [node("property_set", label="probe_propset", name="ps")] duration: int(query_result[0]["ps"].values["accumulate_duration"]) Another example is a that probes can validate a compliance requirement; the compliance value may change over time and/or it can be used by more than one probe. Also, a probe can validate NOS versions on devices. In this case, property sets can be used to define the current NOS version requirement. If it changes tomorrow: change the property set value, instead of going under the probe stage. |
Enable Streaming (enable_streaming) |
Makes samples of output stages streamed if enabled. An optional boolean that defaults to False. If set to True, all output stages of this processor are streamed in the generic protobuf schema. |
Example: Periodic Average
period: 2
Assume the following input at time t=1
[if_name=eth0] : 10 [if_name=eth1] : 20 [if_name=eth3] : 30
And following input at time t=1.5
[if_name=eth0] : 20 [if_name=eth1] : 30 [if_name=eth3] : 40
And the following at time t=2.1
[if_name=eth0] : 40 [if_name=eth1] : 50 [if_name=eth3] : 60
We would now have the following output:
[if_name=eth0] : 15 [if_name=eth1] : 25 [if_name=eth3] : 35
This output is the average over the last discrete period of 2 seconds (time=0 to time=2). Notice that the average is not weighted by time; frequently-occuring closely-spaced samples will bias the average.
The next time the output would be updated would be at time t=4, in which case it would contain the average of the input over the range [t=2, t=4], a period of the configured two seconds.