重定向客户端连接¶

示例¶

以下 SQL 语句将贯穿整个 Client Redirect 工作流程。本主题后面的章节将详细介绍每个步骤。

-- Create a new primary connection
CREATE CONNECTION myconnection;

-- View accounts in your organization that are enabled for replication
SHOW REPLICATION ACCOUNTS;

-- Configure failover accounts for the primary connection
ALTER CONNECTION myconnection
  ENABLE FAILOVER TO ACCOUNTS myorg.myaccount2, myorg.myaccount3;

-- View the details for the connection
SHOW CONNECTIONS;

CREATE CONNECTION myconnection
  AS REPLICA OF myorg.myaccount1.myconnection;

先决条件¶

要为账户启用 Client Redirect 功能，组织管理员（具有 ORGADMIN 角色的用户）必须为两个或多个账户启用复制。要启用复制，请参阅 先决条件：为组织中的账户启用复制，了解详细说明。

创建主连接¶

您可以使用 Snowsight 或 SQL 在源账户中创建主连接。

在每个目标账户中创建辅助连接¶

使用 CREATE CONNECTION ...AS REPLICA OF，在一个或多个账户中创建辅助连接，并将其链接到主连接。请注意，您只能在 ALTER CONNECTION ...ENABLE FAILOVER TO ACCOUNTS 语句（在 创建主连接 中）中指定的账户中创建辅助连接。

在每个目标账户中执行 CREATE CONNECTION ...AS REPLICA OF 语句，以创建指定主连接的副本。

在要创建辅助连接的 目标 账户中，执行本节中的 SQL 语句。

1. 执行 SHOW CONNECTIONS 命令以查看所有连接。复制主连接的 primary 列的值。在下一步中创建辅助连接时，您将使用此值。

   SHOW CONNECTIONS;
   
   +--------------------+-------------------------------+---------------------+-------------------+-----------------+---------------+-------------------------------+-------------------------------------+-------------------------------------------+-------------------+-------------------+
   | snowflake_region   | created_on                    | account_name        | name              | comment         | is_primary    | primary                       | failover_allowed_to_accounts        | connection_url                            | organization_name | account_locator   |
   |--------------------+-------------------------------+---------------------+-------------------+-----------------+---------------+-------------------------------+-------------------------------------+-------------------------------------------+-------------------+-------------------|
   | AWS_US_WEST_2      | 2020-07-19 14:49:11.183 -0700 | MYORG.MYACCOUNT1    | MYCONNECTION      | NULL            | true          | MYORG.MYACCOUNT1.MYCONNECTION | MYORG.MYACCOUNT2, MYORG.MYACCOUNT3  | myorg-myconnection.snowflakecomputing.cn | MYORG             | MYACCOUNTLOCATOR1 |
   +--------------------+-------------------------------+---------------------+-------------------+-----------------+---------------+-------------------------------+-------------------------------------+-------------------------------------------+-------------------+-------------------+
   

   Copy

2. 执行 CREATE CONNECTION ...AS REPLICA OF 命令以创建辅助连接。

   例如，创建一个链接到 myorg.myaccount1.myconnection 主连接的名为 myconnection 的辅助连接。在 AS REPLICA OF 之后，粘贴主连接的完全限定名称（上一步中从 SHOW CONNECTIONS 输出复制的名称）。

   CREATE CONNECTION myconnection
     AS REPLICA OF MYORG.MYACCOUNT1.MYCONNECTION;
   

   Copy

3. 执行 SHOW CONNECTIONS 命令以验证是否已创建辅助连接。

   SHOW CONNECTIONS;
   
   +--------------------+-------------------------------+---------------------+-------------------+-----------------+---------------+-------------------------------+-------------------------------------+-------------------------------------------+-------------------+-------------------+
   | snowflake_region   | created_on                    | account_name        | name              | comment         | is_primary    | primary                       | failover_allowed_to_accounts        | connection_url                            | organization_name | account_locator   |
   |--------------------+-------------------------------+---------------------+-------------------+-----------------+---------------+-------------------------------+-------------------------------------+-------------------------------------------+-------------------+-------------------|
   | AWS_US_WEST_2      | 2020-07-19 14:49:11.183 -0700 | MYORG.MYACCOUNT1    | MYCONNECTION      | NULL            | true          | MYORG.MYACCOUNT1.MYCONNECTION | MYORG.MYACCOUNT2, MYORG.MYACCOUNT3  | myorg-myconnection.snowflakecomputing.cn | MYORG             | MYACCOUNTLOCATOR1 |
   | AWS_US_EAST_1      | 2020-07-22 13:52:04.925 -0700 | MYORG.MYACCOUNT2    | MYCONNECTION      | NULL            | false         | MYORG.MYACCOUNT1.MYCONNECTION |                                     | myorg-myconnection.snowflakecomputing.cn | MYORG             | MYACCOUNTLOCATOR2 |
   +--------------------+-------------------------------+---------------------+-------------------+-----------------+---------------+-------------------------------+-------------------------------------+-------------------------------------------+-------------------+-------------------+
   

   Copy

