telegraph + influxdb + grafana 实现交换机流量展示

2024-04-20 13:36

本文主要是介绍telegraph + influxdb + grafana 实现交换机流量展示,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

实验环境

influxdb2:2.7.5
telegraf:1.30.1
grafana:10.4.2

influxdb

官方文档见https://docs.influxdata.com/influxdb/v2/,网络上很多文档比较老,可能是v1版本的influxdb。

部署方法1:二进制

从https://www.influxdata.com/downloads/可以查看不同版本的下载地址
下载压缩包并解压、复制二进制文件至默认bin目录下

wget https://dl.influxdata.com/influxdb/releases/influxdb2-2.7.6_linux_amd64.tar.gz
tar -zxf influxdb2-2.7.6_linux_amd64.tar.gz
cp influxdb2-2.7.6/usr/bin/influxd /usr/local/bin/

此后就可以通过influxd启动,通过--http-bind-address可以修改端口,通过--reporting-disabled可以不发送telemetry数据,例如:

influxd --http-bind-address=:8089
influxd --reporting-disabled

部署方法2:RPM包部署

按照官网说明下载及安装即可

cat <<EOF | sudo tee /etc/yum.repos.d/influxdata.repo
[influxdata]
name = InfluxData Repository - Stable
baseurl = https://repos.influxdata.com/stable/\$basearch/main
enabled = 1
gpgcheck = 1
gpgkey = https://repos.influxdata.com/influxdata-archive_compat.key
EOF
sudo yum install influxdb2

此后即可通过service或者systemctl操作influxdb,service influxdb start或者systemctl start influxdb
如果想要修改配置,修改配置文件/etc/influxdb/config.toml,例如增加配置如下:

http-bind-address = ":8089"
reporting-disabled = false

测试

启动完成后,可以通过8089端口进行管理,例如http://192.168.101.91:8089/
本次实验中,设置

Username: test
Password: teStUsEr
Organization: test
Bucket: traffic-test

记录下API token,后面telegraf和grafana连接influxdb要用,也可以创建一个All Access API Token。
influxdb启动后,可以参考官方文档的 Get Started ——> Write Data和Query Data进行写入数据和查询数据的测试,按照文档操作即可,唯一要注意的是,官网的样例数据是以秒为单位的,所以load data时精度一定要选择秒,否则数据都会被丢弃

telegraph

安装

配置yum源并安装:

cat <<EOF | sudo tee /etc/yum.repos.d/influxdb.repo
[influxdb]
name = InfluxData Repository - Stable
baseurl = https://repos.influxdata.com/stable/\$basearch/main
enabled = 1
gpgcheck = 1
gpgkey = https://repos.influxdata.com/influxdata-archive_compat.key
EOF
sudo yum install telegraf

配置

