MavLink and Google BigQuery 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 Google BigQuery plugin allows Telegraf to write metrics to Google Cloud BigQuery, enabling robust data analytics capabilities for telemetry data.

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.

Google BigQuery

The Google BigQuery plugin for Telegraf enables seamless integration with Google Cloud’s BigQuery service, a popular data warehousing and analytics platform. This plugin facilitates the transfer of metrics collected by Telegraf into BigQuery datasets, making it easier for users to perform analyses and generate insights from their telemetry data. It requires authentication through a service account or user credentials and is designed to handle various data types, ensuring that users can maintain the integrity and accuracy of their metrics as they are stored in BigQuery tables. The configuration options allow for customization around dataset specifications and handling metrics, including the management of hyphens in metric names, which are not supported by BigQuery for streaming inserts. This plugin is particularly useful for organizations leveraging the scalability and powerful query capabilities of BigQuery to analyze large volumes of monitoring data.

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

Google BigQuery

# Configuration for Google Cloud BigQuery to send entries
[[outputs.bigquery]]
  ## Credentials File
  credentials_file = "/path/to/service/account/key.json"

  ## Google Cloud Platform Project
  # project = ""

  ## The namespace for the metric descriptor
  dataset = "telegraf"

  ## Timeout for BigQuery operations.
  # timeout = "5s"

  ## Character to replace hyphens on Metric name
  # replace_hyphen_to = "_"

  ## Write all metrics in a single compact table
  # compact_table = ""
  

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.

Google BigQuery

1. Real-Time Analytics Dashboard: Leverage the Google BigQuery plugin to feed live metrics into a custom analytics dashboard hosted on Google Cloud. This setup would allow teams to visualize performance data in real-time, providing insights into system health and usage patterns. By using BigQuery’s querying capabilities, users can easily create tailored reports and dashboards to meet their specific needs, thus enhancing decision-making processes.

2. Cost Management and Optimization Analysis: Utilize the plugin to automatically send cost-related metrics from various services into BigQuery. Analyzing this data can help businesses identify unnecessary expenses and optimize resource usage. By performing aggregation and transformation queries in BigQuery, organizations can create accurate forecasts and manage their cloud spending efficiently.

3. Cross-Team Collaboration on Monitoring Data: Enable different teams within an organization to share their monitoring data using BigQuery. With the help of this Telegraf plugin, teams can push their metrics to a central BigQuery instance, fostering collaboration. This data-sharing approach encourages best practices and cross-functional awareness, leading to collective improvements in system performance and reliability.

4. Historical Analysis for Capacity Planning: By using the BigQuery plugin, companies can collect and store historical metrics data essential for capacity planning. Analyzing trends over time can help anticipate system needs and scale infrastructure proactively. Organizations can create time-series analyses and identify patterns that inform their long-term strategic decisions.

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.