ai.anomalyarmor/armor-mcp

Official

by anomalyarmor · Python

AnomalyArmor

Data observability tools for engineering teams: alerts, freshness, schema drift, lineage, quality.

Monitor data quality with alerts, freshness checks, schema drift detection, and lineage.

README.md9 KBView on GitHub

AnomalyArmor Agents

AI skills and MCP server for AnomalyArmor data observability. Monitor data quality, detect schema drift, and manage alerts directly from Claude Code, Cursor, or any MCP-compatible AI tool.

Version: 0.6.0 | Tools: 52 consolidated MCP tools | Skills: 14 slash commands

Quick Start

Option 1: Claude Code Plugin (Recommended)

bash

# Install the plugin
claude plugin marketplace add anomalyarmor/agents
claude plugin install armor@anomalyarmor

# Or via skills.sh
npx skills add anomalyarmor/agents

Then use skills like:

/armor:status - Check data health
/armor:alerts - View and manage alerts
/armor:recommend - Get AI monitoring recommendations
/armor:ask - Ask questions about your data

Option 2: MCP Server

Add to your MCP configuration (Claude Code, Cursor, etc.):

json

{
  "mcpServers": {
    "armor": {
      "command": "uvx",
      "args": ["armor-mcp"]
    }
  }
}

Prerequisites

AnomalyArmor Account: Sign up at anomalyarmor.ai
API Key: Generate at Settings > API Keys
Configure: Set ARMOR_API_KEY env var or create ~/.armor/config.yaml:

yaml

api_key: aa_live_your_key_here

Available Skills

Skill	Description	Example
`/armor:start`	Guided onboarding for new users	"Help me get set up"
`/armor:status`	Health summary across all assets	"Is my data healthy?"
`/armor:connect`	Connect a new data source	"Connect my Snowflake warehouse"
`/armor:monitor`	Set up freshness and schema monitoring	"Monitor freshness for orders table"
`/armor:alerts`	Query and manage alerts	"What alerts fired yesterday?"
`/armor:ask`	Natural language Q&A about your data	"What tables contain customer data?"
`/armor:analyze`	Trigger AI analysis	"Analyze the finance schema"
`/armor:quality`	Data quality metrics and validity rules	"Add null check for customer_id"
`/armor:coverage`	Monitoring coverage analysis	"What tables have no monitoring?"
`/armor:recommend`	AI-driven monitoring recommendations	"What should I monitor?"
`/armor:tags`	Asset tagging and classification	"Tag this table as PII"
`/armor:investigate`	Root cause analysis	"Why is this table stale?"
`/armor:lineage`	Data lineage exploration	"What depends on this table?"
`/armor:profile`	Table profiling and stats	"Profile the orders table"

MCP Tools (29 consolidated)

Tools follow a consolidated pattern: one tool per domain handles multiple operations via an action parameter, reducing context window usage while maintaining full functionality.

Health and Briefing

health_summary() - Overall data health across all assets
get_todays_briefing() - Daily AI briefing with alerts, freshness, and coverage gaps

Alerts (5 tools)

get_alerts_summary() - Alert counts by severity and status
list_alerts(status, severity, asset_id, from_date, to_date) - Query alerts with filters
list_inbox_alerts(status, limit) - Unresolved alerts inbox
update_alert(alert_id, action, ...) - Acknowledge, resolve, snooze, or comment on alerts
get_alert_trends(period) - Alert trends over time
get_alert_history(alert_id) - Full history for a specific alert

Alert Rules (3 tools)

list_alert_rules(asset_id, is_active) - List configured rules
create_alert_rule(asset_id, rule_type, ...) - Create new alert rule
manage_alert_rule(rule_id, action, ...) - Update, delete, enable/disable, or duplicate rules

Assets (3 tools)

list_assets(source, asset_type, search) - List monitored assets
create_asset(name, source_type, connection_config) - Create data source
manage_asset(asset_id, action, ...) - Update, delete, test connection, or trigger discovery
trigger_asset_discovery(asset_id) - Start schema discovery

Freshness (4 tools)

get_freshness_summary() - Freshness overview across all assets
check_freshness(asset_id, table_path) - Check specific table freshness
setup_freshness(asset_id, table_path, check_interval, ...) - Create freshness schedule
list_freshness_schedules(asset_id) - List configured schedules
manage_freshness_schedule(schedule_id, action, ...) - Update, delete, pause/resume schedules

Schema Drift (5 tools)

