NSQ and Librato Integration

Input and output integration overview

The NSQ Telegraf plugin reads metrics from the NSQD messaging system, allowing for real-time data processing and monitoring.

The Librato plugin for Telegraf is designed to facilitate seamless integration with the Librato Metrics API, allowing for efficient metric reporting and monitoring.

Integration details

NSQ

The NSQ plugin interfaces with NSQ, a real-time messaging platform, enabling the reading of messages from NSQD. This plugin is categorized as a service plugin, meaning it actively listens for metrics and events rather than polling them at regular intervals. With an emphasis on reliability, it prevents data loss by tracking undelivered messages until they are acknowledged by outputs. The plugin allows for configurations such as specifying NSQLookupd endpoints, topics, and channels, and it supports multiple data formats for flexibility in data handling.

Librato

The Librato plugin enables Telegraf to send metrics to the Librato Metrics API. To authenticate, users must provide an api_user and api_token, which can be acquired from the Librato account settings. This integration allows for efficient monitoring and reporting of custom metrics within the Librato platform. The plugin also utilizes a source_tag option that can enrich the metrics with contextual information from Point Tags; however, it does not currently support sending associated Point Tags. It is essential to note that any point value sent that cannot be converted to a float64 type will be skipped, ensuring that only valid metrics are processed and sent to Librato. The plugin also supports secret-store options for managing sensitive authentication credentials securely, facilitating best practices in credential management.

Configuration

NSQ

# Read metrics from NSQD topic(s)
[[inputs.nsq_consumer]]
  ## Server option still works but is deprecated, we just prepend it to the nsqd array.
  # server = "localhost:4150"

  ## An array representing the NSQD TCP HTTP Endpoints
  nsqd = ["localhost:4150"]

  ## An array representing the NSQLookupd HTTP Endpoints
  nsqlookupd = ["localhost:4161"]
  topic = "telegraf"
  channel = "consumer"
  max_in_flight = 100

  ## Max undelivered messages
  ## This plugin uses tracking metrics, which ensure messages are read to
  ## outputs before acknowledging them to the original broker to ensure data
  ## is not lost. This option sets the maximum messages to read from the
  ## broker that have not been written by an output.
  ##
  ## This value needs to be picked with awareness of the agent's
  ## metric_batch_size value as well. Setting max undelivered messages too high
  ## can result in a constant stream of data batches to the output. While
  ## setting it too low may never flush the broker's messages.
  # max_undelivered_messages = 1000

  ## Data format to consume.
  ## Each data format has its own unique set of configuration options, read
  ## more about them here:
  ## https://github.com/influxdata/telegraf/blob/master/docs/DATA_FORMATS_INPUT.md
  data_format = "influx"

Librato

[[outputs.librato]]
  ## Librato API Docs
  ## http://dev.librato.com/v1/metrics-authentication
  ## Librato API user
  api_user = "[email protected]" # required.
  ## Librato API token
  api_token = "my-secret-token" # required.
  ## Debug
  # debug = false
  ## Connection timeout.
  # timeout = "5s"
  ## Output source Template (same as graphite buckets)
  ## see https://github.com/influxdata/telegraf/blob/master/docs/DATA_FORMATS_OUTPUT.md#graphite
  ## This template is used in librato's source (not metric's name)
  template = "host"

Input and output integration examples

NSQ

1. Real-Time Analytics Dashboard: Integrate this plugin with a visualization tool to create a dashboard that displays real-time metrics from various topics in NSQ. By subscribing to specific topics, users can monitor system health and application performance dynamically, allowing for immediate insights and timely responses to any anomalies.

2. Event-Driven Automation: Combine NSQ with a serverless architecture to trigger automated workflows based on incoming messages. This use case could involve processing data for machine learning models or responding to user actions in applications, thus streamlining operations and enhancing user experience through rapid processing.

3. Multi-Service Communication Hub: Use the NSQ plugin to act as a centralized messaging hub among different microservices in a distributed architecture. By enabling services to communicate through NSQ, developers can ensure reliable message delivery while maintaining decoupled service interactions, significantly improving scalability and resilience.

4. Metrics Aggregation for Enhanced Monitoring: Implement the NSQ plugin to aggregate metrics from multiple sources before sending them to an analytics tool. This setup enables businesses to consolidate data from various applications and services, creating a unified view for better decision-making and strategic planning.

Librato

1. Real-time Application Monitoring: Utilize Librato to collect performance metrics from a web application in real-time. This setup involves sending response times, error rates, and user interactions to Librato, allowing developers to monitor the application’s health and performance metrics closely. By analyzing these metrics, teams can quickly identify and address performance bottlenecks or application failures before they impact end users.

2. Infrastructure Metrics Aggregation: Leverage this plugin to gather and send metrics from various infrastructure components, such as servers or containers, to Librato for centralized monitoring. Configuring the plugin to send CPU, memory usage, and disk I/O metrics enables system administrators to have a comprehensive view of infrastructure performance, assisting in capacity planning and resource optimization strategies.

3. Custom Metrics for Business Operations: Feed business-specific metrics, such as sales transactions or user sign-ups, to the Librato service using this plugin. By tracking these custom metrics, businesses can gain insights into their operational performance and make data-driven decisions to enhance their strategies, marketing efforts, or product development initiatives.

4. Anomaly Detection in Metrics: Implement monitoring tools that utilize machine learning for anomaly detection. By continuously sending real-time metrics to Librato, teams can analyze trends and automatically flag unusual behavior, such as sudden spikes in latency or unusual traffic patterns, enabling timely intervention and troubleshooting.

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.