Как выполнить предварительные запросы в Python, используя Pyhive? - PullRequest
Новая
       60

Как выполнить предварительные запросы в Python, используя Pyhive?

0 голосов
/ 27 марта 2019

Я пытаюсь выполнить предварительный запрос в python с использованием библиотеки pyhive, но появляется ошибка max retries.Я запускаю его в ноутбуке Jupyter локально (ноутбук).Я думаю, что его невозможно подключить к узлу Presto.Я использую кластер Azure hdinsight и установил приложение Presto на головном узле (с использованием распределения starburst).Я использовал имя пользователя и пароль кластера, а также я попробовал имя пользователя и пароль ssh головного узла, но ничего не работает.Ниже мой код: 

from pyhive import presto
conn= presto.connect(
    host='clustername-ssh.azurehdinsight.net',
    port=8085,
    username='sshuser'
    password='sshpassword',
    protocol='https'
    ).cursor()
conn.execute('SELECT * FROM hive.default.parquettest limit 1')

Ошибка, которую я получаю:

ConnectionError: HTTPConnectionPool (host = 'sm-hdinsight01-ssh.azurehdinsight.net', port =8085): максимальное количество повторных попыток превышено с помощью оператора url: / v1 / (вызвано NewConnectionError (': не удалось установить новое соединение: [Errno 110] истекло время ожидания соединения',))

но когда яя запускаю его в терминале головного узла, он работает: 

from pyhive import presto
conn= presto.connect(
    host='localhost',
    port=8085).cursor()
conn.execute('SELECT * FROM hive.default.parquettest limit 1')

Я думаю, что здесь не хватает какой-то важной вещи.пожалуйста, помогите.

...