get_schema_summary() - Schema drift overview
list_schema_changes(asset_id, severity, from_date, to_date) - List detected changes
create_schema_baseline(asset_id, description) - Create baseline
enable_schema_monitoring(asset_id, schedule_type, notify_on) - Enable monitoring
disable_schema_monitoring(asset_id) - Disable monitoring
get_schema_monitoring(asset_id) - View current monitoring config
dry_run_schema(asset_id, schedule_type) - Test schema monitoring before enabling

Data Quality (4 tools)

get_metrics_summary(asset_id) / list_metrics(asset_id) - View metrics
create_metric(asset_id, metric_type, table_path, ...) - Create row count, null rate, or custom metric
manage_metric(metric_id, action, ...) - Update, delete, capture, or view snapshots
get_validity_summary(asset_id) / list_validity_rules(asset_id) - View validity rules
create_validity_rule(asset_id, rule_type, table_path, ...) - Create validity rule
manage_validity_rule(rule_id, action, ...) - Update, delete, check, or view results

Referential Integrity (2 tools)

create_referential_check(asset_id, ...) - Create cross-table referential check
manage_referential(check_id, action, ...) - List, delete, run, or view results

Destinations (4 tools)

list_destinations(destination_type) - List alert destinations (Slack, email, webhook)
setup_destination(destination_type, ...) - Create Slack channel, email, or webhook destination
manage_destination(destination_id, action, ...) - Update, delete, test, enable/disable
manage_rule_destinations(rule_id, action, ...) - Link/unlink destinations to alert rules

Coverage and Recommendations (3 tools)

get_coverage(asset_id) - Coverage tier and score for an asset
manage_coverage(asset_id, action) - Get next steps or apply recommended monitoring
recommend(asset_id, recommendation_type) - AI recommendations for freshness, metrics, coverage, or thresholds

Intelligence (2 tools)

ask_question(asset, question) - Natural language Q&A
generate_intelligence(asset) - Trigger AI knowledge base generation

Catalog (4 tools)

get_lineage(asset_id, depth, direction) - Data lineage graph
job_status(job_id) - Check async job status
create_tag(asset_id, name, object_path, ...) - Create and assign tags
list_tags(asset_id) / apply_tags(asset_id, ...) - List and apply tags

API Keys

get_api_key_info() - View current API key details and permissions

Examples

Check Data Health

code

User: Is my data healthy?

Your data health status:
- Overall: WARNING
- 3 unresolved alerts (1 critical, 2 warning)
- 2 stale tables (orders, customers)
- 1 unacknowledged schema change
- Coverage: 65% (Tier 2: Protected)

Get AI Recommendations

code

User: What should I monitor on my Snowflake warehouse?

Based on your table patterns and update frequency:
1. orders (high traffic) - Add freshness check (hourly), row count metric
2. customers (PII) - Enable schema drift monitoring, add null checks
3. payments (financial) - Add freshness + row count + validity rules

Want me to set these up? I can configure all three in one go.

Daily Briefing

code

User: What happened overnight?

Your daily briefing:
- 2 new alerts: orders table stale (6h), schema change in users
- Coverage improved: finance schema now at Tier 3 (Verified)
- Recommendation: 4 tables still have no monitoring. Run /armor:recommend.

Root Cause Analysis

code

User: Why is the orders table stale?

Investigation results:
- Last update: 6 hours ago (expected: hourly)
- Upstream dependency: raw_orders was last updated 8 hours ago
- Likely cause: upstream ETL job failed or delayed
- Impact: 3 downstream dashboards affected

Troubleshooting

Authentication Failed

code

Error: No API key configured

Solution: Set ARMOR_API_KEY environment variable or create ~/.armor/config.yaml

MCP Server Not Found

code

Error: MCP server 'armor' not found

Solution:

Restart your AI tool after config changes
Verify uvx is installed: uvx --version
Check MCP config syntax

Skills Not Loading

Solution:

Verify plugin installed: claude plugin list
Check skills directory exists
Restart Claude Code

Development

See AGENTS.md for development guidelines.

Support

License

MIT License - see LICENSE

Install

Configuration

Environment variables

ARMOR_API_KEYrequiredsecret

AnomalyArmor API key (aa_live_*). Generate at https://app.anomalyarmor.ai/settings/api-keys.

claude_desktop_config.json

{
  "mcpServers": {
    "armor-mcp": {
      "command": "uvx",
      "args": [
        "armor-mcp"
      ],
      "env": {
        "ARMOR_API_KEY": "<YOUR_ARMOR_API_KEY>"
      }
    }
  }
}