2017-09-19 4 views
0

내가presto pyhive에 어떻게 연결할 수 있습니까?

지금 비행선에 pyhive 사용 프레스토를 연결합니다, 나는 약 https://github.com/dropbox/PyHive

내가 사용하는 연결 기능과 올바른 매개 변수를 다음과 같습니다.

%python 
from pyhive import presto 
cursor = presto.connect(host='localhost', 
       port=10000, 
       username='id:password').cursor() 
cursor.execute('SELECT * FROM table LIMIT 10') 

하지만이 작동하지 않습니다 ..

내가 그것을 어떻게

Traceback (most recent call last): 
    File "/tmp/zeppelin_python-557261260901431465.py", line 278, in <module> 
    raise Exception(traceback.format_exc()) 
Exception: Traceback (most recent call last): 
    File "/tmp/zeppelin_python-557261260901431465.py", line 266, in <module> 
    exec(code) 
    File "<stdin>", line 5, in <module> 
    File "/usr/lib/python2.7/dist-packages/pyhive/presto.py", line 206, in execute 
    self._process_response(response) 
    File "/usr/lib/python2.7/dist-packages/pyhive/presto.py", line 263, in _process_response 
    response_json = response.json() 
    File "/usr/lib/python2.7/dist-packages/requests/models.py", line 650, in json 
    return json.loads(self.content.decode(encoding), **kwargs) 
    File "/usr/lib64/python2.7/encodings/utf_32_le.py", line 11, in decode 
    return codecs.utf_32_le_decode(input, errors, True) 
UnicodeDecodeError: 'utf32' codec can't decode bytes in position 4-7: code point not in range(0x110000) 
을 를 해결할 수 ?

답변

0

사용자 이름과 비밀번호를 분리하려고 했습니까? presto.connect(host='xxx', port=xxx, username='xxx', password='xxx') 나를 위해 일했습니다.

+0

나는 anwser를 찾을 수 있습니다! 잘못된 포트입니다 .. username = 'id : password'가 맞습니다! ~ –

관련 문제