代码之家 › 专栏 › 技术社区 › Chris Snow

如何使用Ambari检索名称节点主机名?

analytics-engine ibm-cloud

Chris Snow · 技术社区 · 7 年前

这个 python-ambariclient 库具有用于检索host\u组件的api:

ambari.services(service_name).components(component_name).host_components

如何提取IBM Analytics Engine群集的name\u节点?

我想我需要打电话:

GET https://xxxx.bi.services.us-south.bluemix.net:9443/api/v1/clusters/AnalyticsEngine/services/HDFS/components/NAMENODE?fields=host_components

检索以下信息:

{
  "href" : "https://xxxx.bi.services.us-south.bluemix.net:9443/api/v1/clusters/AnalyticsEngine/services/HDFS/components/NAMENODE?fields=host_components",
  "ServiceComponentInfo" : {
    "cluster_name" : "AnalyticsEngine",
    "component_name" : "NAMENODE",
    "service_name" : "HDFS"
  },
  "host_components" : [
    {
      "href" : "https://xxxx.bi.services.us-south.bluemix.net:9443/api/v1/clusters/AnalyticsEngine/hosts/xxxx.bi.services.us-south.bluemix.net/host_components/NAMENODE",
      "HostRoles" : {
        "cluster_name" : "AnalyticsEngine",
        "component_name" : "NAMENODE",
        "host_name" : "xxxx.bi.services.us-south.bluemix.net"
      }
    }
  ]
}

2 回复 | 直到 7 年前

Chris Snow 7 年前

首先,安装 python-ambariclient 图书馆:

! 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
PROTOCOL = url.scheme

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

CLUSTER_NAME = ambari.clusters.next().cluster_name # gets first cluster - there will only be one

namenode_hc = ambari.clusters(CLUSTER_NAME).services('HDFS').components('NAMENODE').host_components

namenode_host_name = [hc.host_name for hc in namenode_hc if hc.host_name][0]

print(namenode_host_name)

Chris Snow 7 年前

我创建了一个库来提取这些信息。安装时使用:

pip install --quiet --upgrade git+https://github.com/snowch/ibm-analytics-engine-python@master

然后运行:

from ibm_analytics_engine import AmbariOperations
ambari_ops = AmbariOperations(vcap_filename='./vcap.json')
ambari_ops.get_namenode_hostname()

推荐文章

Chris Snow · 如何在分析引擎上读取和写入Apache Spark中的配置单元表

7 年前

Carlos Ferreira · 如何列出我的机器人在Watson对话服务中使用的@Cities实体值

7 年前

Ronald Bower · IBM Cloud Node红色管理调色板不安装项目

7 年前

data_henrik · 如何将Python OpenID Connect模块与IBM云应用程序ID一起使用?

7 年前

James Silvester · 使用Ng serve将angular 2+应用程序部署到cloud Foundry

7 年前

Herman · 上传到IBM云后的“ImportError:无模块”

7 年前

zcleghern · 无法从Xamarin应用程序连接到IBM IOT平台

7 年前

Cinn smfoote · 如何在OpenWhisk上使用redis包运行Go函数?

7 年前

Matri · “500错误:无法建立背面连接”-Bluemix Selenium测试

7 年前

jpsstack · 我可以在Raspberry PI上安装Secure Gateway客户端吗

7 年前