MavLink and OpenObserve 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.

This configuration pairs Telegraf’s HTTP output with OpenObserve’s native JSON ingestion API, turning any Telegraf agent into a first-class OpenObserve collector.

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.

OpenObserve

OpenObserve is an open source observability platform written in Rust that stores data cost-effectively on object storage or local disk. It exposes REST endpoints such as /api/{org}/ingest/metrics/_json that accept batched metric documents conforming to a concise JSON schema, making it an attractive drop-in replacement for Loki or Elasticsearch stacks. The Telegraf HTTP output plugin streams metrics to arbitrary HTTP targets; when the "data_format = "json"" serializer is selected, Telegraf batches its metric objects into a payload that matches OpenObserve’s ingestion contract. The plugin supports configurable batch size, custom headers, TLS, and compression, allowing operators to authenticate with Basic or Bearer tokens and to enforce back-pressure without additional collectors. By reusing existing Telegraf agents already collecting system, application, or SNMP data, organizations can funnel rich telemetry into OpenObserve dashboards and SQL-like analytics with minimal overhead, enabling unified observability, long-term retention, and real-time alerting without vendor lock-in.

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

OpenObserve

[[outputs.http]]
  ## OpenObserve JSON metrics ingestion endpoint
  url = "https://api.openobserve.ai/api/default/ingest/metrics/_json"

  ## Use POST to push batches
  method = "POST"

  ## Basic auth header (base64 encoded "username:password")
  headers = { Authorization = "Basic dXNlcjpwYXNzd29yZA==" }

  ## Timeout for HTTP requests
  timeout = "10s"

  ## Override Content-Type to match OpenObserve expectation
  content_type = "application/json"

  ## Force Telegraf to batch and serialize metrics as JSON
  data_format = "json"

  ## JSON serializer specific options
  json_timestamp_units = "1ms"

  ## Uncomment to restrict batch size
  # batch_size = 5000

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.

OpenObserve

1. Edge Device Health Mirror: Deploy Telegraf on thousands of industrial IoT devices to capture temperature, vibration, and power metrics, then use this output to push JSON batches to OpenObserve. Plant operators gain a real-time overview of machine health and can trigger maintenance based on anomalies without relying on heavyweight collectors.

2. Blue-Green Deployment Canary: Attach a lightweight Telegraf sidecar to each Kubernetes release-candidate pod that scrapes /metrics and forwards container stats to a dedicated “canary” stream in OpenObserve. Continuous comparison of error rates between blue and green versions empowers the CI pipeline to auto-roll back poor performers within seconds.

3. Multi-Tenant SaaS Billing Pipeline: Emit per-customer usage counters via Telegraf and tag them with tenant_id; the HTTP plugin posts them to OpenObserve where SQL reports aggregate usage into invoices, eliminating separate metering services and simplifying compliance audits.

4. Security Threat Scoring: Fuse Suricata events and host resource metrics in Telegraf, deliver them to OpenObserve’s analytics engine, and run stream-processing rules that correlate spikes in suspicious traffic with CPU saturation to produce an actionable threat score and automatically open tickets in a SOAR platform.

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.