使用 Snowsight 设置 Snowflake Connector for MySQL

备注

使用 Snowflake Connector for MySQL 需遵守 Connector 条款。

备注

对于 AUTOCOMMIT 参数设置为 false 的账户，应在配置期间使用 SQL 命令 ALTER SESSION SET AUTOCOMMIT=TRUE 在会话级别将其设置为 true。

使用 Snowsight 配置 Snowflake Connector for MySQL 的过程包括以下步骤：

本主题内容：

为连接器配置日志记录

Snowflake Connector for MySQL 使用事件表来存储连接器代码生成的事件和日志。设置事件表是一个强制性步骤。

备注

如果已为用于连接器的账户配置了事件表，请跳过此步骤。

要创建事件表，请执行以下操作：

CREATE EVENT TABLE IF NOT EXISTS <fully_qualified_event_table_name> CHANGE_TRACKING = TRUE;
ALTER ACCOUNT SET EVENT_TABLE = <fully_qualified_event_table_name>;
Copy

其中：

fully_qualified_event_table_name

指定事件表的名称。

可以在 `此处<https://other-docs.snowflake.com/en/native-apps/consumer-enable-logging>`__ 找到有关 事件表 的更多信息。

安装 Snowflake Connector for MySQL

以下过程描述了如何安装连接器：

  1. 以具有 ACCOUNTADMIN 角色的用户身份登录 Snowsight。

  2. 在左侧导航栏中，选择 Data Products » Marketplace。

  3. 搜索 Snowflake Connector for MySQL，然后选择连接器的磁贴。

  4. 在 Snowflake Connector for MySQL 页面中，选择 Get。

    这将显示一个对话框，您可以使用该对话框开始安装过程的初始部分。

    在对话框中配置以下内容：

    1. 在 Warehouse used for installation 字段中，选择要用于安装连接器的仓库。

      备注

      这与连接器用于同步来自 MySQL 数据库的数据的仓库不同。在后续步骤中，您将为此目的创建一个单独的仓库。

    2. （可选）您可以在 Options » Application name 下更改应用程序的名称。

    3. 选择 Get。

  5. 此时将显示一个通知对话框：Successfully Installed。要继续配置，请选择 Configure。

    之后对话框关闭，并且 Snowflake Connector for MySQL 页面显示用于配置和管理连接器的 UI。

可选：安装 Snowflake Connector for MySQL 的多个实例

您可以在 Snowflake 账户中安装同一连接器应用程序的多个实例。

要安装其他应用程序实例，请执行以下操作：

  1. 登录 Snowsight。

  2. 导航到 Snowflake Marketplace 并选择要为其安装另一个实例的应用程序。此时将显示应用程序详细信息页面。

  3. 点击 Add instance。出现安装对话框。

  4. 提供实例名称并选择要在安装期间使用的仓库。

  5. 选择 Get 开始安装过程。

添加连接器实例可能需要几分钟时间。安装过程完成后，您会收到一封电子邮件通知。

注意

为了避免引入的数据损坏，在配置连接器期间，请始终使用与所有其他原生应用程序不同的数据库架构。

要访问已安装的连接器应用程序实例，请执行以下操作：

  1. 登录 Snowsight。

  2. 在导航菜单中，选择 Data Products » Apps。

  3. 选择您的应用程序实例以访问它。

配置 Snowflake Connector for MySQL

  1. 以具有 ACCOUNTADMIN 角色的用户身份登录 Snowsight。

  2. 在导航菜单中，选择 Data Products » Apps。

  3. 搜索 Snowflake Connector for MySQL，然后选择它。现在，您将转到安装向导页面，该页面将引导您完成配置过程。

按如下方式配置应用程序：

第 1 步：完成先决条件

完成以下先决条件步骤以设置数据库和代理：

步骤

描述

Provide access to the source database

Snowflake Connector for MySQL 数据源的先决条件

Download and install the Agent

设置 Snowflake Connector for MySQL 代理容器

为每个已完成的步骤选择 Mark as done。

选择 Start configuration。

第 2 步：配置

在配置对话框中，为以下字段输入值：

字段

描述

Compute Warehouse

连接器的新的专用虚拟仓库的标识符。此仓库将用于处理从代理获取的数据并将其放入目标表中。

为您的账户指定一个唯一的名称。仓库的名称必须是有效的 对象标识符。

备注

请勿指定您在连接器安装开始时选择的同一仓库。

配置过程创建一个具有指定名称的新 X-Small 仓库。

Operational Warehouse

连接器的新的专用虚拟仓库的标识符。此仓库将用于管理连接器及其代理的活动。

为您的账户指定一个唯一的名称。仓库的名称必须是有效的 对象标识符。

备注

请勿指定您在连接器安装开始时选择的同一仓库。

配置过程创建一个具有指定名称的新 X-Small 仓库。

Role

代理的新自定义角色的标识符。

为您的账户指定一个唯一的名称。角色的名称必须是有效的 对象标识符。

配置过程会创建具有指定名称的新角色。

User

代理将用于向 Snowflake 进行身份验证的新用户的标识符。

指定一个在所选数据库中具有唯一性的名称。角色的名称必须是有效的 对象标识符。

配置过程将创建一个具有指定名称和类型 SERVICE 的新用户。

备注

默认情况下，这些字段设置为配置连接器时创建的对象的名称。Snowflake 建议对这些字段使用新对象。但是，如果需要（例如，如果您要重新安装连接器），您可以指定现有对象的名称。

选择 Configure。

第 3 步：验证代理连接

检查代理与 Snowflake 的连接，如下所示：

  1. 选择 Generate file 以生成代理的初始配置文件。

    小心

    每次点击 Generate file 将生成一个新文件，其中包含代理用户的一组新的临时访问密钥。用户将自动更改为使用这些新密钥进行身份验证。如果您已经使用另一组密钥运行代理，它将与 Snowflake 断开连接并停止工作。

  2. 使用生成的 snowflake.json 文件，继续配置代理，如 设置 Snowflake Connector for MySQL 代理容器 中所述。然后返回 Snowsight。

  3. 选择 Refresh 检查与代理的连接。应用程序将确认代理已成功连接，并显示一个确认对话框。

  4. 选择 Define data to sync 继续。

后续步骤

完成以上过程后，请按照 设置 Snowflake Connector for MySQL 代理容器 中的步骤操作。

语言: 中文