mcpField
S
stream-inspector

stream-inspector

github.com/lyticsData & databases451 installsUpdated 3w ago
Repository

About stream-inspector

stream-inspector is a Lytics skill for examining incoming data streams through the authenticated API. It provides stream listings, statistics, and recent events to help investigate collection and integration behavior.

Key features

  1. 01List available streams and fields
  2. 02View stream-specific details and statistics
  3. 03Browse recent events
  4. 04Surface errors and anomalies in event data

Use cases

  1. 01Check whether an integration is sending recent events
  2. 02Investigate errors when profiles are not updating
  3. 03Inspect the shape of incoming event data

Install

Copy the command and run it in a terminal.

$npx skills add https://github.com/lytics/agent-skills --skill stream-inspector

After installing, type/stream-inspectorin Claude Code to confirm it loaded.

Details

From the project README

Stream Inspector

Purpose

Inspect data streams flowing into Lytics -- list available streams, view their statistics, and browse recent events. Useful for debugging data collection, verifying integrations, and understanding incoming data shape.

Environment

Requires authenticated API access. See ../references/auth.md for credential resolution.

API Endpoints

List Streams
curl -s "${LYTICS_API_URL:-https://api.lytics.io}/v2/stream" \
  -H "Authorization: ${LYTICS_API_TOKEN}"
Get Stream Names
curl -s "${LYTICS_API_URL:-https://api.lytics.io}/v2/stream/names" \
  -H "Authorization: ${LYTICS_API_TOKEN}"
Get Stream Fields
curl -s "${LYTICS_API_URL:-https://api.lytics.io}/v2/stream/fields" \
  -H "Authorization: ${LYTICS_API_TOKEN}"
Get Specific Stream
curl -s "${LYTICS_API_URL:-https://api.lytics.io}/v2/stream/${STREAM_NAME}" \
  -H "Authorization: ${LYTICS_API_TOKEN}"
Stream Statistics
curl -s "${LYTICS_API_URL:-https://api.lytics.io}/v2/stream/${STREAM_NAME}/stats" \
  -H "Authorization: ${LYTICS_API_TOKEN}"
Recent Events
curl -s "${LYTICS_API_URL:-https://api.lytics.io}/v2/stream/${STREAM_NAME}/events" \
  -H "Authorization: ${LYTICS_API_TOKEN}"

Behavior

All operations are read-only -- execute immediately.

List Streams

Show a summary table of all streams:

  • Stream name, event count, last event time, field count
Stream Stats

Display key metrics:

  • Total events, events per second/minute/hour
  • Error rate, processing latency
  • Active/inactive status
Recent Events

Show the most recent events with:

  • Timestamp, key fields, event type
  • Highlight any errors or anomalies
  • If events are complex, show a summary and offer to drill into specific events

Use Cases

  • "What data is flowing in?" -> List streams + stats
  • "Is my integration working?" -> Check stream stats for recent events
  • "What does the data look like?" -> Browse recent events
  • "Why aren't profiles updating?" -> Check stream for errors

Error Handling

  • Stream not found: List available streams
  • No events: Check if the integration is active, suggest checking job status

Dependencies

  • Uses: ../references/auth.md, ../references/api-client.md

Comments

Markdown supported