Data Nexus MCP

Модульная безопасная платформа для подключения к SQL и NoSQL базам данных через REST API, MCP (Model Context Protocol) и веб-интерфейс на Vue.js.

Архитектура

┌─────────────┐     ┌──────────────┐     ┌─────────────────┐
│   Web UI    │────▶│  REST API    │────▶│ core-db-command │
│  (Vue.js)   │     │  (FastAPI)   │     │  (Python lib)   │
└─────────────┘     └──────┬───────┘     └────────┬────────┘
                           │                       │
                    ┌──────▼───────┐               │
                    │  MCP Server  │───────────────┘
                    └──────┬───────┘
                           │
                    ┌──────▼───────┐
                    │  MCP Client  │──▶ AI Agents / LLMs
                    └──────────────┘

Модули

Related MCP server: Database MCP Server

Поддерживаемые типы баз данных

Реестр драйверов поддерживает более 50 типов баз данных в 13 категориях:

• Реляционные: PostgreSQL, MySQL, MSSQL, Oracle, CockroachDB, TiDB, YugabyteDB, TimescaleDB, pgvector

• Документные: MongoDB, DocumentDB, Firestore, Couchbase (заглушка)

• Ключ-значение: Redis, DynamoDB, Memcached/etcd/RocksDB (заглушка)

• Ширококолоночные: Cassandra, ScyllaDB, Bigtable/HBase (заглушка)

• Графовые: Neo4j, Neptune/JanusGraph/ArangoDB (заглушка)

• Временные ряды: InfluxDB, ClickHouse, Prometheus/QuestDB (заглушка)

• Векторные: Qdrant, Weaviate, Milvus, Pinecone

• Поисковые: Elasticsearch, OpenSearch, Splunk/Solr (заглушка)

• Хранилища: BigQuery, Snowflake, Redshift/Databricks (заглушка)

• Мультимодельные: Cosmos DB, OrientDB (заглушка)

• Встраиваемые: SQLite, DuckDB, Realm/LMDB (заглушка)

• Реестровые: QLDB/BigchainDB (заглушка)

• NewSQL: Spanner (заглушка)

Полностью реализованные драйверы включают PostgreSQL, MySQL, MSSQL, Oracle, MongoDB, Redis, SQLite, DuckDB, Elasticsearch, ClickHouse, Neo4j, InfluxDB, Cassandra, DynamoDB, BigQuery, Snowflake, Qdrant, Weaviate, Milvus, Pinecone, Cosmos DB и Firestore. Драйверы-заглушки зарегистрированы и расширяемы.

Быстрый старт

Предварительные требования

• Python 3.11+

• Node.js 20+ (для разработки веб-интерфейса)

• Docker и Docker Compose (опционально)

1. Установка зависимостей Python

cp .env.example .env
pip install -e ".[dev]"

2. Настройка подключений

Отредактируйте config/connections.yaml и задайте секреты через переменные окружения:

connections:
  - name: postgres_prod
    type: postgresql
    host: localhost
    port: 5432
    database: mydb
    user: readonly_user
    password: ${PG_PASSWORD}

3. Запуск REST API

db-rest-api
# or: uvicorn rest_api_command.app:app --reload

Документация API: http://localhost:8000/docs

4. Запуск веб-интерфейса (разработка)

cd web-ui
cp .env.example .env
npm install
npm run dev

Откройте http://localhost:5173 — учетные данные по умолчанию: admin / changeme

5. Запуск с Docker Compose

docker compose up -d

Сервисы:

• REST API: http://localhost:8000

• Веб-интерфейс: http://localhost:5173

• PostgreSQL, MySQL, MongoDB, Redis, Elasticsearch

Конечные точки REST API

MCP-сервер

Настройте в .env или Cursor MCP env:

MCP_REST_API_URL=http://localhost:8000
# Option A: bearer token (when REST_API_AUTH_MODE=oauth2)
MCP_REST_API_TOKEN=<jwt-from-/api/auth/token>
# Option B: username/password (works with basic auth; auto-fetches JWT if oauth2)
MCP_REST_API_USER=admin
MCP_REST_API_PASSWORD=changeme

Запустите:

db-mcp-server

Добавьте в конфигурацию MCP Cursor/Claude:

{
  "mcpServers": {
    "data-nexus-mcp": {
      "command": "db-mcp-server",
      "cwd": "/path/to/data_nexus_mcp",
      "env": {
        "MCP_REST_API_URL": "http://localhost:8000",
        "MCP_REST_API_USER": "admin",
        "MCP_REST_API_PASSWORD": "changeme"
      }
    }
  }
}

Примечание: переменные REST_API_* относятся к процессу REST API (db-rest-api), а не к конфигурации MCP-сервера.

MCP-клиент

db-mcp-client                    # list available tools
db-mcp-client query local_sqlite "SELECT 1"

Аутентификация

Установите REST_API_AUTH_MODE в одно из значений:

• basic — HTTP Basic Auth (по умолчанию для разработки)

• oauth2 — JWT токены через /api/auth/token

• ldap — LDAP привязка (требует REST_API_LDAP_SERVER и REST_API_LDAP_BASE_DN)

Добавление нового драйвера

1. Создайте core_db_command/drivers/mydb.py

2. Унаследуйте от BaseDriver и задайте driver_type

3. Декорируйте с помощью @DriverRegistry.register

4. Импортируйте в core_db_command/drivers/registry_loader.py

from core_db_command.base import BaseDriver, DriverRegistry

@DriverRegistry.register
class MyDBDriver(BaseDriver):
    driver_type = "mydb"

    async def connect(self): ...
    async def disconnect(self): ...
    async def query(self, query, params=None): ...
    async def execute(self, command, params=None): ...
    async def list_tables(self, schema=None): ...
    async def describe_table(self, table, schema=None): ...

Тестирование

pytest tests/ -v

Замечания по безопасности

• Учетные данные никогда не возвращаются REST API или MCP-сервером

• Секреты должны использовать заполнители ${ENV_VAR} в конфигурации YAML

• Все конечные точки API требуют аутентификации

• Ввод запросов проверяется и ограничивается по длине

Структура проекта

data-nexus-mcp/
├── core_db_command/       # Core library + drivers
├── rest_api_command/      # FastAPI REST API
├── mcp_server/            # MCP server
├── mcp_client/            # MCP client
├── web-ui/                # Vue.js frontend
├── config/                # YAML connection config
├── tests/                 # Unit tests
├── docker-compose.yml
├── Dockerfile
└── pyproject.toml

Лицензия

MIT