我正在尝试将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('没有响应的远程端关闭连接',)))
我错过了协议:
...
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)