2

我有一个简单的impyla代码,我想pandas dataFrame从我的光标创建一个。我的代码正在运行,但我dataframe的始终是空的dataframe。如果我直接在 上运行查询impala,则结果不为空。这就是我的代码的样子:

from impala.dbapi import connect
from impala.util import as_pandas


conn = connect(host='impala_server', port=21051,
               user='user' , password='pass',
               use_ssl=True,
               auth_mechanism='PLAIN')
cursor = conn.cursor()
cursor.execute("SELECT * FROM TABLE")

results = cursor.fetchall()

df = as_pandas(cursor)

print(df.head())   

请帮助我,我做错了什么?

4

2 回答 2

1

只需删除:

results = cursor.fetchall()

从你的代码。它应该工作。

于 2018-11-19T12:21:35.407 回答
1
'results = cursor.fetchall()  ' delete this line and it will be ok.

    from impala.dbapi import connect
    from impala.util import as_pandas
    
    conn = connect(host='****.com', port=****, database='****')
    cursor = conn.cursor()
    cursor.execute('select * from table limit 10')
    df = as_pandas(cursor)
    df.head()

我运行上面的代码,它运行良好。

于 2020-07-21T08:40:05.830 回答