python - 齐柏林飞艇 : how to read a DataFrame with sql

Question

我必须将 python 与 Zeppelin 一起使用。我很新，我只找到有关 pyspark 到 Zeppelin 的 Material 。我想用python导入一个数据框，然后通过sql访问它:

%python    
import pandas as pd #To work with dataset
import numpy as np #Math library     
#Importing the data
df_credit = pd.read_csv("../data.csv",index_col=0)

如果我尝试:

%python
from sqlalchemy import create_engine
engine = create_engine('sqlite://')
df_credit.to_sql('mydatasql',con=engine)

然后访问它，即:

%sql select Age, count(1) from mydatasql where Age < 30 group by Age order by Age

我收到错误:“找不到表或 View ”

我认为问题是 %sql 无法读取用 %python 创建的变量，但我不确定这一点。

Answer 1

尝试 %python.sql 解释器。您必须安装pandasql包。检查这个link了解更多信息。