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

备注

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

安装 Snowflake Connector for MySQL 之前，请在 MySQL 环境中执行以下操作：

配置关联的数据源

  • 确保您有一台 MySQL 版本 8 或更高版本的服务器，其中包含您要与 Snowflake 同步的数据。

  • 为您的 MySQL 服务器设置以下选项：

    log_bin = on
binlog_format = row
binlog_row_metadata = full
binlog_row_image = full
binlog_row_value_options =
    Copy

    备注

    对二进制日志有效期 (binlog_expire_logs_seconds) 保持警惕。到期之后，二进制日志文件可能会被自动移除。如果代理长时间暂停（例如由于维护工作），并且在此期间删除了过期的二进制日志文件，则代理无法从这些文件复制数据。将二进制日志有效期至少设置为几个小时，以确保连接器稳定工作。

    有关自动清除二进制日志文件的更多信息，请参阅 MySQL 参考手册 (https://dev.mysql.com/doc/refman/8.0/en/replication-options-binary-log.html)。

创建所需的用户

为 Snowflake Connector for MySQL 创建具有以下权限的用户：

  • REPLICATION SLAVE 和 REPLICATION CLIENT，以便能够从 binlog 中读取。

    例如：

    GRANT REPLICATION SLAVE ON *.* TO '<username>'@'%'
GRANT REPLICATION CLIENT ON *.* TO '<username>'@'%'
    Copy

  • 对复制的所有表的 SELECT 权限。

    例如：

    GRANT SELECT ON <schema>.* TO '<username>'@'%'
GRANT SELECT ON <schema>.<table> TO '<username>'@'%'
    Copy

    其中 <schema>.<table> 是要复制的表的唯一标识符。

后续步骤

完成以上过程后，请按照 使用 Snowsight 设置 Snowflake Connector for MySQL 中的步骤操作。

语言: 中文