[Python] How can i connect to presto pyhive?

Discussão em 'Python' iniciado por Stack, Fevereiro 10, 2025.

  1. Stack

    Stack Membro Participativo

    I want to connect presto using pyhive in zeppelin

    now, I follows about https://github.com/dropbox/PyHive

    I use the connect function and correct parameters.

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


    but it does not work.

    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)


    how can I fix it?

    Continue reading...

Compartilhe esta Página