2

有没有办法使用带有雪花的“pd.read_sql_query”？

我正在尝试在 pandas 数据框中读取我的雪花查询，但是我收到一个“属性错误”，说明“SnowflakeCursor”对象没有属性“形状”（下面的代码）......

雪花 python 连接器有效。fetch_pandas_all() 有效。一旦我尝试将查询作为熊猫数据框读取，它就会中断。

import pyodbc  
import sys  
import os  
import getpass  
import snowflake.connector  
import pyarrow  


conn = snowflake.connector.connect(user='***', password='***', account='***', warehouse='***', database='***', schema='***')
cur = conn.cursor()
tenure = cur.execute(
    """SELECT DISTINCT CT_ID, CT_STRT_DATE, MONTHS_BETWEEN(TO_DATE('2022-01-01'), TO_DATE(CT_STRT_DATE)) AS TENURE 
    FROM ***.***.****
    WHERE CT_SVC_FREQ != 'OT' AND CT_CNCL_DATE IS NULL AND CT_ID LIKE 'S|%'
    ORDER BY CT_STRT_DATE DESC""")


print(tenure.fetch_pandas_all()) --- This code works fine

一旦我尝试使用熊猫进行操作，我就会遇到错误......

print(tenure.shape) -- breaks w/ "Attribute Error"
4

1 回答 1

2

这种方式怎么样：

df_new = tenure.fetch_pandas_all()
total_rows = df_new.shape[0]

创建一个新的 DF 应该允许你运行shape

于 2022-01-31T15:28:42.127 回答