ConnectionError连接到IBM Analytics Engine

问题描述 投票:0回答:1

我正在尝试将python-ambariclient与IBM Analytics Engine一起使用:

$ pip install --quiet python-ambariclient

然后

from future.standard_library import install_aliases
install_aliases()
from urllib.parse import urlparse

import json
vcap = json.load(open('vcap.json'))

USER         = vcap['cluster']['user']
PASSWORD     = vcap['cluster']['password']
AMBARI_URL   = vcap['cluster']['service_endpoints']['ambari_console']
CLUSTER_ID   = vcap['cluster']['cluster_id']

url = urlparse(AMBARI_URL)

HOST = url.hostname
PORT = url.port

from ambariclient.client import Ambari
ambari = Ambari(HOST, port=PORT, username=USER, password=PASSWORD)

for cluster in ambari.clusters:
    print('> ' + cluster.cluster_name)

但是,我遇到了连接问题:

ConnectionError:HTTPConnectionPool(host ='XXXXXX.bi.services.us-south.bluemix.net',port = 9443):使用url:/ api / v1 / clusters超出最大重试次数(由ProtocolError引起('连接已中止。', RemoteDisconnected('没有响应的远程端关闭连接',)))

ibm-cloud analytics-engine
1个回答
0
投票

我错过了协议:

...
url = urlparse(AMBARI_URL)

HOST = url.hostname
PORT = url.port
PROTOCOL = url.scheme  
...

ambari = Ambari(HOST, ... , protocol=PROTOCOL)

完整代码:

from future.standard_library import install_aliases
install_aliases()
from urllib.parse import urlparse

import json
vcap = json.load(open('vcap.json'))

USER         = vcap['cluster']['user']
PASSWORD     = vcap['cluster']['password']
AMBARI_URL   = vcap['cluster']['service_endpoints']['ambari_console']
CLUSTER_ID   = vcap['cluster']['cluster_id']

url = urlparse(AMBARI_URL)

HOST = url.hostname
PORT = url.port
PROTOCOL = url.scheme

from ambariclient.client import Ambari
ambari = Ambari(HOST, port=PORT, username=USER, password=PASSWORD, protocol=PROTOCOL)

for cluster in ambari.clusters:
    print('> ' + cluster.cluster_name)
© www.soinside.com 2019 - 2024. All rights reserved.