Amazon ECS and Databricks Integration

Input and output integration overview

The Amazon ECS Input Plugin enables Telegraf to gather metrics from AWS ECS containers, providing detailed insights into container performance and resource usage.

Use Telegraf’s HTTP output plugin to push metrics straight into a Databricks Lakehouse by calling the SQL Statement Execution API with a JSON-wrapped INSERT or volume PUT command.

Integration details

Amazon ECS

The Amazon ECS plugin for Telegraf is designed to collect metrics from ECS (Elastic Container Service) tasks running on AWS Fargate or EC2 instances. By utilizing the ECS metadata and stats API endpoints (v2 and v3), it fetches real-time information about container performance and health within a task. This plugin operates within the same task as the inspected workload, ensuring seamless access to metadata and statistics. Notably, it incorporates ECS-specific features that distinguish it from the Docker input plugin, such as handling unique ECS metadata formats and statistics. Users can include or exclude specific containers and adjust which container states to monitor, along with defining tag options for ECS labels. This flexibility allows for a tailored monitoring experience that aligns with the specific needs of an ECS environment, thereby enhancing observability and control over containerized applications.

Databricks

This configuration turns Telegraf into a lightweight ingestion agent for the Databricks Lakehouse. It leverages the Databricks SQL Statement Execution API 2.0, which accepts authenticated POST requests containing a JSON payload with a statement field. Each Telegraf flush dynamically renders a SQL INSERT (or, for file-based workflows, a PUT ... INTO /Volumes/... command) that lands the metrics into a Unity Catalog table or volume governed by Lakehouse security. Under the hood Databricks stores successful inserts as Delta Lake transactions, enabling ACID guarantees, time-travel, and scalable analytics. Operators can point the warehouse_id at any serverless or classic SQL warehouse, and all authentication is handled with a PAT or service-principal token—no agents or JDBC drivers required. Because Telegraf’s HTTP output supports custom headers, batching, TLS, and proxy settings, the same pattern scales from edge IoT gateways to container sidecars, consolidating infrastructure telemetry, application logs, or business KPIs directly into the Lakehouse for BI, ML, and Lakehouse Monitoring. Unity Catalog volumes provide a governed staging layer when file uploads and COPY INTO are preferred, and the approach aligns with Databricks’ recommended ingestion practices for partners and ISVs.

Configuration

Amazon ECS

[[inputs.ecs]]
  # endpoint_url = ""
  # container_name_include = []
  # container_name_exclude = []
  # container_status_include = []
  # container_status_exclude = []
  ecs_label_include = [ "com.amazonaws.ecs.*" ]
  ecs_label_exclude = []
  # timeout = "5s"

[[inputs.ecs]]
  endpoint_url = "http://169.254.170.2"
  # container_name_include = []
  # container_name_exclude = []
  # container_status_include = []
  # container_status_exclude = []
  ecs_label_include = [ "com.amazonaws.ecs.*" ]
  ecs_label_exclude = []
  # timeout = "5s"

Databricks

[[outputs.http]]
  ## Databricks SQL Statement Execution API endpoint
  url = "https://{{ env "DATABRICKS_HOST" }}/api/2.0/sql/statements"

  ## Use POST to submit each Telegraf batch as a SQL request
  method = "POST"

  ## Personal-access token (PAT) for workspace or service principal
  headers = { Authorization = "Bearer {{ env "DATABRICKS_TOKEN" }}" }

  ## Send JSON that wraps the metrics batch in a SQL INSERT (or PUT into a Volume)
  content_type = "application/json"

  ## Serialize metrics as JSON so they can be embedded in the SQL statement
  data_format = "json"
  json_timestamp_units = "1ms"

  ## Build the request body.  Telegraf replaces the template variables at runtime.
  ## Example inserts a row per metric into a Unity-Catalog table.
  body_template = """
  {
    \"statement\": \"INSERT INTO ${TARGET_TABLE} VALUES {{range .Metrics}}(from_unixtime({{.timestamp}}/1000), {{.fields.usage}}, '{{.tags.host}}'){{end}}\",
    \"warehouse_id\": \"${WAREHOUSE_ID}\"
  }
  """

  ## Optional: add batching limits or TLS settings
  # batch_size = 500
  # timeout     = "10s"

Input and output integration examples

Amazon ECS

1. Dynamic Container Monitoring: Use the Amazon ECS plugin to monitor container health dynamically within an autoscaling ECS architecture. As new containers spin up or down, the plugin will automatically adjust the metrics it collects, ensuring that each container’s performance data is captured efficiently without manual configuration.

2. Custom Resource Allocation Alerts: Implement the ECS plugin to establish thresholds for resource usage per container. By integrating with notification systems, teams can receive alerts when a container’s CPU or memory usage exceeds predefined limits, enabling proactive resource management and maintaining application performance.

3. Cost-Optimization Dashboard: Leverage the metrics gathered from the ECS plugin to create a dashboard that visualizes resource usage and costs associated with each container. This insight allows organizations to identify underutilized resources, optimizing costs associated with their container infrastructure, thus driving financial efficiency in cloud operations.

4. Advanced Container Security Monitoring: Utilize this plugin in conjunction with security tools to monitor ECS container metrics for anomalies. By continuously analyzing usage patterns, any sudden spikes or irregular behaviors can be detected, prompting automated security responses and maintaining system integrity.

Databricks

1. Edge-to-Lakehouse Telemetry Pipe: Deploy Telegraf on factory PLCs to sample vibration metrics and post them every second to a serverless SQL warehouse. Delta tables power PowerBI dashboards that alert engineers when thresholds drift.
2. Blue-Green CI/CD Rollout Metrics: Attach a Telegraf sidecar to each Kubernetes canary pod; it inserts container stats into a Unity Catalog table tagged by deployment_id, letting Databricks SQL compare error-rate percentiles and auto-rollback underperforming versions.
3. SaaS Usage Metering: Insert per-tenant API-call counters via the HTTP plugin; a nightly Lakehouse query aggregates usage into invoices, eliminating custom metering micro-services.
4. Security Forensics Lake: Upload JSON batches of Suricata IDS events to a Unity Catalog volume using PUT commands, then run COPY INTO for near-real-time enrichment with Delta Live Tables, producing a searchable threat-intel lake that joins network logs with user session data.

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.