gnmi 插件做Telemetry监控 Dial-out Dial-in 模式都支持吗

[wm55555]

2026/05/26 11:42:16 gnmi.go:251: W! Error in gNMI subscription: failed to setup subscription: rpc error: code = Unavailable desc = connection error: desc = "transport: Error while dialing: dial tcp 0.0.0.0:50050: connect: connection refused" 好像是在连接交换机 而不是作为服务端等待交换机连接
我看文档说是可以监听端口的

tingyu@630-10.16.254.114:~/categraf/conf/input.gnmi$ docker exec -it categraf /usr/bin/categraf --configs /etc/categraf/conf --test --debug --inputs gnmi
2026/05/26 11:41:56 main.go:151: I! runner.binarydir: /usr/bin
2026/05/26 11:41:56 main.go:152: I! runner.hostname: categraf
2026/05/26 11:41:56 main.go:153: I! runner.fd_limits: (soft=1048576, hard=1048576)
2026/05/26 11:41:56 main.go:154: I! runner.vm_limits: (soft=unlimited, hard=unlimited)
2026/05/26 11:41:56 provider_manager.go:60: I! use input provider: [local]
2026/05/26 11:41:56 prometheus_agent.go:19: I! prometheus scraping disabled!
2026/05/26 11:41:56 ibex_agent.go:19: I! ibex agent disabled!
2026/05/26 11:41:56 agent.go:38: I! agent starting
2026/05/26 11:41:56 gnmi.go:203: D! Internal alias mapping: map[/interfaces/interface/state/counters:ifcounters]
2026/05/26 11:41:56 metrics_agent.go:323: I! input: local.gnmi started
2026/05/26 11:41:56 agent.go:46: I! [*agent.MetricsAgent] started
2026/05/26 11:41:56 agent.go:49: I! agent started
2026/05/26 11:41:56 metrics_reader.go:62: D! local.gnmi : before gather once
2026/05/26 11:41:56 metrics_reader.go:68: D! local.gnmi : after gather once, duration: 141.14µs
2026/05/26 11:41:56 gnmi.go:251: W! Error in gNMI subscription: failed to setup subscription: rpc error: code = Unavailable desc = connection error: desc = "transport: Error while dialing: dial tcp 0.0.0.0:50050: connect: connection refused"
2026/05/26 11:41:59 heartbeat.go:191: E! failed to do heartbeat: Post "http://127.0.0.1:17000/v1/n9e/heartbeat": dial tcp 127.0.0.1:17000: connect: connection refused
2026/05/26 11:42:06 metrics_reader.go:62: D! local.gnmi : before gather once
2026/05/26 11:42:06 metrics_reader.go:68: D! local.gnmi : after gather once, duration: 75.916µs
2026/05/26 11:42:06 gnmi.go:251: W! Error in gNMI subscription: failed to setup subscription: rpc error: code = Unavailable desc = connection error: desc = "transport: Error while dialing: dial tcp 0.0.0.0:50050: connect: connection refused"
2026/05/26 11:42:09 heartbeat.go:191: E! failed to do heartbeat: Post "http://127.0.0.1:17000/v1/n9e/heartbeat": dial tcp 127.0.0.1:17000: connect: connection refused
2026/05/26 11:42:16 metrics_reader.go:62: D! local.gnmi : before gather once
2026/05/26 11:42:16 metrics_reader.go:68: D! local.gnmi : after gather once, duration: 112.18µs
2026/05/26 11:42:16 gnmi.go:251: W! Error in gNMI subscription: failed to setup subscription: rpc error: code = Unavailable desc = connection error: desc = "transport: Error while dialing: dial tcp 0.0.0.0:50050: connect: connection refused"
^C2026/05/26 11:42:18 main.go:134: I! received signal: interrupt
2026/05/26 11:42:18 agent.go:53: I! agent stopping
2026/05/26 11:42:18 agent.go:61: I! [*agent.MetricsAgent] stopped
2026/05/26 11:42:18 agent.go:64: I! agent stopped
2026/05/26 11:42:18 main.go:146: I! exited

