MCP 连接器¶

概述¶

Snowflake 中的 MCP 连接器将 Snowflake Intelligence 和 Cortex Agents 连接到远程的模型上下文协议 (MCP) 服务器，使代理能够发现并调用由 Atlassian Jira、Salesforce 或您自己的自定义应用程序等提供商托管的工具。通过 MCP 连接器，您的代理不仅可以回答问题，还可以在企业系统中执行操作，例如创建 Jira 工单、更新 Salesforce 记录或发布到 Slack，所有这些都在 Snowflake 的治理环境中完成。

设置受支持的 MCP 连接器¶

您可以通过最少的配置连接到以下 MCP 服务器：

• Atlassian

• GitHub

• Glean

• Linear

• Salesforce

对于这些 MCP 提供商，您需要完成以下工作流程：

1. 在 API_USER_AUTHENTICATION 类型字段中指定提供商详细信息。

2. 设置提供商配置，该配置对于每个提供商都是唯一的。

3. 在创建外部 MCP 服务器对象时引用此 API 集成。

-- Create the API integration using dynamic client registration (DCR)
CREATE API INTEGRATION jira_mcp_api_integration
  API_PROVIDER = external_mcp
  API_ALLOWED_PREFIXES = ('https://mcp.jira.atlassian.com')
  API_USER_AUTHENTICATION = (
    TYPE=OAUTH_DYNAMIC_CLIENT,
    OAUTH_RESOURCE_URL='https://mcp.atlassian.com/v1/mcp'
  )
  ENABLED = TRUE;

-- Create the external MCP server
CREATE EXTERNAL MCP SERVER atlassian_mcp_server
  WITH DISPLAY_NAME = 'Atlassian (Jira & Confluence)'
  URL='https://mcp.atlassian.com/v1/mcp'
  API_INTEGRATION = jira_mcp_api_integration;

自定义 MCP 连接器¶

您还可以手动配置自定义连接器以连接到任何与 MCP 兼容的端点。

1. 在创建 API 集成时提供完整的 OAuth 配置：

   CopyExpand

    -- Create the API integration with full OAuth configuration
   CREATE API INTEGRATION custom_mcp_api_integration
      API_PROVIDER = external_mcp
      API_ALLOWED_PREFIXES = ('https://internal.mycompany.com/mcp')
      API_USER_AUTHENTICATION = (
        TYPE = OAUTH2
        OAUTH_CLIENT_ID = 'your_client_id'
        OAUTH_CLIENT_SECRET = 'your_client_secret'
        OAUTH_TOKEN_ENDPOINT = 'https://internal.mycompany.com/oauth/token'
        OAUTH_CLIENT_AUTH_METHOD = CLIENT_SECRET_BASIC
        OAUTH_AUTHORIZATION_ENDPOINT = 'https://internal.mycompany.com/oauth/authorize'
      )
      ENABLED = TRUE;
   

   Show lessSee more

   Scroll to top

   或者，您可以将 API 集成与 DCR 一起使用：

   CopyExpand

   CREATE API INTEGRATION custom_mcp_api_integration
     API_PROVIDER = external_mcp
     API_ALLOWED_PREFIXES = ('https://internal.mycompany.com/mcp')
     API_USER_AUTHENTICATION = (
       TYPE = OAUTH_DYNAMIC_CLIENT
       OAUTH_RESOURCE_URL='https://internal.mycompany.com/mcp'
     )
     ENABLED = TRUE;
   

   Show lessSee more

   Scroll to top

2. 创建 MCP 服务器对象：

   CopyExpand

   -- Create the external MCP server
   CREATE EXTERNAL MCP SERVER mycompany_mcp_server
     WITH DISPLAY_NAME = 'Mycompany MCP server'
     API_INTEGRATION = custom_mcp_api_integration;
   

   Show lessSee more

   Scroll to top

3. 在代理配置中引用 MCP 服务器：

   CopyExpand

   -- Add MCP server to agent
   ALTER AGENT my_support_agent
     ADD MCP_SERVER = 'db.schema.MCP server';
   

   Show lessSee more

   Scroll to top

将 MCP 连接器添加到 Cortex Agent¶

创建 MCP 服务器对象后，代理开发者会在 Cortex Agent 配置中引用它。MCP 连接器位于代理管理员 UI 中可用，开发者可在此浏览并选择已在账户级别配置的 MCP 连接器。您还可以使用 SQL 或 API 将 MCP 连接器添加到您的代理中。

ALTER AGENT [ IF EXISTS ] <name> MODIFY LIVE VERSION SET SPECIFICATION $$
    <previous_spec>
    mcp_servers:
      - server_spec:
         name: "db.schema.mcp_server1"
      - server_spec:
         name: "db.schema.mcp_server2"
$$;

PUT /api/v2/databases/{database}/schemas/{schema}/agents/{name}

{
    "comment": "An agent to answer questions about all my data",
    "profile": {
        "display_name": "My Agent"
    },
    "models": {
        "orchestration": "claude-4-sonnet"
    },
    "mcp_servers": [
        {"server_spec": "prod_db.integrations.jira_mcp_server"},
        {"server_spec": "prod_db.integrations.github_mcp_server"}
    ]
}

