我正在尝试使用FASTAPI从雪花数据库中读取数据。我能够创建一个连接,它能够从雪花中提取数据。
我现在面临的问题是,我只拿到一张唱片(而不是十张唱片)。我怀疑我在返回数据时没有使用正确的关键字。感谢你的帮助。
这是我的密码:-
from fastapi import FastAPI
import snowflake.connector as sf
import configparser
username='username_value'
password='password_value'
account= 'account_value'
warehouse= 'test_wh'
database= 'test_db'
ctx=sf.connect(user=username,password=password,account=account,warehouse=warehouse,database=database)
app = FastAPI()
@app.get('/test API')
async def fetchdata():
cursor = ctx.cursor()
cursor.execute("USE WAREHOUSE test_WH ")
cursor.execute("USE DATABASE test_db")
cursor.execute("USE SCHEMA test_schema")
sql = cursor.execute ("SELECT DISTINCT ID,NAME,AGE,CITY FROM TEST_TABLE WHERE AGE > 60")
for data in sql:
return data发布于 2022-01-24 11:06:06
在内部for-循环中使用return。这将返回遇到的第一行。
如果希望将所有行作为列表返回,则可能可以这样做(我不熟悉雪花连接器):
return list(data)而不是for-loop或sql.fetchall()。
https://stackoverflow.com/questions/70832633
复制相似问题