ASP.NET MVC 4.7.2集成Snowflake .NET连接器遇会话过期求解决方案

针对你使用Snowflake.Data 2.0.15在ASP.NET MVC 4.7.2应用中遇到的4小时会话过期问题，以下是几个可行的替代方案：

• 手动实现会话保活定时任务
  在应用中启动一个后台定时任务，每隔3.5小时左右发起一次轻量查询（如SELECT 1），维持Snowflake会话活跃。可以用System.Threading.Timer实现，示例代码如下：

  private Timer _keepAliveTimer;
  
  // 在应用启动时调用（比如Global.asax的Application_Start方法）
  public void InitializeSessionKeepAlive()
  {
      // 设置间隔为3.5小时，单位：毫秒
      int intervalMs = (int)TimeSpan.FromHours(3.5).TotalMilliseconds;
      _keepAliveTimer = new Timer(PerformSessionKeepAlive, null, 0, intervalMs);
  }
  
  private void PerformSessionKeepAlive(object state)
  {
      var connectionString = "你的Snowflake连接字符串";
      using (var conn = new SnowflakeDbConnection { ConnectionString = connectionString })
      {
          try
          {
              conn.Open();
              using (var cmd = conn.CreateCommand())
              {
                  cmd.CommandText = "SELECT 1";
                  cmd.ExecuteScalar();
              }
          }
          catch (Exception ex)
          {
              // 记录保活失败日志，可根据需求添加重试逻辑
              // Logger.Error("会话保活失败", ex);
          }
          finally
          {
              if (conn.State == System.Data.ConnectionState.Open)
                  conn.Close();
          }
      }
  }
  

  注意要在应用生命周期内管理好定时器，避免内存泄漏；同时处理异常，防止单次保活失败导致会话过期。

• 捕获异常自动重连
  针对VendorCode: 390111的会话过期异常，在代码中捕获并自动重新建立连接后重试操作。示例代码：

  public TResult ExecuteSnowflakeQuery<TResult>(Func<SnowflakeDbConnection, TResult> queryFunc)
  {
      var connectionString = "你的Snowflake连接字符串";
      using (var conn = new SnowflakeDbConnection { ConnectionString = connectionString })
      {
          try
          {
              conn.Open();
              return queryFunc(conn);
          }
          catch (SnowflakeDbException ex) when (ex.VendorCode == 390111)
          {
              // 会话过期，重新连接后重试
              conn.Close();
              conn.Open();
              return queryFunc(conn);
          }
      }
  }
  
  // 使用示例
  var data = ExecuteSnowflakeQuery(conn => 
  {
      using (var cmd = conn.CreateCommand())
      {
          cmd.CommandText = "SELECT COLUMN_NAME FROM YOUR_TABLE LIMIT 10";
          using (var reader = cmd.ExecuteReader())
          {
              // 读取并转换结果
              var resultList = new List<string>();
              while (reader.Read())
              {
                  resultList.Add(reader.GetString(0));
              }
              return resultList;
          }
      }
  });
  

  这种方案无需额外后台任务，仅在会话过期时触发重连，适合调用频率较低的场景。

• 调整Snowflake服务端会话超时参数
  联系Snowflake管理员，尝试调整账户或用户级别的SESSION_IDLE_TIMEOUT_MINS参数，延长会话超时时间。注意该参数的最大值受Snowflake账户策略约束，需确认是否允许调整。

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