将mqtt度量发布到statsd的脚本

mqtt-statsd的Python项目详细描述


顾名思义,这是一个将mqtt度量发布到statsd的脚本。是的 最初设计用于处理mosquito中$sys/主题的度量 代理,但是框架足够通用,可以使用任何mqtt主题。

安装

mqtt_statsd可通过pypi获得,因此您只需运行:

pip install -U mqtt_statsd

在系统上获取mqtt_statsd。如果需要使用 mqtt_statsd您可以克隆repo并使用以下命令在本地安装它:

git clone https://github.com/mtreinish/mqtt_statsd.git && pip install -e mqtt_statsd

它将以可编辑模式在您的python环境中安装mqtt_statsd 地方发展。

配置mqtt_statsd

在运行mqtt_statsd之前,必须创建一个yaml配置文件来告诉 mqtt_statsd如何连接到mqtt代理和statsd。以及 要订阅的mqtt主题以及如何用它获得的数据填充statsd 从mqtt主题。例如:

statsd:
  hostname: localhost
  # port is optional, the default is shown
  port: 8125
  # prefix is optional, the default is shown
  prefix: mosquitto.stats
mqtt:
  hostname: localhost
  # port is optional, the default is shown
  port: 1883
  # keepalive is optional, the default is shown
  keepalive: 60
  # username is optional, there is no default
  username: foo
  # password is optional, there is no default. If username isn't set this
  # is ignored
  password: PASS
  # qos is optional, the default is shown
  qos: 0
  # websocket is optional, it defaults to False
  websocket: True
topics:
  # You can specify as many topics as you want, and mqtt_statsd will
  # listen to all of them
  - $SYS/broker/messages/publish/sent:
    statsd_topic: publish_messages_sent
    # statsd_type is optional, the default is shown. Valid options are
    # gague, counter, and timer
    statsd_type: gauge
  - $SYS/broker/clients/connected:
    statsd_topic: connected_clients

运行mqtt_statsd

在安装和配置mqtt_statsd并运行它之后 直截了当。只要调用mqtt_statsd,它就需要一个强制参数, yaml配置文件的路径。例如:

mqtt_statsd my_config_file.yaml

欢迎加入QQ群-->: 979659372 Python中文网_新手群

推荐PyPI第三方库


热门话题
java将数据从一个输入流传输到多个输出流的最佳方式   java如何使用反射机制调用驻留在具有默认可见性的基类中的公共方法?   在Java中将两个不同的方法调用为一个方法   集合的最佳Java线程安全锁定机制?   java在gae中存储json字符串   PHP/Java桥。如何从php服务器连接到桌面应用程序   java Spring:无法持久化用@JsonIgnore注释的实体   基准测试中的java非确定性分配行为   JavaSpring:使用Spring安全性为执行器端点配置安全性   java扩展spring应用程序上下文的最佳方式是什么?   在Mac OS上使用Java向终端窗口发送一些输入   java addInputStream(InputStream InputStream)方法失败   java为什么下面的代码打印为false?   java错误:类按钮中的addActionListener方法无法应用于给定类型;   java在spring数据jpa投影中使用嵌入式值对象   java访问匿名内部类中的变量的干净方法是什么?   java将POJO转换为JSON只返回“id”字段   jvm热点我在哪里可以找到MemoryConsumer。测试内存消耗的java程序?