Elastic APM安装和使用

在上文分布式跟踪系统选型和实践中，简单介绍过APM系统，这里记录一下Elastic APM的安装和使用过程。

---

搭建elk

按照es官网说明分别部署(见参考资料)。

部署elasticsearch

通过命令行下载elasticsearch：
curl -L -O https://artifacts.elastic.co/downloads/elasticsearch/elasticsearch-7.0.1-linux-x86_64.tar.gz

解压到指定目录，如/usr/local目录。
进入elasticsearch的bin目录，运行elasticsearch脚本：
./elasticsearch
即可启动elasticsearch。向本地9200端口发送一个http请求，得到返回如下：

部署logstash

下载logstash：https://www.elastic.co/cn/downloads/logstash（7.9版本）

解压到指定目录，如/usr/local。

进入logstash目录，运行logstash脚本：
./bin/logstash -f config/logstash-sample.conf

可以看到当前输出：

如果elasticsearch未运行，则会报错：无法连接es实例。

部署kibana

通过命令行下载kibana：
wget https://artifacts.elastic.co/downloads/kibana/kibana-7.0.1-linux-x86_64.tar.gz

解压到指定目录，进入bin目录执行脚本：
./kibana

访问127.0.0.1:5601,可以看到界面kibana界面：

Elk使用

上面在启动logstash的时候是通过样例配置文件来启动的，现在创建一个新的配置文件logstash.conf:

然后重新启动logstash，指定配置文件为新创建的文件：

./bin/logstash -f config/logstash.conf
1

该配置文件表示从文件读取数据，然后存储到elasticsearch中，索引名为test-log-[年月]。

在kibana的manager页面查看索引，会发现新增了一个名为test-log-2020.11的索引。

创建Index pattern，输入索引正则表达式，会自动匹配上索引文件：

创建完索引的正则表达式后，在discover页面就能可以选择索引了。在搜索框输入查询条件就能搜索数据了。

Elastic APM

启动apm server

下载（https://www.elastic.co/guide/en/apm/server/7.0/installing.html
）并解压apm server到指定目录，进入bin目录导入kibana apm仪表盘并启动apm server：

./apm-server setup
./apm-server -e
1
2

启动agent

不同语言的agent的使用方式是不同的。下面以python的agent为例进行说明。

支持的web框架和版本参考官网说明：https://www.elastic.co/guide/en/apm/agent/python/5.x/supported-technologies.html。

Python中的agent是以库的方式提供的，在代码中集成即可，如下所示：

from flask import Flask
from elasticapm.contrib.flask import ElasticAPM
from elasticapm.handlers.logging import LoggingHandler
app = Flask(__name__)
app.config['ELASTIC_APM'] = {
    'SERVER_URL': 'http://127.0.0.1:8200',
    'DEBUG': True
}
apm = ElasticAPM(app, service_name='python-test', logging=True)
port = 5000

@app.route('/')
def hello_world():
    try:
        1 / 0
    except ZeroDivisionError:
        apm.client.capture_exception()
    return 'Hello World! I am running on port ' + str(port)

if __name__ == '__main__':
    handler = LoggingHandler(client=apm.client)
    app.logger.addHandler(handler)
    app.run(host='0.0.0.0', port=port)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

访问http://127.0.0.1:5000/接口，输出：Hello World! I am running on port 5000。

官网上说支持6.0+版本的tornado，但使用agent之后服务无法启动，why??

APM界面

进入kibana的apm菜单，按照指引创建apm界面。完成后可以看到如下界面：

点击server进入：

进入discover菜单，选择apm-*索引，可以查看apm索引数据。

下一篇将继续介绍cat的安装使用。

参考资料

[1].https://www.elastic.co/guide/en/apm/get-started/7.9/install-and-run.html