引用这些 MCP 服务器的 Cortex Agent 可以访问提供商提供的工具。例如，对于 Atlassian，工具包括创建 Jira 问题、评论问题、创建 Confluence 页面以及更新现有页面。

当代理被调用时，它会从每个 MCP 服务器获取工具列表，并将这些工具包含在其编排中。代理根据用户的查询和 MCP 服务器提供的工具描述来选择并调用工具。

在 Snowflake Intelligence 中使用 MCP 连接器¶

Snowflake Intelligence 用户通过 Snowflake Intelligence 接口连接到外部 MCP 服务器：

1. 按照 访问代理 中的说明导航到 Snowflake Intelligence 接口。

2. 打开源面板并选择 Connectors。

3. 在所选连接器旁边选择 Connect。您也可以选择 Manage Connections，然后选择 Connect。

4. 用户将被重定向到第三方服务的身份验证页面以批准连接。

5. 身份验证后，连接器将在源列表中显示为 Connected。您现在可以与代理交互以从外部 MCP 服务器取信息。

要断开服务器连接，用户可以完成以下操作：

1. 选择 Manage Connections。

2. 选择 MCP Server，然后选择 Disconnect。

用户可以在源下拉菜单中连接和断开连接器，以将其包含在代理的编排中或从中排除。未处于 Connected 状态的连接器不会包含在编排中。

当用户的身份验证令牌过期时，Snowflake Intelligence 会提示用户重新进行身份验证。

在 Agent:run API 中使用 MCP 连接器¶

Agent:run API 通过客户端接口连接到 MCP 服务器。使用以下函数通过第三方服务对用户进行身份验证：

• 启动 OAuth 流程的函数：

  CopyExpand

  -- Returns authorization URI to authenticate through the third-party service
  SELECT SYSTEM$START_USER_OAUTH_FLOW('<API_INTEGRATION_NAME>');
  

  Show lessSee more

  Scroll to top

• 完成 OAuth 流程的函数：

  CopyExpand

  SYSTEM$FINISH_OAUTH_FLOW( '<query_string>' )
  

  Show lessSee more

  Scroll to top

SYSTEM$START_USER_OAUTH_FLOW 会返回一个授权 URL，用于 API_PROVIDER = EXTERNAL_MCP 的 API 集成。在浏览器中打开 URL 以完成同意授权，然后在同一会话中使用来自重定向 URL 的查询字符串运行 SYSTEM$FINISH_OAUTH_FLOW。有关 SYSTEM$FINISH_OAUTH_FLOW 的更多信息，请参阅 SYSTEM$FINISH_OAUTH_FLOW。

管理 MCP 服务器¶

-- List all MCP servers in the account
SHOW EXTERNAL MCP SERVERS IN ACCOUNT;

-- List MCP servers in a specific database or schema
SHOW EXTERNAL MCP SERVERS IN DATABASE prod_db;
SHOW EXTERNAL MCP SERVERS IN SCHEMA prod_db.integrations;

DESCRIBE EXTERNAL MCP SERVER mycompany_mcp_server;

-- Disable the MCP server
ALTER API INTEGRATION mycompany_mcp_integration SET ENABLED = FALSE;

-- Re-enable the MCP server
ALTER API INTEGRATION mycompany_mcp_integration SET ENABLED = TRUE;

-- Drop the MCP server
DROP EXTERNAL MCP SERVER mycompany_mcp_server;

-- Drop the API integration (permanently deletes OAuth configuration and secrets)
DROP API INTEGRATION mycompany_mcp_integration;

关键注意事项和最佳实践¶

• 自定义 MCP 服务器：在连接到不在可用 MCP 连接器列表中的 MCP 端点时，请使用自定义服务器。Snowflake 在 API 集成中支持 Atlassian、GitHub、Glean、Linear 和 Salesforce 的用户身份验证类型。

• 最低权限访问： 仅授予每个角色所需的最低权限。对 MCP 服务器的访问权限不会自动授予对其工具的访问权限，您必须为每个工具单独授予权限。

• OAuth 身份验证： Snowflake 仅支持对所有 MCP 服务器连接使用 OAuth。

• 禁用或删除： 禁用 API 集成会保留其配置，但会使所有用户令牌立即失效并阻止工具调用。删除 API 集成会将其与所有存储的密钥一起永久删除。在执行维护时禁用集成。在停用时删除集成。

• 主机名格式： 在配置 MCP 服务器连接时，主机名中请使用连字符 (-) 而不是下划线 (_)。包含下划线的主机名会导致连接问题。

限制¶

以下限制适用于 MCP 连接器：

• 监控： MCP 工具调用不会记录到监控表中。

• MCP 协议范围： 外部 MCP 服务器仅支持工具能力。不支持资源、提示、根、通知、版本协商、生命周期阶段和采样。

• 已禁用的集成： 您无法创建引用已禁用 API 集成的新 MCP 服务器。

• 主机名格式： 主机名必须使用连字符，不能使用下划线。