diff --git a/examples/telegraf/net/net_alert_batch.tick b/examples/telegraf/net/net_alert_batch.tick index f02031a20..6ad8012ef 100644 --- a/examples/telegraf/net/net_alert_batch.tick +++ b/examples/telegraf/net/net_alert_batch.tick @@ -20,7 +20,8 @@ var unit = 1s // Dataframe var rawdata = batch - |query('''SELECT err_in, err_out, drop_in, drop_out FROM "telegraf"."autogen"."net" ''') + // "interface" 'all' has missing some fields - so it must be excluded from results + |query('''SELECT err_in, err_out, drop_in, drop_out FROM "telegraf"."autogen"."net" WHERE interface != 'all' ''') .period(period) .every(every) .groupBy('host', 'interface') diff --git a/examples/telegraf/net/net_alert_stream.tick b/examples/telegraf/net/net_alert_stream.tick index 590ee81cd..385912023 100644 --- a/examples/telegraf/net/net_alert_stream.tick +++ b/examples/telegraf/net/net_alert_stream.tick @@ -22,6 +22,7 @@ var rawdata = stream .database('telegraf') .retentionPolicy('autogen') .measurement('net') + .where(lambda: "interface" != 'all' ) // "interface" 'all' has missing error fields so it must be excluded .groupBy('host', 'interface') var err_in = rawdata