MCP 服务器

DynamoDB Read-Only MCP

一个服务器，使像 Claude 这样的大型语言模型 (LLM) 能够通过自然语言请求查询 AWS DynamoDB 数据库，支持表管理、数据查询和模式分析。

README

DynamoDB 只读 MCP

一个利用模型上下文协议 (MCP) 查询 AWS DynamoDB 数据库的服务器。该服务器允许像 Claude 这样的大型语言模型 (LLM) 通过自然语言请求查询 DynamoDB 数据。

特性

此 MCP 服务器提供以下特性：

表管理工具:
- list-tables: 查看所有 DynamoDB 表的列表
- describe-table: 查看关于特定表的详细信息
数据查询工具:
- scan-table: 扫描表的所有或部分数据
- query-table: 搜索表中符合特定条件的数据
- paginate-query-table : 检索跨多个页面符合特定条件的数据
- get-item: 检索具有特定键的项目
- count-items: 计算表中的项目数量
资源:
- dynamodb-tables-info: 提供所有表的元数据的资源
- dynamodb-table-schema: 提供特定表的模式信息的资源
提示:
- dynamodb-query-help: 用于编写 DynamoDB 查询的帮助提示

安装和执行

您可以使用下面的“使用 NPX 运行”方法，无需安装即可运行它。

安装

克隆存储库:

git clone https://github.com/jjikky/dynamo-readonly-mcp.git
cd dynamo-readonly-mcp

安装所需的包:
```
npm install
```

创建一个 .env 文件并设置您的 AWS 凭证:

AWS_ACCESS_KEY_ID=your_access_key
AWS_SECRET_ACCESS_KEY=your_secret_key
AWS_REGION=your_region

构建和运行

npm run build
npm start

连接到 Claude Desktop

要将此 MCP 服务器与 Claude Desktop 一起使用，您需要修改 Claude Desktop 配置文件。

打开 Claude Desktop 配置文件:
- macOS: ~/Library/Application Support/Claude/claude_desktop_config.json
- Windows: %APPDATA%\Claude\claude_desktop_config.json

添加服务器配置，如下所示:

{
  "mcpServers": {
    "dynamodb-readonly": {
      "command": "node",
      "args": ["/absolute-path/dynamo-readonly-mcp/dist/index.js"],
      "env": {
        "AWS_ACCESS_KEY_ID": "your_access_key",
        "AWS_SECRET_ACCESS_KEY": "your_secret_key",
        "AWS_REGION": "your_region"
      }
    }
  }
}

重新启动 Claude Desktop。

使用 NPX 运行

您也可以使用 npx 运行此服务器，而无需全局安装:

{
  "mcpServers": {
    "dynamodb-readonly": {
      "command": "npx",
      "args": ["-y", "dynamo-readonly-mcp"],
      "env": {
        "AWS_ACCESS_KEY_ID": "your_access_key",
        "AWS_SECRET_ACCESS_KEY": "your_secret_key",
        "AWS_REGION": "your_region"
      }
    }
  }
}

使用示例

您可以向 Claude 提出如下问题：

"你能告诉我 DynamoDB 中有哪些表吗？"
"解释一下 Users 表的结构"
"在 'Users' 表中查找 groupId 为 '0lxp4paxk7' 的用户数量"

架构

此 MCP 服务器由以下分层结构组成：

客户端界面 (Claude Desktop) - 用户与 LLM 之间的交互
MCP 协议层 - 提供标准化的消息交换方法
DynamoDB 服务器 - 实现与 DynamoDB 交互的功能
AWS SDK - 与 AWS DynamoDB 服务通信

关键操作机制

1. 初始化和连接

当服务器启动时，会发生以下过程：

async function main() {
  const transport = new StdioServerTransport();
  await server.connect(transport);
  console.error('DynamoDB read-only MCP server is running...');
}

StdioServerTransport 通过标准输入/输出设置通信通道。
server.connect(transport) 通过 MCP 协议连接到 Claude Desktop。
在连接期间，服务器将有关支持的工具、资源和提示的信息发送到客户端。

2. 工具请求处理

当用户向 Claude 提出类似“显示 DynamoDB 表的列表”的问题时：

Claude 分析此请求并调用 list-tables 工具。
此请求通过 MCP 协议发送到服务器。
服务器执行相应的工具处理程序：

server.tool('list-tables', 'Gets a list of all DynamoDB tables', {}, async () => {
  try {
    const tables = await listTables();
    return {
      content: [{ type: 'text', text: JSON.stringify(tables, null, 2) }],
    };
  } catch (error) {
    return { isError: true, content: [{ type: 'text', text: `Error: ${error.message}` }] };
  }
});

结果通过 MCP 协议返回给 Claude。
Claude 将此结果处理成自然语言并呈现给用户。

3. 特定参数处理

当用户请求“告诉我 Users 表的结构”时：

Claude 确定此请求应使用 describe-table 工具。
Claude 将参数配置为 { tableName: "Users" }。
此信息被发送到 MCP 服务器：

server.tool(
  'describe-table',
  'Gets detailed information about a DynamoDB table',
  {
    tableName: z.string().describe('Name of the table to get detailed information for'),
  },
  async ({ tableName }) => {
    // Query table information using the tableName parameter
    const tableInfo = await describeTable(tableName);
    // Return results
  }
);

在这里，z.string() 使用 Zod 库来验证参数。

4. 资源处理

资源是 MCP 的另一个特性，它提供只读数据：

server.resource('dynamodb-tables-info', 'DynamoDB table information', async () => {
  // Create and return resource data
  const tables = await listTables();
  const tablesInfo = await Promise.all(/* Query table information */);

  return {
    contents: [
      {
        uri: 'dynamodb://tables-info',
        text: JSON.stringify(tablesInfo, null, 2),
        mimeType: 'application/json',
      },
    ],
  };
});

Claude 访问资源并将其用作上下文信息。

5. 提示处理

MCP 服务器可以为特定任务提供提示模板：

server.prompt(
  'dynamodb-query-help',
  'A prompt that helps write DynamoDB queries',
  {
    tableName: z.string().describe('Table name to query'),
    queryType: z.enum(['basic', 'advanced']).default('basic'),
  },
  async ({ tableName, queryType }) => {
    // Generate prompt content
    return {
      messages: [
        {
          role: 'user',
          content: { type: 'text', text: helpContent },
        },
      ],
    };
  }
);