# Heapster

## 概述

该项目将被废弃（RETIRED）

Heapster是Kubernetes旗下的一个项目，Heapster是一个收集者，并不是采集

* 1.Heapster可以收集Node节点上的cAdvisor数据：CPU、内存、网络和磁盘
* 2.将每个Node上的cAdvisor的数据进行汇总
* 3.按照kubernetes的资源类型来集合资源，比如Pod、Namespace
* 4.默认的metric数据聚合时间间隔是1分钟。还可以把数据导入到第三方工具ElasticSearch、InfluxDB、Kafka、Graphite
* 5.展示：Grafana或Google Cloud Monitoring

## 使用场景

* Heapster+InfluxDB+Grafana共同组成了一个流行的监控解决方案
* Kubernetes原生dashboard的监控图表信息来自heapster
* 在HPA（Horizontal Pod Autoscaling）中也用到了Heapster，HPA将Heapster作为Resource Metrics API，向其获取metric，作为水平扩缩容的监控依据

## 监控指标

### 流程：

1.Heapster首先从apiserver获取集群中所有Node的信息。 2.通过这些Node上的kubelet获取有用数据，而kubelet本身的数据则是从cAdvisor得到。 3.所有获取到的数据都被推到Heapster配置的后端存储中，并还支持数据的可视化。

### 部署

docker部署：

![](http://www.xuyasong.com/wp-content/uploads/2019/01/04df980f537101f123140ac0084a1196.png)

k8s中部署：

heapster.yml

![](http://www.xuyasong.com/wp-content/uploads/2019/01/7f71e6306f278e8d5f2a95bb140d90bb.png)

influxdb.yml

![](http://www.xuyasong.com/wp-content/uploads/2019/01/8ecf4d51cc9c64775eaedcef1f911518.png)

注意修改镜像地址，k8s.gcr.io无法访问的话，修改为内网镜像地址，如替换为registry.cn-hangzhou.aliyuncs.com/google\_containers

### Heapster的参数

* source: 指定数据获取源，如kube-apiserver

inClusterConfig:

* kubeletPort: 指定kubelet的使用端口，默认10255
* kubeletHttps: 是否使用https去连接kubelets(默认：false)
* apiVersion: 指定K8S的apiversion
* insecure: 是否使用安全证书(默认：false)
* auth: 安全认证
* useServiceAccount: 是否使用K8S的安全令牌
* sink: 指定后端数据存储，这里指定influxdb数据库

### Metrics列表

![](http://www.xuyasong.com/wp-content/uploads/2019/01/626916950630a7461320b47aead94821.png)

## 深入解析

架构图：

![](http://www.xuyasong.com/wp-content/uploads/2019/01/c6cc7daab52b226d81a95a51df66100a.png)

代码结构（<https://github.com/kubernetes-retired/heapster）>

![](http://www.xuyasong.com/wp-content/uploads/2019/01/794b158e7f3ad6f69d064a87c3676da7.png)

heapster主函数（heapster/metrics/heapster.go）

![](http://www.xuyasong.com/wp-content/uploads/2019/01/176eb5c5ce6d264f37e9975afba9c1c2.png)

主要流程：

* 创建数据源对象
* 创建后端存储对象list
* 创建处理metrics数据的processors
* 创建manager，并开启数据的获取及export的协程
* 开启Heapster server，并支持各类API

cAdvisor返回的原始数据包含了nodes和containers的相关数据，heapster需要创建各种processor，用于处理成不同类型的数据，比如pod, namespace, cluster，node的聚合，求和平均之类，processor有如下几种：

![](http://www.xuyasong.com/wp-content/uploads/2019/01/f2789d5a2fe67703e2caf7f577d6987f.png)

例如Pod的处理如下：

![](http://www.xuyasong.com/wp-content/uploads/2019/01/827a0cd9a2c0d2d7be05305936d48194.png)

详细解析参考: <https://segmentfault.com/a/1190000008863353>

## 现状

heapster已经被官方废弃（k8s 1.11版本中，HPA已经不再从hepaster获取数据）

* CPU内存、HPA指标： 改为[metrics-server](https://github.com/kubernetes-incubator/metrics-server)
* 基础监控：集成到prometheus中，kubelet将metric信息暴露成prometheus需要的格式，使用[Prometheus Operator](https://github.com/coreos/prometheus-operator)
* 事件监控：集成到<https://github.com/heptiolabs/eventrouter>

## 基于Heapster的HPA

参考：[基于Heapster的HPA](mweblib://15466995225914)


---

# Agent Instructions: Querying This Documentation

If you need additional information that is not directly available in this page, you can query the documentation dynamically by asking a question.

Perform an HTTP GET request on the current page URL with the `ask` query parameter:

```
GET https://yasongxu.gitbook.io/container-monitor/yi-.-kai-yuan-fang-an/di-1-zhang-cai-ji/heapster.md?ask=<question>
```

The question should be specific, self-contained, and written in natural language.
The response will contain a direct answer to the question and relevant excerpts and sources from the documentation.

Use this mechanism when the answer is not explicitly present in the current page, you need clarification or additional context, or you want to retrieve related documentation sections.