@rawtree/mcp
v0.3.2
Published
An MCP server for [RawTree](https://rawtree.com/), an analytics database for unstructured data. Query data with SQL, insert JSON, inspect table schemas, review RawTree logs, and manage database credentials from MCP clients like Claude Code, Cursor, and Cl
Readme
RawTree MCP Server
An MCP server for RawTree, an analytics database for unstructured data. Query data with SQL, insert JSON, inspect table schemas, review RawTree logs, and manage database credentials from MCP clients like Claude Code, Cursor, and Claude Desktop.
Features
- Queries — Run read-only SQL against a RawTree database and receive JSON rows, metadata, statistics, and hints.
- Ingest — Insert a single JSON object, arrays of JSON objects, or public URL data.
- Tables — List tables, describe table columns and sizes, and delete tables after explicit confirmation.
- Logs — Inspect RawTree query and insert history with structured filters for type, status, origin, table, hints, time window, and pagination.
- API Keys — List, create, and revoke RawTree API keys for a database. Creation responses include the one-time API key value.
- Organizations — List organizations and manage their members and roles with an OAuth-authenticated user.
- Databases — List, create, verify S3 access for, and delete databases in a cluster.
- Clusters — List, inspect, pause, resume, discover current creation options, verify optional customer-owned S3 access, configure independent per-database S3 access, and provision vertically autoscaling dedicated clusters after explicit confirmation where required. RawTree enforces user and organization-admin authorization.
- Apps — List the app catalog for a cluster, inspect installation state, and install or uninstall apps after explicit confirmation.
- Transports — Supports stdio for local MCP clients and dual-era Streamable HTTP for remote or multi-client deployments, including stateless MCP 2026-07-28 requests and legacy initialize-handshake clients.
Setup
Create a RawTree API key from the RawTree CLI, dashboard, or API. A database API key starts with rt_ and is enough for data tools such as run-query, insert-json, list-tables, and list-logs.
Usage
The server supports two transport modes: stdio (default) and HTTP.
Stdio Transport
Quick Setup
npx add-mcp @rawtree/mcp --name rawtree --env "RAWTREE_API_KEY=rt_xxxxxxxxx"Claude Code
claude mcp add rawtree -e RAWTREE_API_KEY=rt_xxxxxxxxx -- npx -y @rawtree/mcpCursor
Open the command palette and choose "Cursor Settings" > "MCP" > "Add new global MCP server".
{
"mcpServers": {
"rawtree": {
"command": "npx",
"args": ["-y", "@rawtree/mcp"],
"env": {
"RAWTREE_API_KEY": "rt_xxxxxxxxx"
}
}
}
}Claude Desktop
Open Claude Desktop settings > "Developer" tab > "Edit Config".
{
"mcpServers": {
"rawtree": {
"command": "npx",
"args": ["-y", "@rawtree/mcp"],
"env": {
"RAWTREE_API_KEY": "rt_xxxxxxxxx"
}
}
}
}HTTP Transport
Run the server over HTTP for remote or web-based integrations. In HTTP mode, each MCP client authenticates by passing its RawTree API key in the Authorization header.
Start the server:
npx -y @rawtree/mcp --http --port 3000The server listens on http://127.0.0.1:3000 and exposes the MCP endpoint at /mcp using Streamable HTTP.
Claude Code
claude mcp add rawtree --transport http http://127.0.0.1:3000/mcp --header "Authorization: Bearer rt_xxxxxxxxx"Cursor
{
"mcpServers": {
"rawtree": {
"url": "http://127.0.0.1:3000/mcp",
"headers": {
"Authorization": "Bearer rt_xxxxxxxxx"
}
}
}
}You can also set the port via the MCP_PORT environment variable:
MCP_PORT=3000 npx -y @rawtree/mcp --httpOptions
--api-key: RawTree database API key for stdio mode--api-url: RawTree API base URL, defaulthttps://api.rawtree.com--database: Database name for scoped routes--org: Organization name for scoped routes--http: Use HTTP transport instead of stdio--port: HTTP port when using--http, default3000orMCP_PORT
Environment variables:
RAWTREE_API_KEY: RawTree database API keyRAWTREE_API_URL: RawTree API base URL, defaulthttps://api.rawtree.comRAWTREE_DATABASE: Database name for scoped routesRAWTREE_ORG: Organization name for scoped routesMCP_PORT: HTTP port when using--http
Tools
Data
run-query— Run read-only SQL and return RawTree's JSON query response. Accepts organization, cluster, and database overrides.insert-json— Insert JSON object(s) into a table.insert-from-url— Ingest data from a public URL and wait for completion, returning the inserted row count (ornullwhen unavailable).
Tables
list-tables— List tables in the configured database.create-table— Create an empty table with cluster-default storage or an optional per-table customer-owned S3 bucket.describe-table— Inspect columns, row count, byte count, database, and organization.delete-table— Delete a table after explicit confirmation. Requires admin permission.
create-table.s3Storage is optional. Omit it to inherit database-level storage when configured, then the cluster's default storage. To use explicit per-table customer-owned storage, provide the complete s3Storage object with data and backup buckets, optional paths, roleArn, and externalId. Cluster responses expose s3_storage metadata with bucket and path values only; credentials are never returned.
Logs
list-logs— Read RawTree query and insert logs. Defaults to the last hour when no time window is provided.
Structured log filters include:
{
"statuses": ["error"],
"types": ["insert"],
"tables": ["events"],
"origins": ["api"],
"hints": "any",
"limit": 50
}API Keys
list-api-keys— List API keys for the configured database.create-api-key— Create a key withadmin,read_write,write_only, orread_onlypermission.delete-api-key— Revoke a key after explicit confirmation.
Databases
list-databases— List databases in an organization and cluster.verify-database-s3-access— Verify a customer-owned S3 configuration before creating a database.create-database— Create a database with cluster-default storage or an optional customer-owned S3 configuration.delete-database— Delete a database and all its data after explicit confirmation.
create-database.s3Storage is optional. Omit it to use the cluster's default storage. When provided, tables inherit that database-level storage unless they specify their own s3Storage override. Call verify-database-s3-access with the identical configuration before creation. Database listings expose s3_storage metadata with bucket and path values only; credentials are never returned.
Organizations
list-organizations— List organizations available to the authenticated user. Requires a user credential such as OAuth.list-organization-members— List accepted members of an organization with their user IDs and roles.add-organization-member— Send an organization member invitation after confirming the organization and email address. Membership starts after acceptance.update-organization-member— Change an accepted member's role toadminormemberafter explicit confirmation.remove-organization-member— Remove an accepted member and revoke organization access after explicit confirmation.
Clusters
list-clusters— List dedicated clusters accessible in an organization.list-cluster-sizes— List current replica limits, supported per-replica sizes, and default vertical autoscaling bounds.verify-cluster-s3-access— Verify an optional customer-owned S3 configuration before cluster creation. The check temporarily writes, reads, and removes a probe object in both configured destinations.create-cluster— Provision a dedicated cluster after confirming its organization, replica count, minimum size, maximum size, autoscaling behavior, optional idle timeout, optional customer-owned default S3 configuration, and optional independent per-database S3 access.get-cluster— Get one dedicated cluster and its current lifecycle status by ID.update-cluster— Change a dedicated cluster's idle timeout after confirming the organization, cluster ID, and new value. Use0to disable idling.pause-cluster— Pause a dedicated cluster after explicit confirmation. Its databases become unavailable until the cluster is resumed.resume-cluster— Resume a paused dedicated cluster after explicit confirmation.
Cluster tools are advertised to every MCP client. Call list-cluster-sizes before create-cluster; creation starts at the selected minimum per-replica size and can vertically autoscale to the selected maximum. idleTimeoutMinutes accepts 0 to disable idling or a value from 15 through 43200; omit it during creation to use the server default.
create-cluster.s3Storage is optional. Omit it to use RawTree-managed storage. When provided, data and backups each require a bucket and accept an optional object-key path; roleArn identifies the customer IAM role RawTree may assume, and externalId must exactly match the role trust policy. Call verify-cluster-s3-access with the identical configuration before creation, and repeat verification after changing any s3Storage field.
create-cluster.databaseS3Access is optional and independent from s3Storage. Provide it when databases may later use dedicated customer-owned buckets, including when the cluster uses RawTree-managed default storage. It contains externalId and databaseBucketTag; tag every customer database bucket with rawtree.com/cluster=<databaseBucketTag>. If both s3Storage and databaseS3Access are supplied, their External ID values must match. The role ARN and bucket destinations for a specific database are supplied later through create-database.s3Storage. Cluster list and get responses expose database_s3_access metadata only; credentials are never returned.
The RawTree API remains the authorization boundary: cluster access requires a user access token, and cluster creation, S3 verification, updates, pausing, and resuming additionally require organization-admin access.
Apps
list-apps— List the available apps and installation state for one cluster.install-app— Install an app on a cluster after confirming the organization, cluster name, and app ID.uninstall-app— Uninstall an app and disable its native endpoints after confirming the organization, cluster name, and app ID. Existing cluster data is not deleted.
App tools require a user credential. Organization members can list apps; installing and uninstalling require organization-admin access. Use the app IDs returned by list-apps.
Connectors
list-connectors— List the managed connectors and destinations in a cluster.get-connector— Get one connector's status and sanitized configuration.create-connector— Create an active Kafka connector with one or more destinations.get-connector-metrics— Read connector and per-destination health, lag, buffers, delivery counters, errors, source lag, and HTTP latency counters.add-connector-destination— Preserve the existing routes and add another topic-to-table destination.set-connector-status— Pause or resume all destinations in a connector.
Connector tools use the same nested field names as the RawTree API. A minimal Kafka connector request looks like:
{
"organization": "acme",
"cluster": "production",
"name": "orders",
"type": "kafka",
"destinations": [
{
"topics": ["orders"],
"database": "default",
"table": "orders"
}
],
"settings": {
"bootstrap_servers": "kafka.example.com:9092",
"auto_offset_reset": "largest",
"tls": { "enabled": true },
"sasl": {
"enabled": true,
"mechanism": "PLAIN",
"username": "connector-user",
"password": "secret"
},
"batch": { "max_events": 1000, "timeout_secs": 1 }
}
}Creating connectors, adding destinations, and changing status require
organization-admin access. Credentials are encrypted by RawTree and omitted
from connector responses. get-connector-metrics returns cumulative counters;
take two samples and divide counter differences by elapsed time to calculate
event rates.
Programmatic hosted deployments can require explicit resource selection on
every applicable tool. Organization and cluster identify the resource boundary;
database remains an optional override and defaults to default when omitted.
This lets one OAuth-backed MCP connection switch between organizations,
clusters, and databases without encoding context in the MCP URL:
const server = createMcpServer(client, { requireExplicitScope: true });Examples
Query
{
"organization": "acme",
"cluster": "production",
"database": "analytics",
"sql": "SELECT count() AS rows FROM events"
}Insert JSON
{
"table": "events",
"data": [
{
"event": "signup",
"user_id": "user_123",
"source": "mcp"
}
]
}Debug Failed Inserts
{
"statuses": ["error"],
"types": ["insert"],
"startTime": "2026-05-28T09:00:00.000Z",
"endTime": "2026-05-28T10:00:00.000Z",
"limit": 25
}Local Development
- Install and build:
pnpm install
pnpm build- Use the local build from an MCP client:
claude mcp add rawtree -e RAWTREE_API_KEY=rt_xxxxxxxxx -- node /absolute/path/to/rawtree-mcp/dist/index.jsLive Testing with an MCP Client
Run TypeScript in watch mode, then point a separate MCP client at the built server:
pnpm tsc --watch{
"mcpServers": {
"rawtree-dev": {
"command": "node",
"args": ["/absolute/path/to/rawtree-mcp/dist/index.js"],
"env": {
"RAWTREE_API_KEY": "rt_xxxxxxxxx"
}
}
}
}Restart the MCP client session after each rebuild.
Programmatic usage
The package root exposes the reusable MCP server layer. The Node HTTP transport
is available separately from @rawtree/mcp/http, so hosted adapters can use
the server factory without importing the local process entrypoint.
import { createMcpServer, RawTreeClient } from '@rawtree/mcp';
const client = new RawTreeClient({ apiKey: process.env.RAWTREE_API_KEY! });
const server = createMcpServer(client);Publishing
Publishing is handled by the GitHub Actions Publish workflow.
Required repository secret:
NPM_TOKEN: npm automation token with permission to publish@rawtree/mcp.
Release flow:
- Update
package.jsonto the new version. - Push the change to
main. - Create and publish a GitHub release with a tag that matches the package version, such as
v0.2.0.
The workflow verifies that the release tag matches package.json, runs lint, tests, and build, then publishes with npm provenance:
npm publish --provenance --access publicTesting with MCP Inspector
Build first:
pnpm buildStart the inspector:
RAWTREE_API_KEY=rt_xxxxxxxxx pnpm inspectorIn the Inspector UI, choose stdio:
- Command:
node - Args:
dist/index.js - Environment:
RAWTREE_API_KEY=rt_xxxxxxxxx
