Azure Storage Queue and M3DB Integration

Input and output integration overview

This plugin gathers sizes of Azure Storage Queues, providing users with metrics that enhance observability and management of their storage resources.

This plugin allows Telegraf to stream metrics to M3DB using the Prometheus Remote Write protocol, enabling scalable ingestion through the M3 Coordinator.

Integration details

Azure Storage Queue

The Azure Storage Queue plugin allows users to gather various metrics concerning the size and message age of Azure Storage Queues. This plugin connects to Azure Storage, requiring specific credentials and offers configurable options to enhance performance. By collecting metrics, users gain valuable insights into the performance of their storage queues, enabling them to monitor usage patterns, peak loads, and optimize storage management effectively. The integration with Azure’s storage infrastructure provides a straightforward way to monitor queue metrics, ensuring that users can react to changes promptly, maintaining the efficiency and reliability of their applications.

M3DB

This configuration uses Telegraf’s HTTP output plugin with prometheusremotewrite format to send metrics directly to M3DB through the M3 Coordinator. M3DB is a distributed time series database designed for scalable, high-throughput metric storage. It supports ingestion of Prometheus remote write data via its Coordinator component, which manages translation and routing into the M3DB cluster. This approach enables organizations to collect metrics from systems that aren’t natively instrumented for Prometheus (e.g., Windows, SNMP, legacy systems) and ingest them efficiently into M3’s long-term, high-performance storage engine. The setup is ideal for high-scale observability stacks with Prometheus compatibility requirements.

Configuration

Azure Storage Queue

[[inputs.azure_storage_queue]]
  ## Required Azure Storage Account name
  account_name = "mystorageaccount"

  ## Required Azure Storage Account access key
  account_key = "storageaccountaccesskey"

  ## Set to false to disable peeking age of oldest message (executes faster)
  # peek_oldest_message_age = true

M3DB

# Configuration for sending metrics to M3
[outputs.http]
  ## URL is the address to send metrics to
  url = "https://M3_HOST:M3_PORT/api/v1/prom/remote/write"

  ## HTTP Basic Auth credentials
  username = "admin"
  password = "password"

  ## Data format to output.
  data_format = "prometheusremotewrite"

  ## Outgoing HTTP headers
  [outputs.http.headers]
    Content-Type = "application/x-protobuf"
    Content-Encoding = "snappy"
    X-Prometheus-Remote-Write-Version = "0.1.0"

Input and output integration examples

Azure Storage Queue

1. Monitoring Queue Performance in Real-time: Use the Azure Storage Queue plugin to continuously track the size and age of messages in queues, providing operators with real-time insights. This information can help teams understand throughput and delays, enabling them to adjust processing rates or troubleshoot bottlenecks.

2. Dynamic Alerting Based on Queue Metrics: Integrate metrics from the Azure Storage Queue plugin into an alerting system. By defining thresholds for message age and queue size, organizations can automate notifications, ensuring they promptly address situations where queues become too long or messages are delayed, maintaining a healthy and responsive system environment.

3. Optimizing Cost Management: Leverage the insights from the Azure Storage Queue metrics to identify periods of inactivity and implement cost-saving measures by adjusting storage scales. By analyzing queue size trends, organizations can make informed decisions about resource allocation, effectively balancing performance needs with cost efficiency.

4. Enhancing Application Fault Tolerance: Use the age metrics of the oldest message to design smarter retry strategies within applications. In scenarios where message processing fails, understanding how long messages sit in the queue allows developers to fine-tune their error handling logic, enhancing the resilience and reliability of their applications.

M3DB

1. Large-Scale Cloud Infrastructure Monitoring: Deploy Telegraf agents across thousands of virtual machines and containers to collect metrics and stream them into M3DB through the M3 Coordinator. This provides reliable, long-term visibility with minimal storage overhead and high availability.

2. Legacy System Metrics Ingestion: Use Telegraf to gather metrics from older systems that lack native Prometheus exporters (e.g., Windows servers, SNMP devices) and forward them to M3DB via remote write. This bridges modern observability workflows with legacy infrastructure.

3. Centralized App Telemetry Aggregation: Collect application-specific telemetry using Telegraf’s plugin ecosystem (e.g., exec, http, jolokia) and push it into M3DB for centralized storage and query via PromQL. This enables unified analytics across diverse data sources.

4. Hybrid Cloud Observability: Install Telegraf agents on-prem and in the cloud to collect and remote-write metrics into a centralized M3DB cluster. This ensures consistent visibility across environments while avoiding the complexity of running Prometheus federation layers.

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.