MQTT and OpenTSDB Integration

Input and output integration overview

The MQTT Telegraf plugin is designed to read from specified MQTT topics and create metrics, enabling users to leverage MQTT for real-time data collection and monitoring.

The OpenTSDB plugin facilitates the integration of Telegraf with OpenTSDB, allowing users to push time-series metrics to an OpenTSDB backend seamlessly.

Integration details

MQTT

The MQTT plugin allows for reading metrics from specified MQTT topics, creating metrics using supported input data formats. This plugin operates as a service input, which listens for incoming metrics or events rather than gathering them at set intervals like normal plugins. The flexibility of the plugin is enhanced with support for various broker URLs, topics, and connection features, including Quality of Service (QoS) levels and persistent sessions. Its configuration options incorporate global settings to modify metrics and handle startup errors effectively. It also supports secret-store configurations for securing username and password options, ensuring secure connections to MQTT servers.

OpenTSDB

The OpenTSDB plugin is designed to send metrics to an OpenTSDB instance using either the telnet or HTTP mode. With the introduction of OpenTSDB 2.0, the recommended method for sending metrics is via the HTTP API, which allows for batch processing of metrics by configuring the ‘http_batch_size’. The plugin supports several configuration options including metrics prefixing, server host and port specification, URI path customization for reverse proxies, and debug options for diagnosing communication issues with OpenTSDB. This plugin is particularly useful in scenarios where time series data is generated and needs to be efficiently stored in a scalable time series database like OpenTSDB, making it suitable for a wide range of monitoring and analytics applications.

Configuration

MQTT

[[inputs.mqtt_consumer]]
  servers = ["tcp://127.0.0.1:1883"]
  topics = [
    "telegraf/host01/cpu",
    "telegraf/+/mem",
    "sensors/#",
  ]
  # topic_tag = "topic"
  # qos = 0
  # connection_timeout = "30s"
  # keepalive = "60s"
  # ping_timeout = "10s"
  # max_undelivered_messages = 1000
  # persistent_session = false
  # client_id = ""
  # username = "telegraf"
  # password = "metricsmetricsmetricsmetrics"
  # tls_ca = "/etc/telegraf/ca.pem"
  # tls_cert = "/etc/telegraf/cert.pem"
  # tls_key = "/etc/telegraf/key.pem"
  # insecure_skip_verify = false
  # client_trace = false
  data_format = "influx"
  # [[inputs.mqtt_consumer.topic_parsing]]
  #   topic = ""
  #   measurement = ""
  #   tags = ""
  #   fields = ""
  #   [inputs.mqtt_consumer.topic_parsing.types]
  #      key = type

OpenTSDB

[[outputs.opentsdb]]
  ## prefix for metrics keys
  prefix = "my.specific.prefix."

  ## DNS name of the OpenTSDB server
  ## Using "opentsdb.example.com" or "tcp://opentsdb.example.com" will use the
  ## telnet API. "http://opentsdb.example.com" will use the Http API.
  host = "opentsdb.example.com"

  ## Port of the OpenTSDB server
  port = 4242

  ## Number of data points to send to OpenTSDB in Http requests.
  ## Not used with telnet API.
  http_batch_size = 50

  ## URI Path for Http requests to OpenTSDB.
  ## Used in cases where OpenTSDB is located behind a reverse proxy.
  http_path = "/api/put"

  ## Debug true - Prints OpenTSDB communication
  debug = false

  ## Separator separates measurement name from field
  separator = "_"

Input and output integration examples

MQTT

1. Smart Home Monitoring: Use the MQTT Consumer plugin to monitor various sensors in a smart home setup. In this scenario, the plugin can be configured to subscribe to topics for different devices, such as temperature, humidity, and energy consumption. By aggregating this data, homeowners can visualize trends and receive alerts for unusual patterns, enhancing the overall quality and efficiency of home automation systems.

2. IoT Environmental Sensing: Deploy the MQTT Consumer to gather environmental data from sensors distributed across different locations. For instance, this can include readings from air quality sensors, temperature sensors, and noise level meters. The plugin can be configured to extract relevant tags and fields from the MQTT topics which allows for detailed analyses and reporting on environmental conditions at scale, supporting better decision making for urban planning or environmental initiatives.

3. Real-Time Vehicle Tracking and Telemetry: Integrate the MQTT Consumer plugin within a vehicle telemetry system that collects data from various sensors in real-time. With the plugin, metrics related to vehicle performance, location, and fuel consumption can be sent to a centralized monitoring dashboard. This real-time telemetry data enables fleet managers to optimize routes, reduce fuel costs, and improve vehicle maintenance schedules through proactive data analysis.

4. Agricultural Monitoring System: Leverage this plugin to collect data from agricultural sensors that monitor soil moisture, crop health, and weather conditions. The MQTT Consumer can subscribe to multiple topics associated with farming equipment and environmental sensors, allowing farmers to make data-driven decisions to improve crop yields while also conserving resources, enhancing sustainability in agriculture.

OpenTSDB

1. Real-time Infrastructure Monitoring: Utilize the OpenTSDB plugin to collect and store metrics from various infrastructure components. By configuring the plugin to push metrics to OpenTSDB, organizations can have a centralized view of their infrastructure health and performance over time.

2. Custom Application Metrics Tracking: Integrate the OpenTSDB plugin into custom applications to track key performance indicators (KPIs) such as response times, error rates, and user interactions. This setup allows developers and product teams to visualize application performance trends and make data-driven decisions.

3. Automated Anomaly Detection: Leverage the plugin in conjunction with machine learning algorithms to automatically detect anomalies in time-series data sent to OpenTSDB. By continuously monitoring the incoming metrics, the system can train models that alert users to potential issues before they affect application performance.

4. Historical Data Analysis: Use the OpenTSDB plugin to store and analyze historical performance data for capacity planning and trend analysis. This provides valuable insights into system behavior over time, helping teams to understand usage patterns and prepare for future growth.

Feedback

Thank you for being part of our community! If you have any general feedback or found any bugs on these pages, we welcome and encourage your input. Please submit your feedback in the InfluxDB community Slack.