tingyu@630-10.16.254.114:~/categraf/conf/input.gnmi$ ss -tlnp | grep 50050

配置如下
tingyu@630-10.16.254.114:~/categraf/conf/input.gnmi$ cat gnmi.toml
interval="10s"

gNMI telemetry input plugin

[[instances]]

Address and port of the gNMI GRPC server

addresses = ["0.0.0.0:50050"]

[kongfei605]

0.0.0.0 换成你本机的实际IP

[wm55555]

0.0.0.0 换成你本机的实际IP
修改了报错，看样子 gnmi插件只支持 dial-in模式， 他只能主动去拉交换机信息，而不能接收交换机的推信息
tingyu@630-10.16.254.114:~/categraf/conf/input.gnmi$ cat gnmi.toml
interval = "10s"
[[instances]]
addresses = ["10.252.255.60:50050"]

2026/05/26 18:56:46 gnmi.go:251: W! Error in gNMI subscription: failed to setup subscription: rpc error: code = Unavailable desc = connection error: desc = "transport: Error while dialing: dial tcp 10.252.255.60:50050: connect: connection refused"

[kongfei605]

这么笃定？

修改了报错，看样子 gnmi插件只支持 dial-in模式， 他只能主动去拉交换机信息，而不能接收交换机的推信息
tingyu@630-10.16.254.114:~/categraf/conf/input.gnmi$ cat gnmi.toml
interval = "10s"
[[instances]]
addresses = ["10.252.255.60:50050"]

[kongfei605]

gnmi插件是一个client， 连设备的gnmi server，发送配置中设置好的订阅， 等设备推送。

[[instances]]
  # 1. 目标设备的 gNMI gRPC Server 地址和端口
  addresses = ["1.2.3.4:5678"]
...

[[instances.subscription]]
    ## Name of the measurement that will be emitted
    name = "ifcounters"
   # 订阅的 Origin 和 Path (参考设备的 YANG 模型文档) 
    origin = ""
    path = "/interfaces/interface/state/counters"
    # 订阅模式：
    # - "sample": 周期性采样 (最常用)
    # - "on_change": 状态变更时推送
    # - "target_defined": 由设备决定

    subscription_mode = "sample"
    sample_interval = "15s"

... 

gnmi server的配置 你要自己配置了。 采集端配置文件可以参考 https://github.com/flashcatcloud/categraf/blob/main/conf/input.gnmi/interface.toml.example

[wm55555]

gnmi插件是一个client， 连设备的gnmi server，发送配置中设置好的订阅， 等设备推送。

[[instances]]
  # 1. 目标设备的 gNMI gRPC Server 地址和端口
  addresses = ["1.2.3.4:5678"]
...

[[instances.subscription]]
    ## Name of the measurement that will be emitted
    name = "ifcounters"
   # 订阅的 Origin 和 Path (参考设备的 YANG 模型文档) 
    origin = ""
    path = "/interfaces/interface/state/counters"
    # 订阅模式：
    # - "sample": 周期性采样 (最常用)
    # - "on_change": 状态变更时推送
    # - "target_defined": 由设备决定

    subscription_mode = "sample"
    sample_interval = "15s"

... 

gnmi server的配置 你要自己配置了。 采集端配置文件可以参考 https://github.com/flashcatcloud/categraf/blob/main/conf/input.gnmi/interface.toml.example

好的 想问一下 categraf会支持做 gnmi server的功能吗，即监听某个端口，等待其他gnmi设备连接进来

[kongfei605]

标准gnmi协议不支持dial out模式。 现在dial out模式没有统一的标准，反序列化没有通用方式，只能针对单独的设备或者厂商 做插件。 短期内还没有计划支持。

[wm55555]

标准gnmi协议不支持dial out模式。 现在dial out模式没有统一的标准，反序列化没有通用方式，只能针对单独的设备或者厂商 做插件。 短期内还没有计划支持。

感谢大佬