I am new to using Python with Zeppelin and I am trying to import a dataframe into Zeppelin through SQL. However, I have only found materials about PySpark in Zeppelin so far.
%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)
When I try the following code:
%python
from sqlalchemy import create_engine
engine = create_engine('sqlite://')
df_credit.to_sql('mydatasql',con=engine)
and then attempt to access it with SQL:
%sql select Age, count(1) from mydatasql where Age < 30 group by Age order by Age
I receive an error message stating "Table or view not found."
I suspect that %sql cannot read variables created with %python, but I am uncertain about this assumption.