Movatterモバイル変換

[0]ホーム
URL:

Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

 Sign up
Appearance settings

MQTT-TOPN: display MQTT topic statistics

License

NotificationsYou must be signed in to change notification settings

gambitcomminc/golang-mqtt-topn

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

6 Commits
 
 
 
 
 
 

Repository files navigation

MQTT-TOPN: display MQTT topic statistics

Overview

This is a simple MQTT subscriber client in Go to display topic performance statisticswith TopN most "chatty" topics. The idea is similar to the Unix "top" process statistics utilitydetailed athttps://www.geeksforgeeks.org/top-command-in-linux-with-examples/ .

It is the command-line interface equivalent ofhttps://github.com/gambitcomminc/mqtt-statsimplemented with Go ncurseshttps://godoc.org/github.com/gbin/goncurses

This utility allows you to analyze quantitatively the published topics underneath a wildcard topic and answer such questions as "which topic generates the most messages?" and "which topic generates the most traffic?". You can sort by messages/second to get the most active topics.

Installation / Requirements

  • To install this program, you need to install Go and set your Go workspace first.

  • Follow instructions for Eclipse Paho Go libraryhttps://github.com/eclipse/paho.mqtt.golang

  • go get github.com/pborman/getopt/v2

  • go get github.com/gbin/goncurses

  • go build mqtt-topn.go

Usage

Non-curses mode for redirecting into files:

% ./mqtt-topn --host mqtt.eclipse.org --topic # --verbose 0 --report 1 -N -T 512/31.12:49:51: MQTT-TOPN -- q: exit, p: pause, h: halt[12/31.12:49:51: Subscribed to topic # on mqtt.eclipse.org:1883]12/31.12:49:52: msgs/s 2218.1, bytes/s 263927.1, bytes/msg 119.0, topics 2149- msgs ---- msgs/s ---- bytes -- bytes/s - topic -------------   14      14.0        70      69.9 shpi/motion   14      14.0       236     235.6 shpi/lastmotion    7       7.0        84      83.9 /merakimv/Q2GV-P692-B34D/light    5       5.0       165     164.7 /merakimv/Q2GV-UJ9A-JRJD/raw_detections    4       4.0       172     171.7 /merakimv/Q2GV-UJ9A-JRJD/012/31.12:49:53: msgs/s 133.8, bytes/s 6175.6, bytes/msg 46.2, topics 2173- msgs ---- msgs/s ---- bytes -- bytes/s - topic -------------   23       8.9       115      44.6 shpi/motion   23       8.9       380     142.7 shpi/lastmotion    6       5.9       198     196.2 /merakimv/Q2GV-P692-B34D/raw_detections    6       5.9       258     255.7 /merakimv/Q2GV-P692-B34D/0    6       5.9       258     255.7 /merakimv/Q2GV-P692-B34D/66709569480425478812/31.12:49:54: msgs/s 158.8, bytes/s 9315.8, bytes/msg 58.7, topics 2184- msgs ---- msgs/s ---- bytes -- bytes/s - topic -------------   34      11.0       170      54.9 shpi/motion   34      11.0       562     181.8 shpi/lastmotion   12       7.0       516     300.6 /merakimv/Q2GV-UJ9A-JRJD/0   12       7.0       516     300.6 /merakimv/Q2GV-UJ9A-JRJD/615867249042915441   12       7.0       516     300.6 /merakimv/Q2GV-UJ9A-JRJD/615867249042915443

Curses mode video athttps://www.youtube.com/watch?v=M1c--mXYl_Q

About

MQTT-TOPN: display MQTT topic statistics

Topics

Resources

License

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages

[8]ページ先頭
©2009-2025 Movatter.jp