Как использовать pyhive sqlalchemy для подключения к кластерам Databricks? - PullRequest
Новая
       42

Как использовать pyhive sqlalchemy для подключения к кластерам Databricks?

0 голосов
/ 23 февраля 2019

Я использую следующий код для подключения к кластерам Databricks.Но получил thrift.transport.TTransport.TTransportException: TSocket read 0 bytes .Я думаю, что есть некоторая ошибка my_url в create_engine. 

from sqlalchemy.engine import create_engine

engine = create_engine(my_url)

res = engine.execute('SELECT * FROM 
alex_db.sams_us_clubs_sams_member_index LIMIT 5')

for row in res:
    print(res)

Поскольку это кластер компании, я не могу показать детали my_url.У кого-нибудь есть опыт использования pyhive sqlalchemy для подключения к кластеру баз данных?

...