Hello:
Below is the connection code & i am getting following error, please me what wrong i am doing.
Any help is greatly appreciated.
Below is the connection code & i am getting following error, please me what wrong i am doing.
Any help is greatly appreciated.
import pandas as pd import sqlalchemy as sa import mysql.connector as mc cnx = mc.connect(host='11.11.11.11',port=3306,database='kafka',user='root',password='xxxxxxx') cur=cnx.cursor() query = ("select * from kafka_test where flag = 0 order by id limit 20") df = pd.read_sql_query(query,con=cnx) print(df)ERROR:-
Error:Traceback (most recent call last):
File "<ipython-input-102-a83485540962>", line 13, in <module>
df = pd.read_sql_query(query,con=cnx)
File "E:\ProgramData\Anaconda3\lib\site-packages\pandas\io\sql.py", line 311, in read_sql_query
pandas_sql = pandasSQL_builder(con)
File "E:\ProgramData\Anaconda3\lib\site-packages\pandas\io\sql.py", line 507, in pandasSQL_builder
if _is_sqlalchemy_connectable(con):
File "E:\ProgramData\Anaconda3\lib\site-packages\pandas\io\sql.py", line 68, in _is_sqlalchemy_connectable
return isinstance(con, sqlalchemy.engine.Connectable)
AttributeError: module 'sqlalchemy' has no attribute 'engine'