将 FAILOVER 权限授予角色 – 可选¶

账户管理员可以将连接对象的 FAILOVER 权限授予账户角色。这使得账户管理员以外的用户可以将辅助连接提升为主连接。

例如，要授予角色 my_failover_role 对连接 myconnection 进行故障转移的能力，请在 目标 账户上执行以下语句：

GRANT FAILOVER ON CONNECTION myconnection TO ROLE my_failover_role;

具有角色 my_failover_role 的用户现在可以在故障转移的情况下将辅助连接 myconnection 提升为主连接：

USE ROLE my_failover_role;

ALTER CONNECTION myconnection PRIMARY;

有关重定向客户端连接的更多信息，请参阅 重定向客户端连接。

支持的 Snowflake 客户端¶

Snowsight 和 Snowflake Classic Console 支持 Client Redirect。此外，以下 Snowflake 客户端版本（及更高版本）支持 Client Redirect：

配置 Snowflake 客户端¶

连接到 Snowflake 时，请使用以下连接 URL 的主机名：

主机名： organization_name-connection_name.snowflakecomputing.cn

其中：

organization_name

Snowflake 组织的名称。您的用户连接到的 Snowflake 账户包含在此组织中。

connection_name

连接对象的名称。

<organization-name>-<connection-name>

myorg-myconnection

https://<organization_name>-<connection_name>.snowflakecomputing.cn/

https://myorg-myconnection.snowflakecomputing.cn/

accountname = <organization_name>-<connection_name>
username = <username>
password = <password>

accountname = myorg-myconnection
username = jsmith
password = mySecurePassword

con = snowflake.connector.connect (
      account = <organization_name>-<connection_name>
      user = <username>
      password = <password>
)

con = snowflake.connector.connect (
      account = myorg-myconnection
      user = jsmith
      password = mySecurePassword
)

jdbc:snowflake://<organization_name>-<connection_name>.snowflakecomputing.cn/?user=<username>&password=<password>

jdbc:snowflake://myorg-myconnection.snowflakecomputing.cn/?user=jsmith&password=mySecurePassword

[ODBC Data Sources]
<account_name> = SnowflakeDSIIDriver

[<dsn_name>]
Description     = SnowflakeDB
Driver          = SnowflakeDSIIDriver
Locale          = en-US
SERVER          = <organization_name>-<connection_name>.snowflakecomputing.cn

[ODBC Data Sources]
myaccount = SnowflakeDSIIDriver

[client_redirect]
Description     = SnowflakeDB
Driver          = SnowflakeDSIIDriver
Locale          = en-US
SERVER          = myorg-myconnection.snowflakecomputing.cn

var configuration = {
  username: '<username>',
  password: '<password>',
  account: <organization_name>-<connection_name>.
}

var connection = snowflake.createConnection(configuration)

var configuration = {
  username: 'jsmith',
  password: 'mySecurePassword',
  account: myorg-myconnection.
}

var connection = snowflake.createConnection(configuration)

cfg := &Config{
  Account: "<organization_name>-<connection_name>",
  User: "<username>",
  Password: "<password>"
}

dsn, err := DSN(cfg)

cfg := &Config{
  Account: "myorg-myconnection",
  User: "jsmith",
  Password: "mySecurePassword"
}

dsn, err := DSN(cfg)

connection_parameters = {
  "account": "<organization_name>-<connection_name>",
  "user": "<snowflake_user>",
  "password": "<snowflake_password>"
}

connection_parameters = {
  "account": "myorg-myconnection",
  "user": "jsmith",
  "password": "mySecurePassword"
}

# Properties file (a text file) for establishing a Snowpark session
URL = https://<organization_name>-<connection_name>.snowflakecomputing.cn

# Properties file (a text file) for establishing a Snowpark session
URL = https://myorg-myconnection.snowflakecomputing.cn

# Properties file (a text file) for establishing a Snowpark session
URL = https://<organization_name>-<connection_name>.snowflakecomputing.cn

# Properties file (a text file) for establishing a Snowpark session
URL = https://myorg-myconnection.snowflakecomputing.cn

联合身份验证和 SSO¶

在每个目标账户中单独配置联合身份验证。使用“ 配置 Snowflake 以使用联合身份验证”中的设置选项提供身份提供商 (IdP) 详细信息：