默认配置文件位置为/etc/telegraf/telegraf.conf,默认的telegraf是不产生日志的,需要z在telegraf.conf`修改如下配置手工开启:

logtarget = "file"
logfile = "/var/log/telegraf/telegraf.log"

原始配置文件内容极多,可以仅生成需要的配置,例如:

telegraf --input-filter snmp --output-filter file config > test.conf

则只会生成一个输入为snmp,输出为file的配置文件test.conf。可以测试此配置文件是否正确,如果正确则会完成一次采集:

telegraf -config test.conf -input-filter snmp -test

每次修改配置文件后,telegraf都需要重启才能生效。如果使用systemctl启动telegraf,则会应用/etc/telegraf/telegraf.conf和/etc/telegraf/telegraf.d下的所有*.conf配置文件。如果有多个不同的采集任务,可以在一个配置文件中写多个Inputs插件,也可以在/etc/telegraf/telegraf.d下写多个配置文件,但是要注意,telegraf.d目录可以为空,telegraf.conf文件是必需的。

示例

输出

influxdb输出插件配置如下:

[[outputs.influxdb_v2]]urls = ["http://127.0.0.1:8089"]token = "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx"organization = "test"bucket = "traffic-test"
流量采集(32位计数器版本)

实验示例为采集192.168.101.229、228两台交换机流量,关键配置如下:

 [[inputs.snmp]]agents = ["udp://192.168.101.229:161","udp://192.168.101.228:161"]version = 2community = "public"agent_host_tag = "source"fieldpass = ["ifOutOctets", "ifInOctets"][[inputs.snmp.field]]oid = "RFC1213-MIB::sysName.0"name = "sysName"is_tag = true[[inputs.snmp.table]]oid = "IF-MIB::ifTable"name = "traffic"inherit_tags = ["sysName"][[inputs.snmp.table.field]]oid = "IF-MIB::ifDescr"name = "ifDescr"is_tag = true[inputs.snmp.tagpass]ifDescr = ["GigabitEthernet*", "XGigabitEthernet*"]

关键配置说明如下:fieldpass会只保留ifOutOctets和ifInOctets两个字段,即流量计数,过滤掉查看流量所不需要的带宽、错包等其他信息;is_tag表示此字段将会成为一个tag;inherit_tags表示将会继承上层tag,此处即为sysName;tagpass会只保留ifDescrtag值为GigabitEthernet开头或者XGigabitEthernet开头,去掉loopback或者vlanif等其他端口。

流量采集(64位计数器版本)

64位计数器版本配置如下,与32位版本的区别是换了oid和过滤器:

 [[inputs.snmp]]agents = ["udp://192.168.101.229:161"]version = 2community = "public"agent_host_tag = "source"fieldpass = ["ifHCOutOctets", "ifHCInOctets"][[inputs.snmp.field]]oid = "RFC1213-MIB::sysName.0"name = "sysName"is_tag = true[[inputs.snmp.table]]oid = "IF-MIB::ifXTable"name = "traffic"inherit_tags = ["sysName"][[inputs.snmp.table.field]]oid = "IF-MIB::ifName"name = "ifName"is_tag = true[[inputs.snmp.table.field]]oid = "IF-MIB::ifAlias"name = "ifAlias"is_tag = true[inputs.snmp.tagpass]ifName = ["GigabitEthernet*", "XGigabitEthernet*"]

示例数据

一条数据示例如下:

traffic,host=net-229,ifDescr=GigabitEthernet0/0/14,ifIndex=19,source=192.168.101.229,sysName=H3C-.S5320-01 ifOutOctets=4189261175i,ifInOctets=3989823012i 1713344116000000000

该数据遵守influxdb的行协议(line protocol):
在这里插入图片描述

grafana

启动

可以直接yum安装,也可以下载后手动安装

yum install -y https://dl.grafana.com/oss/release/grafana-10.4.2-1.x86_64.rpm

如果想要修改默认端口号,修改/etc/grafana/grafana.ini 文件中[server]下的http_port项,将

;http_port = 3000

修改为需要的端口号

http_port = 4000

重启服务即可

systemctl restart grafana-server

默认账号密码是admin/admin,但是登录会建议修改。

添加数据源

Connections—>Addd new connection,选择 InfluxDB
在这里插入图片描述
Query language 选择 Flux,填好URL、Organization、Token、Default Bucket,点击Save & test,即可。

添加可视化

Query需要填写Flux语言的查询语句。
由于通过snmp协议获取值仅为当前流量计数器的总值,获取流量还需要通过计数器差值并计算速率,需要用到derivative()函数。
示例代码(32位计数器版本)如下:

from(bucket: "traffic-test")|> range(start: -3h)|> filter(fn: (r) => r["_measurement"] == "traffic")|> filter(fn: (r) => r["_field"] == "ifInOctets")|> filter(fn: (r) => r["source"] == "192.168.101.229")|> filter(fn: (r) => r["ifDescr"] == "GigabitEthernet0/0/10")|> derivative(unit: 1s)

即可显示图形
在这里插入图片描述

这篇关于telegraph + influxdb + grafana 实现交换机流量展示的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/920391

相关文章

C++使用栈实现括号匹配的代码详解

《C++使用栈实现括号匹配的代码详解》在编程中,括号匹配是一个常见问题,尤其是在处理数学表达式、编译器解析等任务时,栈是一种非常适合处理此类问题的数据结构,能够精确地管理括号的匹配问题,本文将通过C+... 目录引言问题描述代码讲解代码解析栈的状态表示测试总结引言在编程中,括号匹配是一个常见问题,尤其是在

Java实现检查多个时间段是否有重合

《Java实现检查多个时间段是否有重合》这篇文章主要为大家详细介绍了如何使用Java实现检查多个时间段是否有重合,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录流程概述步骤详解China编程步骤1:定义时间段类步骤2:添加时间段步骤3:检查时间段是否有重合步骤4:输出结果示例代码结语作

使用C++实现链表元素的反转

《使用C++实现链表元素的反转》反转链表是链表操作中一个经典的问题,也是面试中常见的考题,本文将从思路到实现一步步地讲解如何实现链表的反转,帮助初学者理解这一操作,我们将使用C++代码演示具体实现,同... 目录问题定义思路分析代码实现带头节点的链表代码讲解其他实现方式时间和空间复杂度分析总结问题定义给定

Java覆盖第三方jar包中的某一个类的实现方法

《Java覆盖第三方jar包中的某一个类的实现方法》在我们日常的开发中,经常需要使用第三方的jar包,有时候我们会发现第三方的jar包中的某一个类有问题,或者我们需要定制化修改其中的逻辑,那么应该如何... 目录一、需求描述二、示例描述三、操作步骤四、验证结果五、实现原理一、需求描述需求描述如下:需要在

如何使用Java实现请求deepseek

《如何使用Java实现请求deepseek》这篇文章主要为大家详细介绍了如何使用Java实现请求deepseek功能,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录1.deepseek的api创建2.Java实现请求deepseek2.1 pom文件2.2 json转化文件2.2

python使用fastapi实现多语言国际化的操作指南

《python使用fastapi实现多语言国际化的操作指南》本文介绍了使用Python和FastAPI实现多语言国际化的操作指南,包括多语言架构技术栈、翻译管理、前端本地化、语言切换机制以及常见陷阱和... 目录多语言国际化实现指南项目多语言架构技术栈目录结构翻译工作流1. 翻译数据存储2. 翻译生成脚本

如何通过Python实现一个消息队列

《如何通过Python实现一个消息队列》这篇文章主要为大家详细介绍了如何通过Python实现一个简单的消息队列,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录如何通过 python 实现消息队列如何把 http 请求放在队列中执行1. 使用 queue.Queue 和 reque

Python如何实现PDF隐私信息检测

《Python如何实现PDF隐私信息检测》随着越来越多的个人信息以电子形式存储和传输,确保这些信息的安全至关重要,本文将介绍如何使用Python检测PDF文件中的隐私信息,需要的可以参考下... 目录项目背景技术栈代码解析功能说明运行结php果在当今,数据隐私保护变得尤为重要。随着越来越多的个人信息以电子形

使用 sql-research-assistant进行 SQL 数据库研究的实战指南(代码实现演示)

《使用sql-research-assistant进行SQL数据库研究的实战指南(代码实现演示)》本文介绍了sql-research-assistant工具,该工具基于LangChain框架,集... 目录技术背景介绍核心原理解析代码实现演示安装和配置项目集成LangSmith 配置(可选)启动服务应用场景

使用Python快速实现链接转word文档

《使用Python快速实现链接转word文档》这篇文章主要为大家详细介绍了如何使用Python快速实现链接转word文档功能,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 演示代码展示from newspaper import Articlefrom docx import