hive2から火災にデータをロードする方法

Question

すべて、

hive2トランプサーバーからデータを読み込もうとしています。私はhereと似た分析をしたいと思います。ここに私の現在のプロセスがあります。

import blaze as bz 
import sqlalchemy 
import impala 

conn = connect(host='myhost.url.com', port=10000, database='mydb', user='hive', auth_mechanism='PLAIN') 
engine = sqlalchemy.create_engine('hive://', creator=conn) 
data = bz.data(engine) 

私が接続し、エンジンを生成することができていますが、それは誤り

TypeError: 'HiveServer2Connection' object is not callable 

で失敗bz.data私が実行したときにすべてのヘルプは高く評価されます。

回答

from pyhive import import hive 
import sqlalchemy 
from impala.dbapi import import connect 


def conn():            
    return connect(host='myhost.com', port=10000, database='database',  user='username', auth_mechanism='PLAIN') 

engine = sqlalchemy.create_engine('hive://', creator=conn) 


#Workaround 
import blaze as bz 


data = bz.data(engine) 

Answer 1

from pyhive import import hive 
import sqlalchemy 
from impala.dbapi import import connect 


def conn():            
    return connect(host='myhost.com', port=10000, database='database', user='username', auth_mechanism='PLAIN') 

engine = sqlalchemy.create_engine('hive://', creator=conn) 


#Workaround 
import blaze as bz 


data = bz.data(engine)