pandas- fetch_pandas_all 连接器杀死内核

Question

我在使用 Snowflake 的 pandas 连接器时遇到问题。

此代码的最后一行导致 python 内核立即死亡。关于如何诊断这种情况有什么建议吗？

import pyarrow
import snowflake.connector
import pandas as pd

ctx = snowflake.connector.connect(
    user=********,
    password=********,
    account=********,
    warehouse='compute_wh',
    database='SNOWFLAKE_SAMPLE_DATA',
    schema='WEATHER'
)
query = 'select * from weather_14_total'
cs = ctx.cursor()
cs.execute()
cs.fetch_pandas_all()

提前致谢。

Answer 1

我觉得你有点混淆了。

如果要用pandas，here是正确的link跟随。这是 Snowflake 文档。

你也可以不使用pandas，只要你愿意就可以了：

cs = ctx.cursor()

尝试：

 cs.execute("SELECT col1, col2 FROM test_table ORDER BY col1")
 for (col1, col2) in cs:
     print('{0}, {1}'.format(col1, col2))

最后：

 cs.close()

或：

cs = ctx.cursor()

查询=“Select * 来自table”

尝试：

 cs.execute(query)
 .....
 .....

最后：

 cs.close()

此外，文档 link 是 here。

pandas- fetch_pandas_all 连接器杀死内核

pandas- fetch_pandas_all Connector Kills Kernel

python

snowflake-sql