MavLink and Redis Integration

Input and output integration overview

This plugin collects metrics from MavLink-compatible flight controllers like ArduPilot and PX4, enabling live data ingestion from unmanned systems such as drones and boats.

The Redis plugin enables users to send metrics collected by Telegraf directly to Redis. This integration is ideal for applications that require robust time series data storage and analysis.

Integration details

MavLink

The MavLink plugin is designed to gather metrics from MavLink-compatible flight controllers such as ArduPilot and PX4. It provides a mechanism to live ingest flight metrics from various unmanned systems, including drones, planes, and boats. By utilizing the ArduPilot-specific MavLink dialect, the plugin parses a wide range of messages as documented in the MavLink documentation. It enables seamless integration of telemetry data, allowing for detailed monitoring and analysis of flight operations. Users must be cautious, as this plugin may generate a substantial volume of data; thus, filters are available to limit the metrics collected and transmitted to output plugins. Additionally, configuration options allow customization of which messages to receive and how to connect to the flight controller.

Redis

The Redis Telegraf plugin is designed for writing metrics to RedisTimeSeries, a specialized Redis database module for time series data. This plugin facilitates the integration of Telegraf with RedisTimeSeries, allowing for the efficient storage and retrieval of timestamped data. With RedisTimeSeries, users can take advantage of enhanced capabilities for managing time series data, including aggregated views and range queries. The plugin offers various configuration options to enable the flexibility needed to connect securely to your Redis database, including support for Authentication, Timeouts, data type conversions, and TLS configurations. The underlying technology leverages Redis’ efficiency and scalability, making it an excellent choice for high-volume metric environments, where real-time processing is essential.

Configuration

MavLink

[[inputs.mavlink]]
  ## Flight controller URL supporting serial port, UDP and TCP connections.
  ## Options are documented at
  ##   https://mavsdk.mavlink.io/v1.4/en/cpp/guide/connections.html.
  ##
  ## Examples:
  ## - Serial port: serial:///dev/ttyACM0:57600
  ## - TCP client:  tcp://192.168.1.12:5760
  ## - UDP client:  udp://192.168.1.12:14550
  ## - TCP server:  tcpserver://:5760
  ## - UDP server:  udpserver://:14550
  # url = "tcp://127.0.0.1:5760"

  ## Filter to specific messages. Only the messages in this list will be parsed.
  ## If blank or unset, all messages will be accepted. Glob syntax is accepted.
  ## Each message in this list should be lowercase camel_case, with "message_"
  ## prefix removed, eg: "global_position_int", "attitude"
  # filter = []

  ## Mavlink system ID for Telegraf. Only used if the mavlink plugin is sending 
  ## messages, eg. when `stream_request_frequency` is 0 (see below.)
  # system_id = 254

  ## Determines whether the plugin sends requests to subscribe to data.
  ## In mavlink, stream rates must be configured before data is received.
  ## This config item sets the rate in Hz, with 0 disabling the request.
  ## 
  ## This frequency should be set to 0 if your software already controls the 
  ## rates using REQUEST_DATA_STREAM or MAV_CMD_SET_MESSAGE_INTERVAL
  ## (See https://mavlink.io/en/mavgen_python/howto_requestmessages.html)
  # stream_request_frequency = 4

Redis

[[outputs.redistimeseries]]
  ## The address of the RedisTimeSeries server.
  address = "127.0.0.1:6379"

  ## Redis ACL credentials
  # username = ""
  # password = ""
  # database = 0

  ## Timeout for operations such as ping or sending metrics
  # timeout = "10s"

  ## Enable attempt to convert string fields to numeric values
  ## If "false" or in case the string value cannot be converted the string
  ## field will be dropped.
  # convert_string_fields = true

  ## Optional TLS Config
  # tls_ca = "/etc/telegraf/ca.pem"
  # tls_cert = "/etc/telegraf/cert.pem"
  # tls_key = "/etc/telegraf/key.pem"
  # insecure_skip_verify = false

Input and output integration examples

MavLink

1. Real-Time Fleet Monitoring: Utilize the MavLink plugin to create a centralized dashboard for monitoring multiple drones in real-time. By ingesting metrics from various flight controllers, operators can oversee the status, health, and location of all drones, allowing for quick decision-making and enhanced situational awareness. This integration could significantly improve coordination during large-scale operations, like aerial surveys or search and rescue missions.

2. Automated Anomaly Detection: Leverage MavLink in conjunction with machine learning algorithms to detect anomalies in flight data. By continuously monitoring metrics such as altitude, speed, and battery status, the system can alert operators to deviations from normal behavior, potentially indicating technical malfunctions or safety issues. This proactive approach can enhance safety and reduce the risk of in-flight failures.

3. Data-Driven Maintenance Scheduling: Integrate the data collected through the MavLink plugin with maintenance management systems to optimize maintenance schedules based on actual flight metrics. Analyzing the collected data can highlight patterns indicating when specific components are likely to fail, thereby enabling predictive maintenance strategies that minimize downtime and repair costs.

4. Enhanced Research Analytics: For academic and commercial UAV research, MavLink can be used to gather extensive flight data for analysis. By compiling metrics over numerous flights, researchers can uncover insights related to flight patterns, environmental interactions, and the efficiency of different drone models. This can foster advancements in UAV technology and broader applications in autonomous systems.

Redis

1. Monitoring IoT Sensor Data: Utilize the Redis Telegraf plugin to collect and store data from IoT sensors in real-time. By connecting the plugin to a RedisTimeSeries database, users can analyze trends in temperature, humidity, or other environmental factors. The ability to query historical sensor data efficiently will aid in predictive maintenance and help in resource management.

2. Financial Market Data Aggregation: Employ this plugin to track and store time-sensitive financial data from various sources. By sending metrics to Redis, financial institutions can aggregate and analyze market trends or price changes over time, providing them with actionable insights derived from reliable time series analytics.

3. Application Performance Monitoring (APM): Implement the Redis plugin for gathering application performance metrics such as response times and CPU usage. Users can visualize their application’s performance over time with RedisTimeSeries, allowing them to identify bottlenecks and optimize resource allocation swiftly.

4. Energy Consumption Tracking: Leverage this plugin to monitor energy usage in buildings over time. By integrating with smart meters and sending data to RedisTimeSeries, municipalities or enterprises can analyze energy consumption patterns, helping to implement energy-saving measures and sustainability practices.

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.