OAuth¶

在每个目标账户中为 OAuth 配置安全集成对象。安全集成对象必须与源账户中的同一对象相同。有关说明，请参阅相应的主题：

• Snowflake OAuth

• External OAuth

要检索安全集成属性，请查询源账户中每个安全集成的 DESCRIBE INTEGRATION 命令。然后，通过执行 CREATE INTEGRATION 命令在目标账户中重新创建每个安全集成。

将辅助连接提升为主连接¶

启动重定向包括：使用 ALTER CONNECTION 将可用区域中的辅助连接提升为主要连接。同时，以前的主连接变成辅助连接。

1. 在包含要提升为主连接的辅助连接的可用区域中登录到目标账户。

2. 执行此部分中的 SQL 语句：

   • 查看账户中的所有连接：

     SHOW CONNECTIONS;
     

     Copy

     该语句返回以下输出：

     +--------------------+-------------------------------+---------------------+-------------------+-----------------+---------------+-------------------------------+-------------------------------------+-------------------------------------------+-------------------+-------------------+
     | snowflake_region   | created_on                    | account_name        | name              | comment         | is_primary    | primary                       | failover_allowed_to_accounts        | connection_url                            | organization_name | account_locator   |
     |--------------------+-------------------------------+---------------------+-------------------+-----------------+---------------+-------------------------------+-------------------------------------+-------------------------------------------+-------------------+-------------------|
     | AWS_US_WEST_2      | 2020-07-19 14:49:11.183 -0700 | MYORG.MYACCOUNT1    | MYCONNECTION      | NULL            | true          | MYORG.MYACCOUNT1.MYCONNECTION | MYORG.MYACCOUNT2, MYORG.MYACCOUNT3  | myorg-myconnection.snowflakecomputing.cn | MYORG             | MYACCOUNTLOCATOR1 |
     | AWS_US_EAST_1      | 2020-07-22 13:52:04.925 -0700 | MYORG.MYACCOUNT2    | MYCONNECTION      | NULL            | false         | MYORG.MYACCOUNT1.MYCONNECTION |                                     | myorg-myconnection.snowflakecomputing.cn | MYORG             | MYACCOUNTLOCATOR2 |
     +--------------------+-------------------------------+---------------------+-------------------+-----------------+---------------+-------------------------------+-------------------------------------+-------------------------------------------+-------------------+-------------------+
     

   • 将辅助连接提升为主连接：

     ALTER CONNECTION myconnection PRIMARY;
     

     Copy

   • 验证以前的辅助连接是否提升成功：

     SHOW CONNECTIONS;
     

     Copy

     该语句返回以下输出：

     +--------------------+-------------------------------+---------------------+-------------------+-----------------+---------------+-------------------------------+-------------------------------------+-------------------------------------------+-------------------+-------------------+
     | snowflake_region   | created_on                    | account_name        | name              | comment         | is_primary    | primary                       | failover_allowed_to_accounts        | connection_url                            | organization_name | account_locator   |
     |--------------------+-------------------------------+---------------------+-------------------+-----------------+---------------+-------------------------------+-------------------------------------+-------------------------------------------+-------------------+-------------------|
     | AWS_US_WEST_2      | 2020-07-19 14:49:11.183 -0700 | MYORG.MYACCOUNT1    | MYCONNECTION      | NULL            | false         | MYORG.MYACCOUNT1.MYCONNECTION | MYORG.MYACCOUNT2, MYORG.MYACCOUNT3  | myorg-myconnection.snowflakecomputing.cn | MYORG             | MYACCOUNTLOCATOR1 |
     | AWS_US_EAST_1      | 2020-07-22 13:52:04.925 -0700 | MYORG.MYACCOUNT2    | MYCONNECTION      | NULL            | true          | MYORG.MYACCOUNT1.MYCONNECTION |                                     | myorg-myconnection.snowflakecomputing.cn | MYORG             | MYACCOUNTLOCATOR2 |
     +--------------------+-------------------------------+---------------------+-------------------+-----------------+---------------+-------------------------------+-------------------------------------+-------------------------------------------+-------------------+-------------------+
     

为 Snowflake 服务的专用连接修改 DNS 设置¶

要将客户端连接重定向到辅助账户，网络管理员必须修改“为 Snowflake 服务的专用连接配置 DNS 设置”中创建的 DNS 设置。

使用 DNS 提供商提供的工具，修改连接 URL 的 DNS 设置。

