python - 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

我认为你有点混淆了事情。

1. 如果你想使用 pandas，这里是正确的链接。这是雪花文档。

2. 如果你愿意，你也可以不使用 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()

   query = "从表中选择 *"

   尝试：

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

   最后：

    cs.close()
   

此外，文档链接在这里。