MQTT and Apache Inlong 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 Inlong plugin connects Telegraf to Apache InLong, enabling seamless transmission of collected metrics to an InLong instance.

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.

Apache Inlong

This Inlong plugin is designed to publish metrics to an Apache InLong instance, which facilitates the management of data streams in a scalable manner. Apache InLong provides a robust framework for efficient data transmission between various components in a distributed environment. By leveraging this plugin, users can effectively route and transmit metrics collected by Telegraf to their InLong data-proxy infrastructure. As a key component in a data pipeline, the Inlong Output Plugin helps ensure that data is consistently formatted, streamed correctly, and managed in compliance with the standards set by Apache InLong, making it an essential tool for organizations looking to enhance their data analytics and reporting capabilities.

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

Apache Inlong

[[outputs.inlong]]
  ## Manager URL to obtain the Inlong data-proxy IP list for sending the data
  url = "http://127.0.0.1:8083"

  ## Unique identifier for the data-stream group
  group_id = "telegraf"  

  ## Unique identifier for the data stream within its group
  stream_id = "telegraf"  

  ## Data format to output.
  ## Each data format has its own unique set of configuration options, read
  ## more about them here:
  ## https://github.com/influxdata/telegraf/blob/master/docs/DATA_FORMATS_OUTPUT.md
  # data_format = "influx"

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.

Apache Inlong

1. Real-time Metrics Monitoring: Integrating the Inlong plugin with a real-time monitoring dashboard allows teams to visualize system performance continuously. As metrics flow from Telegraf to InLong, organizations can create dynamic panels in their monitoring tools, providing instant insights into system health, resource utilization, and performance bottlenecks. This setup encourages proactive management and swift identification of potential issues before they escalate into critical failures.

2. Centralized Data Processing: Use the Inlong plugin to send Telegraf metrics to a centralized data processing pipeline that processes large volumes of data for analysis. By directing all collected metrics through Apache InLong, businesses can streamline their data workflows and ensure consistency in data formatting and processing. This centralized approach facilitates easier data integration with business intelligence tools and enhances decision-making through consolidated data insights.

3. Integration with Machine Learning Models: By feeding metrics collected through the Inlong Output Plugin into machine learning models, teams can enhance predictive analytics capabilities. For instance, metrics can be analyzed to predict system failures or performance trends. This application allows organizations to leverage historical data and infer future performance, helping them optimize resource allocation and minimize downtime using automated alerts based on model predictions.

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.