问题标签 [snowflake-connector]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票
2 回答
46 浏览

visual-studio-code - VSCode 上的 PUT 命令雪花

我在 vscode 上使用用于 SQLTools 的雪花驱动程序,并且我连接到我的雪花帐户,但是当我想将一些扩展名为 .csv 的文件从我的本地机器放到雪花中的舞台时,我遇到了一些问题。实际上,当我使用该命令时put file:///mypath/file.csv @nameofmystage;,它可以在终端上运行,但不能在带有扩展 Snowflake 驱动程序的窗口 vscode 中运行。但是,其他命令如copy into适用于驱动程序 vscode ...

错误消息是 Unsupported feature 'unsupported_requested_format:snowflake'

在此先感谢您的帮助

0 投票
0 回答
42 浏览

python - 如何在python中保持雪花连接活跃

我已将我的数据库存储在雪花服务器中并使用https://pypi.org/project/snowflake-connector-python/我正在访问数据库并从烧瓶服务器执行数据库查询,如下所示:

我已将雪花连接会话定义为全局ctx变量,可从任何烧瓶 api 函数访问。

启动烧瓶服务器后,一切正常,但如果连续几个小时没有进行 api 调用,则会抛出错误 'snowflake.connector.errors.ProgrammingError: 390114 (08001): Authentication token has expired。用户必须再次验证icate。

如您所见,我在雪花连接 api 中保留了“client_session_keep_alive=True”参数以保持会话处于活动状态,但仍然以某种方式失败。我探索了这个问题,但没有得到任何确凿的信息。所以我想知道如何使数据库连接会话保持活动状态,还是必须为每个查询创建新的连接会话?

任何建议都会非常有帮助。

0 投票
1 回答
33 浏览

python - 使用游标执行数据库查询的问题

我正在尝试进行类似于以下的查询:

我的查询看起来像这样:

我收到此错误:

我查看了此错误代码并尝试删除可能存在的任何特殊字符,但没有运气。

提前致谢

0 投票
1 回答
30 浏览

python - 使用 Python 将本地文件加载到 Snowflake 中的 AWS 阶段

我计划使用 Amazon s3 内部阶段将数据从本地系统摄取到雪花表。如何使用 python 将数据加载到 s3 阶段?以前为了将数据加载到雪花中,我使用雪花的内部暂存并使用以下命令执行操作。

将数据从本地系统加载到亚马逊 s3,然后使用 python 将这些文件从暂存表复制到雪花表的方法应该是什么。

请分享您的意见。

0 投票
1 回答
38 浏览

azure-cosmosdb - 我需要将数据从 azure cosmos db(json 格式)加载到雪花中。我有什么选择?

我尝试使用 nodeJS 函数触发 cosmos 更改提要并直接插入雪花表列,但这似乎很慢。请提出任何其他选择

0 投票
0 回答
47 浏览

java - 雪花的 Spark 连接器在“复制到”sql 命令中抛出“java.io.EOFException:SSL 对等体错误关闭”

使用 spark-snowflake_2.12:2.9.3-spark_3.1 和 snowflake-jdbc:3.13.14 尝试使用 spark 在雪花中“覆盖”表,继续获取:

然后我在我的 jUnit 测试中运行了相同的代码,它可以工作——可能是因为我嘲笑了所有的密码:

我在雪花历史中注意到 spark 连接甚至执行一些命令,比如

测试运行和正确执行之间的唯一区别是复制到命令中。我正在使用以下设置运行 spark:

扩展工作日志:

我正在尝试使用雪花选项:

但这无济于事。需要在 spark 3.1.1 上运行,因此没有太多降级驱动程序的空间。任何关于如何使其运行的想法将不胜感激

0 投票
0 回答
18 浏览

python - Python Snowflake Connector - 不能使用 set 语句?

在使用 python 雪花连接器时尝试使用 set 语句创建会话变量时出现错误。

这甚至可能吗?还是我们必须创建自己的字符串插值?

0 投票
1 回答
27 浏览

snowflake-cloud-data-platform - Snowflake - 基于键的两个表的协调

我有两个表(主表和辅助表),我们需要在这两个表之间进行行和列级别的协调,并汇总这些表之间的差异。

表 A:

可乐 col_B col_C

表 B:

可乐 col_B col_C
美国广播公司

在上表中 col_A 是主键列。我想比较表 A 和表 B 并产生如下结果。

匹配行:2

不匹配的行数:1

列不匹配:col_C(示例键:四)

表 A 中存在但 B 中不存在的行数:0

表 B 中存在但 A 中不存在的行:1(示例键:九)

通常,表 A 和表 B 大约有。十亿行。在 Snowflake 中执行此操作的有效方法是什么。

0 投票
0 回答
14 浏览

java - 无法使用胶水中的火花启动雪花

我正在尝试使用以下页面中指定的确切配置为雪花设置 aws glue etl

aws 胶水 etl 为雪花设置

我使用了可以访问所有必需服务的 i am 角色。

但我得到以下错误

我假设它在调用下面的代码时发生

这个错误的解决方法是什么?

0 投票
1 回答
37 浏览

snowflake-cloud-data-platform - 如何在 Snowflake 中执行多个异步查询而不相互干扰?

我想执行多个异步查询。但是,它会不断干扰彼此的 SQL 命令。

例如,查询 A 需要使用架构 A,查询 B 需要使用架构 B,但是触发了使用架构 B 的命令,然后在其后运行查询 A,导致查询 A 失败。

示例查询 A:

  1. 使用模式测试;
  2. 从 TABLE_A 中选择 *;

示例查询 B:

  1. 使用模式测试_2;
  2. 从表_B中选择*;

在我的情况下,当在同一个连接中异步触发它们时发生的事情是它像这样运行:

  1. 使用模式测试;
  2. 从表_B中选择*;

这会导致查询失败,因为 TABLE_B 在模式 TEST 中不存在。

雪花是否有任何方式触发多个异步查询而不会相互干扰?除了连接之外,再次运行查询和断开连接。