hive2에서 블레이즈로 데이터를로드하는 방법

Question

모두,

하이브 2 쓰레드 서버에서 블레이즈에 데이터를로드하려고 시도하고 있습니다. 나는 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) 

나는 연결을 확인하고 엔진을 생성 할 수 있어요,하지만 난 bz.data 실행할 때 그것은 어떤 도움에 감사드립니다 오류

TypeError: 'HiveServer2Connection' object is not callable 

실패합니다.

대답

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)