将目标主机名设置为存储新主连接的账户的完整 Snowflake 账户 URL，包括用于标识托管账户的区域和云平台的附加段，以及对 AWS PrivateLink、Azure 专用链接或 Google Cloud Private Service Connect 的支持。这是账户名称，其中客户端连接现将重定向到连接 URL。更新 DNS 设置时，请务必包括专用连接 OCSP URL。

例如：

myaccount1.us-east-1.privatelink.snowflakecomputing.cn.
ocsp.myaccount1.us-east-1.privatelink.snowflakecomputing.cn.

（请注意必须包含尾随句点。）

验证连接 URL 是否已更新¶

要验证连接 URL 是否已更新，您可以确认当前连接的区域。使用连接 URL 连接到 Snowflake 并执行 CURRENT_REGION 函数。

SELECT CURRENT_REGION();

使用 Snowsight 修改连接的目标账户¶

您可以在创建连接后修改连接的目标账户，但不能更改连接名称。

1. 登录到 Snowsight 并导航至 Admin » Accounts。

2. 选择 Client Redirect。

3. 找到要编辑的连接。选择位于该行最后一列的 More 菜单 (...)。

使用 SQL 修改连接的目标账户¶

您可以使用 ALTER CONNECTION 命令为主连接添加多个目标账户。有关示例，请参阅 示例。

使用 Snowsight 删除连接¶

要删除连接，您必须以具有 ACCOUNTADMIN 角色的用户身份登录具有主连接的 源 账户。

1. 登录到 Snowsight 并导航至 Admin » Accounts。

2. 选择 Client Redirect。

3. 找到要删除的连接。选择位于该行最后一列的 More 菜单 (...)。

4. 选择 Drop，然后选择 Drop Connection。

使用 SQL 删除连接¶

您可以使用 DROP CONNECTION 命令删除连接。

1. 删除目标账户中的所有辅助连接。

2. 删除源账户中的主连接。

有关示例，请参阅 示例。

使用 Snowsight 监控 Client Redirect¶

要查看 Client Redirect 连接详细信息，请完成以下步骤：

1. 登录到 Snowsight 并导航至 Admin » Accounts。

2. 选择 Replication，然后选择 Client Redirect。

3. 如果会话没有活动仓库，系统将提示您选择一个仓库。

使用搜索和筛选，监控特定连接。

• 您可以按连接名称进行搜索。在 |sf-search-icon|（搜索）框中，输入连接名称以筛选结果。

• 选择 Redirecting 即可按主 (To) 或辅助 (From) 连接筛选结果。

• 选择 |sf-account-icon|（账户）菜单即可按账户名称筛选结果。

您可以查看有关每个连接的以下信息：

使用 SQL 监控 Client Redirect¶

您可以使用 SHOW CONNECTIONS 命令和 LOGIN_HISTORY 函数查看连接详细信息并监控使用情况。

SHOW CONNECTIONS;

+--------------------+-------------------------------+---------------------+-------------------+-----------------+---------------+-------------------------------+-------------------------------------+-------------------------------------------+-------------------+-------------------+
| snowflake_region   | created_on                    | account_name        | name              | comment         | is_primary    | primary                       | failover_allowed_to_accounts        | connection_url                            | organization_name | account_locator   |
|--------------------+-------------------------------+---------------------+-------------------+-----------------+---------------+-------------------------------+-------------------------------------+-------------------------------------------+-------------------+-------------------|
| AWS_US_WEST_2      | 2023-07-05 08:57:11.143 -0700 | MYORG.MYACCOUNT1    | MYCONNECTION      | NULL            | true          | MYORG.MYACCOUNT1.MYCONNECTION | MYORG.MYACCOUNT2, MYORG.MYACCOUNT3  | myorg-myconnection.snowflakecomputing.cn | MYORG             | MYACCOUNTLOCATOR1 |
| AWS_US_EAST_1      | 2023-07-08 09:15:11.143 -0700 | MYORG.MYACCOUNT2    | MYCONNECTION      | NULL            | false         | MYORG.MYACCOUNT1.MYCONNECTION | MYORG.MYACCOUNT2, MYORG.MYACCOUNT3  | myorg-myconnection.snowflakecomputing.cn | MYORG             | MYACCOUNTLOCATOR1 |
|--------------------+-------------------------------+---------------------+-------------------+-----------------+---------------+-------------------------------+-------------------------------------+-------------------------------------------+-------------------+-------------------|

SELECT event_timestamp, user_name, client_ip, reported_client_type, is_success, connection
  FROM TABLE(INFORMATION_SCHEMA.LOGIN_HISTORY(
    DATEADD('HOURS',-72,CURRENT_TIMESTAMP()),
    CURRENT_TIMESTAMP()))
  ORDER BY EVENT_TIMESTAMP;