Arista LANZ and Parquet Integration

Input and output integration overview

The Arista LANZ plugin is designed for reading latency and congestion metrics from Arista LANZ, helping users monitor their network performance effectively.

This plugin writes metrics to parquet files, utilizing a schema based on the metrics grouped by name. It supports file rotation and buffered writing for optimal performance.

Integration details

Arista LANZ

This plugin provides a consumer for use with Arista Networks’ Latency Analyzer (LANZ). Metrics are read from a stream of data via TCP through port 50001 on the switches management IP. The data is in Protobuffers format, allowing for efficient transportation and parsing of data. LANZ is utilized to monitor network latency and congestion in real-time, which is vital for maintaining optimal performance in networking environments. The underlying technology, Arista’s latency analysis, provides insights into various network operations and infrastructure behaviors, making it a crucial tool for network engineering and management.

Parquet

The Parquet output plugin for Telegraf writes metrics to parquet files, which are columnar storage formats optimized for analytics. By default, this plugin groups metrics by their name, writing them to a single file. If a metric’s schema does not align with existing schemas, those metrics are dropped. The plugin generates an Apache Arrow schema based on all grouped metrics, ensuring that the schema reflects the union of all fields and tags. It operates in a buffered manner, meaning it temporarily holds metrics in memory before writing them to disk for efficiency. Parquet files require proper closure to ensure readability, and this is crucial when using the plugin, as improper closure can lead to unreadable files. Additionally, the plugin supports file rotation after specific time intervals, preventing overwrites of existing files and schema conflicts when a file with the same name already exists.

Configuration

Arista LANZ

[[inputs.lanz]]
  ## URL to Arista LANZ endpoint
  servers = [
    "tcp://switch1.int.example.com:50001",
    "tcp://switch2.int.example.com:50001",
  ]

Parquet

[[outputs.parquet]]
  ## Directory to write parquet files in. If a file already exists the output
  ## will attempt to continue using the existing file.
  # directory = "."
  
  ## Files are rotated after the time interval specified. When set to 0 no time
  ## based rotation is performed.
  # rotation_interval = "0h"
  
  ## Timestamp field name
  ## Field name to use to store the timestamp. If set to an empty string, then
  ## the timestamp is omitted.
  # timestamp_field_name = "timestamp"

Input and output integration examples

Arista LANZ

1. Real-Time Latency Monitoring: This plugin can be used to set up a monitoring dashboard that tracks real-time latency metrics across multiple interfaces. By gathering and visualizing this data, network admins can swiftly identify and rectify latency issues before they impact service quality. The challenge lies in efficiently handling the influx of metrics from various sources without overwhelming the infrastructure or incurring excessive processing delays.

2. Congestion Analysis for Traffic Engineering: Users can leverage the LANZ plugin to analyze congestion records, enabling the optimization of network traffic flows. By applying historical pattern recognition to the metrics collected, IT teams can make informed decisions on traffic management strategies, thus improving overall network efficiency. This requires implementing robust data storage and analysis capabilities to derive actionable insights from the raw metrics.

3. Integration with Alerting Systems: Integrate the metrics from this plugin with alerting systems to automatically notify network engineers of any significant changes in latency or congestion. By setting thresholds based on historical data trends, this use case enhances proactive incident management, allowing teams to address potential issues proactively. The technical challenge here is establishing the right balance in threshold settings to minimize false positives while ensuring genuine issues are flagged promptly.

4. Network Optimization Reports: Utilize the metrics gathered through the LANZ plugin to generate periodic reports that detail network performance, latency trends, and congestion events. These reports can help stakeholders understand network health over time and guide infrastructure investments. The challenge involves structuring and formatting the output data to make it comprehensible and actionable for various audiences.

Parquet

1. Data Lake Ingestion: Utilize the Parquet plugin to store metrics from various sources into a data lake. By writing metrics in parquet format, you establish a standardized and efficient way to manage time-series data, enabling faster querying capabilities and seamless integration with analytics tools like Apache Spark or AWS Athena. This setup can significantly improve data retrieval times and analysis workflows.

2. Long-term Storage of Metrics: Implement the Parquet plugin in a monitoring setup where metrics are collected over time from multiple applications. This allows for long-term storage of performance data in a compact format, making it cost-effective to store vast amounts of historical data while preserving the ability for quick retrieval and analysis later on. By archiving metrics in parquet files, organizations can maintain compliance and create detailed reports from historical performance trends.

3. Analytics and Reporting: After writing metrics to parquet files, leverage tools like Apache Arrow or PyArrow to perform complex analytical queries directly on the files without needing to load all the data into memory. This can enhance reporting capabilities, allowing teams to generate insights and visualization from large datasets efficiently, thereby improving decision-making processes based on accurate, up-to-date performance metrics.

4. Integrating with Data Warehouses: Use the Parquet plugin as part of a data integration pipeline that feeds into a modern data warehouse. By converting metrics to parquet format, the data can be easily ingested by systems like Snowflake or Google BigQuery, enabling powerful analytics and business intelligence capabilities that drive actionable insights from the collected metrics.

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.