PerfectHadoop: YARN 节点管理器

本项目提供一个YARN节点管理器 REST API的Swift类封装：

• YARNNodeManager(): 用于访问在一个YARN节点管理器上所有应用程序和容器信息的类实例

连接到YARN节点管理器

采用Perfect连接到Hadoop YARN 节点管理器最简单的方法，就是初始化一个YARNNodeManager()对象并提供足够参数：

// 以下连接可能只提供基本操作权限
let nm = YARNNodeManager(host: "yarnNodeManager.somehadoopdomain.com", port: 8042)

或者包含一个有效的用户名连接到Hadoop YARN 节点管理器：

// 如有必要请自行修改用户名
let nm = YARNNodeManager(host: "yarnNodeManager.somehadoopdomain.com", port: 8042, user: "your user name")

用户身份认证

如果您的服务器正在使用Kerberos，请参考以下程序代码：

// 将认证模式设置为krb5
let yarn = YARNNodeManager(host: "yarnNodeManager.somehadoopdomain.com", port: 8042, user: "username", auth: .krb5)

YARNNodeManager 节点管理器对象初始化参数

获取服务器基本信息

调用 checkOverall() 方法可以获得服务器基本信息，返回结果为一个 YARNNodeManager.Info 数据结构

guard let inf = try yarn.checkOverall() else {
    // 出错了
}
print(inf.id)
print(inf.nodeHostName)
print(inf.healthReport)

YARNNodeManager.NodeInfo 数据结构

应用程序

调用 checkApps() 方法可返回一个 APP 应用程序对象组成的数组。每个应用程序对象都是代表这个应用程序的一组资源集合。

let apps = try yarn.checkApps()
apps.forEach { a in
  print(a.id)
  print(a.containerids)
  print(a.state)
}//next

应用程序数据结构

查看特定应用程序

如果具有有效的应用程序代号，您可以调用checkApp()来查询节点信息：

guard let app = try yarn.checkApp("application_1326121700862_0005") else {
    // 出错了
}
// print out all container ids of the application
print(app.containerids)

checkApp() 会返回一个 APP 对象，如前文所述

检查容器

调用 checkContainers() 可以查看当前节点上的所有容器：

// 获取所有容器
let containers = try ynode.checkContainers()

// 查看容器数量
print(containers.count)

containers.forEach { container in
    print(container.id)
    print(container.state)
    print(container.nodeId)
    print(container.diagnostics)
    /// ...
}

checkContainers() 返回值时一个容器数组 Container如下所述：

容器对象

查看特定容器

如果具有有效的容器编号，可以使用 checkContainer() 检查特定容器：

guard let container = try ynode.checkContainer(id: container.id) else {
    // 出错了
}
print(container.id)
print(container.state)
print(container.nodeId)
print(container.diagnostics)

该方法会返回一个Container对象，如前文所述。