Snowflake Python Connector连接耗时2-3秒是否正常？有无提速参数？

嘿，你提到的Snowflake Python Connector连接耗时2-3秒的情况，其实是比较典型的预期行为，不过也确实有不少配置和方法能帮你加快连接速度，我来详细拆解下：

一、2-3秒的连接耗时是否属于预期？ #

答案是肯定的。Snowflake的连接建立过程涉及多个必要步骤：

• DNS解析Snowflake账户地址
• 完成用户名密码的身份验证流程
• 初始化会话并分配对应的计算仓库资源
• 加载基础的元数据信息

尤其是第一次建立连接时，这些步骤都要逐一完成，2-3秒的时长在大多数场景下都是正常范围。但如果后续重复连接还持续保持这个耗时，就可以通过下面的方法来优化了。

二、加快连接速度的配置与方法 #

这里整理了几个实用的优化方向：

• 使用连接池复用连接
  每次新建连接都会重复走一遍初始化流程，使用连接池可以复用已建立的连接，大幅降低后续连接的耗时。示例代码如下：

  from snowflake.connector import pooling
  import time
  
  # 初始化连接池
  pool = pooling.SnowflakeConnectionPool(
      user=user,
      password=password,
      account=account,
      warehouse=warehouse,
      min_connections=1,
      max_connections=5
  )
  
  t1 = time.time()
  # 从连接池获取连接
  conn = pool.get_connection()
  t2 = time.time()
  print(f"连接耗时：{t2-t1:.2f}秒")
  

• 提前指定数据库和Schema
  连接时如果不指定database和schema，Snowflake会默认加载账户的默认数据库和Schema元数据，提前在连接参数中指定这两个值，可以省去这部分加载时间：

  conn = snowflake.connector.connect(
      user=user,
      password=password,
      account=account,
      warehouse=warehouse,
      database=DATABASE,
      schema=SCHEMA
  )
  

• 开启会话保持参数
  在连接时添加client_session_keep_alive=True，可以让连接在空闲时保持活跃，避免频繁重建连接，适合需要多次复用连接的场景：

  conn = snowflake.connector.connect(
      user=user,
      password=password,
      account=account,
      warehouse=warehouse,
      client_session_keep_alive=True
  )
  

• 升级Connector到最新版本
  Snowflake会持续优化Connector的性能，修复连接相关的bug，定期升级到最新版本能获得更好的连接表现，执行命令：

  pip install --upgrade snowflake-connector-python
  

• 优化网络环境
  如果你的网络到Snowflake部署区域的延迟较高，也会拉长连接时间。可以尽量选择就近的Snowflake区域部署，同时检查是否有防火墙、代理等设备限制了连接速度。

附：你提供的示例代码与运行结果 #

示例代码 #

import snowflake.connector
import time
t1=time.time()
print("Start time :"+str(t1))
try:
    conn = snowflake.connector.connect(
        user=user,
        password=password,
        account=account,
        warehouse=warehouse,
        # database=DATABASE,
        # schema=SCHEMA
    )
    cur = conn.cursor()
except Exception as e:
    logging.error("Connection Error while initialing connection to snowflake")
    logging.error(str(e))
t2=time.time()
print("End time: "+str(t2))
t3=t2-t1
print("Difference(secs) : "+str(t3))
print("DB Connection : END")

运行结果 #

Start time :1575009530.075109
End time: 1575009533.320529
Difference(secs) : 3.245419979095459
DB Connection : END

内容的提问来源于stack exchange，提问作者SunilS