Skip to main content
Glama
sankeerthnagapuri

Polaris Catalog & Iceberg Governance MCP Server

by sankeerthnagapuri
OverviewSchemaRelated ServersScoreDiscussions
Python
Remote

Polaris Catalog & Iceberg Governance MCP Server

A FastMCP server that gives AI assistants (and data engineers) conversational access to Apache Polaris catalog management, Iceberg REST Catalog APIs, and PyIceberg table storage/health inspection tools.

It is designed to enable AI agents (like Cursor, Windsurf, or Claude Desktop) to audit data governance, check access control roles, query namespaces, and inspect Iceberg metadata.

What it does

12 tools across 10 categories:

Category

Tool Name

Operations

What you can ask

Connection

connect

N/A

"Connect to Polaris"

disconnect

N/A

"Disconnect from the Polaris server"

get_server_config

N/A

"What endpoints does the server support?"

Catalogs

catalog_request

list, get

"What catalogs exist?", "Show me the storage config for catalog X"

Namespaces

namespace_request

list, get, exists

"List all namespaces in catalog X", "Does namespace Y exist?"

Tables

table_request

list, get, exists

"List tables in prod.analytics", "Show me the schema and snapshots for table Z"

Views

view_request

list, get, exists

"List views", "Load the revenue_daily view metadata"

Principals

principal_request

list, get, roles_assigned

"Who has access?", "What roles does Alice have?"

Roles & Grants

role_request

list_principal_roles, get_principal_role, list_principals_for_role, list_catalog_roles, get_catalog_role, list_catalog_roles_for_principal_role, list_principal_roles_for_catalog_role, list_grants_for_catalog_role

"What roles exist?", "Which catalog roles map to service_admin?", "What privileges does the analyst role have?"

Policies

policy_request

list, get, get_applicable

"What policies apply to this table?", "Show the compaction policy"

Generic Tables

generic_table_request

list, get

"What Delta/CSV tables are registered?"

Metadata Inspection

inspect_request

snapshots, files, manifests, partitions, health

"Check snapshot history", "List raw Parquet data/delete files", "Show partition health/delete file overhead"

Related MCP server: Data Product MCP

Quick Start

Install

cd apache-polaris-iceberg-ai-mcp
pip install -e .

Run the server

# Via FastMCP CLI
fastmcp run server.py

# Or directly
python -m server

Configure in Claude Desktop

Add to your claude_desktop_config.json:

{
  "mcpServers": {
    "polaris-catalog": {
      "command": "fastmcp",
      "args": ["run", "/path/to/apache-polaris-iceberg-ai-mcp/server.py"]
    }
  }
}

Configure in VS Code (Copilot / Cline / etc.)

Add to your .vscode/mcp.json or MCP settings:

{
  "servers": {
    "polaris-catalog": {
      "command": "fastmcp",
      "args": ["run", "/path/to/apache-polaris-iceberg-ai-mcp/server.py"]
    }
  }
}

Authentication

The server supports three authentication modes via the connect tool:

1. Client Credentials (default)

connect(uri="http://localhost:8181", client_id="admin", client_secret="password")

2. Bearer Token

connect(uri="http://localhost:8181", token="eyJhbGciOiJSUzI1NiIs...")

3. Keycloak / OIDC Password Credentials

Use this to exchange username/password credentials for a token from Keycloak or another OIDC provider first, and then authenticate to Polaris with that token:

connect(
  uri="http://localhost:8181",
  oauth_token_url="http://localhost:8080/realms/polaris-realm/protocol/openid-connect/token",
  client_id="polaris-client",
  client_secret="sBbUvTG7qWGbmgwgxKmnEuzqpuE3uGAu",
  username="sankeerth",
  password="nagapuri"
)

Storage & Inspection Configuration

Since the inspect_request tool reads the underlying Avro metadata and Parquet data/delete files directly from your object storage, you should configure your S3/MinIO environment variables or pass options dynamically.

S3 / MinIO Environment Variables

By default, the inspection tools look for these environment variables or fallback to local MinIO dev defaults (admin / password / http://localhost:9000):

  • S3_ENDPOINT: S3 endpoint URL (e.g., http://localhost:9000 or https://s3.amazonaws.com)

  • AWS_ACCESS_KEY_ID: Your AWS or MinIO access key

  • AWS_SECRET_ACCESS_KEY: Your AWS or MinIO secret key

Override parameters

The inspect_request tool also accepts optional overrides:

  • s3_endpoint

  • aws_access_key_id

  • aws_secret_access_key

Architecture

apache-polaris-iceberg-ai-mcp/
├── server.py              # FastMCP server — registers consolidated tools
├── client.py              # Async HTTP client (httpx) with OAuth2 + password grant auth
├── requirements.txt       # Dependencies (fastmcp, httpx, pydantic, pyiceberg, pyarrow, s3fs)
└── tools/                 # Tool implementations by domain
    ├── connection.py      # connect, disconnect, get_server_config
    ├── catalogs.py        # catalog_request (list, get)
    ├── principals.py      # principal_request (list, get, roles_assigned)
    ├── roles.py           # role_request (principal/catalog roles, mapping, grants)
    ├── namespaces.py      # namespace_request (list, get, exists)
    ├── tables.py          # table_request (list, get, exists)
    ├── views.py           # view_request (list, get, exists)
    ├── policies.py        # policy_request (list, get, get_applicable)
    ├── generic_tables.py  # generic_table_request (list, get)
    └── inspect.py         # inspect_request (snapshots, files, manifests, partitions, health)

License

MIT License

This server cannot be installed

A
license - permissive license
-
quality - not tested
C
maintenance

How are these scores calculated?

Maintenance

–Maintainers
–Response time
–Release cycle
–Releases (12mo)
Commit activity

Resources

Unclaimed servers have limited discoverability.

Looking for Admin?

If you are the server author, to access and configure the admin panel.

Latest Blog Posts

MCP directory API

We provide all the information about MCP servers via our MCP API.

curl -X GET 'https://glama.ai/api/mcp/v1/servers/sankeerthnagapuri/apache-polaris-iceberg-ai-mcp'

If you have feedback or need assistance with the MCP directory API, please join our Discord server