出现此问题的原因是,在AWS Lambda函数中,无法直接连接Snowflake;您需要使用Snowflake .NET驱动程序,而该驱动程序不支持AWSSDK .NET SDK的端点策略。
因此,解决此问题的最佳方法是使用AWS Lambda层,并将Snowflake .NET驱动程序添加到其中。
以下是如何在AWS Lambda中设置Snowflake .NET驱动程序的步骤:
创建一个新的AWS Lambda层。
添加以下文件:
a. Snowflake.Data.dll b. 新的参数文件 “AWSPowerShell.json” 或 “Function.json” - AWSPowerShell.json: { "dependencies": { "AWSSDK.Core": "3.3.0", "AWSSDK.SQS": "3.3.0", "AWSSDK.S3": "3.3.0" }, "framework": { "name": "Microsoft.NETCore.App", "version": "2.1.0" }, "runtimes": { "dotnetcore2.1": {} } } - Function.json: { "Framework": { "Name": "Microsoft.NETCore.App", "Version": "2.1.0" }, "Library": { "Type": "project", "AssemblyName": "AWSLambda", "TargetFramework": "netcoreapp2.1" }, "Runtime": { "Isolated": false, "RuntimeIdentifier": "win10-x64" }, "Dependencies": { "Snowflake.Data": "1.2.19" } }
将新的AWS Lambda层添加到您的AWS Lambda函数中,并确保在代码中使用正确的文件路径。
使用Snowflake .NET驱动程序的正确代码示例:
using System.Data.SqlClient; using Snowflake.Data.Core; using System.Data;
SnowflakeDbConnection conn = new SnowflakeDbConnection(); conn.ConnectionString = @"account=xxxxx;user=xxxxx;password=xxxxx;db=xxxxx;schema=xxxxx;role=xxxxx";
using (SqlCommand cmd = new SqlCommand("SELECT * FROM xxxx", conn)) { cmd.CommandType = CommandType.Text; conn.Open(); //连接成功,无超时或错误 SqlDataReader rdr = cmd.ExecuteReader(); try { while (rdr.Read()) { Console.WriteLine(rdr[0]); } } finally { rdr.Close(); } }
使用以上步骤和正确代码示例,您应该可以成功在AWS Lambda函数中连接到Snowflake数据库。