性能监控之Python实战SkyWalking链路追踪

news/2024/9/25 5:36:02/

文章目录

  • 一、介绍
  • 二、SkyWalking支持的语言
  • 三、SkyWalking安装
    • 3.1 前提准备
    • 3.2 先安装ElasticSearch7.X
    • 3.3 Skywalking-OAP 安装
    • 3.4 Skywalking-UI 界面安装
    • 3.5 访问页面检查SkyWalking是否可以访问
  • 四、Python 项目接入SkyWalking
    • 4.1 演示项目代码
    • 4.2 验证 sw-python
    • 4.3 配置依赖
    • 4.4 启动fastapi 项目
    • 3.5 发送请求
    • 4.6 SkyWalking 查看请求信息

一、介绍

SkyWalking 是一款APM工具,Apache 基金会,开源,社区支持,可用于代码调用链路分析以及性能测试中接口调用链路的分析。使用 SkyWalking 可以帮助您快速定位系统的性能瓶颈和异常情况,提高系统的可靠性和稳定性。

二、SkyWalking支持的语言

Java,Python,Go, .Net,C#,NodeJS,Rust,PHP,JavaScript 等等。

地址介绍支持的编程语言:https://skywalking.apache.org/downloads/
在这里插入图片描述

三、SkyWalking安装

版本:SkyWalking-8.5

3.1 前提准备

这里演示的环境为 CentOS7.9 版本,机器4C8G的环境。

机器上安装 Docker, 演示机器的 Docker version 24.0.7 版本

准备1台4C4G的机器,当然机器资源越大越好,Skywalking也更顺畅的运行。

安装 Python3 环境,创建 MySQL 5.7的数据库,推荐使用 Docker 方式安装,方便快捷。

官网对安装机器的条件:https://skywalking.apache.org/docs/skywalking-showcase/next/readme/

使用端口说明:

  • ES 9200, 9300
  • SkyWalking-oap 12800,11800, 应用程序上报使用的端口 gRPC 使用
    • 11800 端口 与 SkyWalking的 gRPC 通信
    • 12800 端口 与 SkyWalking的 HTTP 通信
  • SkyWalking-UI 8085

3.2 先安装ElasticSearch7.X

ElasticSearch 简称ES。

安装ES7版本,docker容器化部署-单节点。

mkdir -p /mydata/es/config  # 创建 es配置目录
mkdir -p /mydata/es/data    # 创建数据存储目录
chmod 777 -R /mydata/es     # 给文件赋权,这里演示使用,真实环境不建议使用777权限
echo "http.host: 0.0.0.0" >> /mydata/es/config/elasticsearch.yml # 创建es yml配置文件
echo "7dgroup.test_interval: 2000" >> /mydata/es/config/elasticsearch.yml # 控制刷新频率 2000
echo "7dgroup.query.bool.max_clause_count: 1024" >> /mydata/es/config/elasticsearch.ymldocker run -d --name es7 \-p 9200:9200 -p 9300:9300 \-e "discovery.type=single-node" \-e ES_JAVA_OPTS="-Xms512m -Xmx512m" \-v /mydata/es/config/elasticsearch.yml:/usr/share/elasticsearch/config/elasticsearch.yml \-v /mydata/es/data:/usr/share/elasticsearch/data \-v /mydata/es/plugins:/usr/share/elasticsearch/plugins elasticsearch:7.6.2

参数说明

  • -e “discovery.type=single-node” 设置为单节点
  • -e ES_JAVA_OPTS=“-Xms512m -Xmx512m” 设置ES的初始内存和最大内存,否则过大启动不了ES

注意:这时候会提示权限不够需要开启权限:

  • chmod 777 -R /mydata/es
  • 登录http://ip:9200/_cat/nodes?v=true&pretty
  • 记得开放网络安全组 9200 9300,因为我这里是演示机器,端口全开。

在这里插入图片描述
访问 http://ip:9200/_cat/nodes?v=true&pretty ES验证是否安装成功。
在这里插入图片描述
验证是否已经安装成功:
在这里插入图片描述

出现图片以上的内容,说明ES安装成功。

3.3 Skywalking-OAP 安装

docker run --name oap \--restart always -d \-e TZ=Asia/Shanghai \-p 12800:12800 \-p 11800:11800 \--link es7 \-e SW_STORAGE=elasticsearch7 \-e SW_STORAGE_ES_CLUSTER_NODES=es7:9200 apache/skywalking-oap-server:8.5.0-es7

参数:

  • –link :alias ,添加到另一个容器的链接,可以添加别名或者不加
  • –link后面的参数和elasticsearch容器名一致;
  • SW_STORAGE=elasticsearch7 是固定的,使用es7;
  • SW_STORAGE_ES_CLUSTER_NODES:es7 也可改为 es 服务器部署的Ip地址,比如ip:9200

3.4 Skywalking-UI 界面安装

docker run -d --name skywalking-ui \--restart always \-e TZ=Asia/Shanghai \-p 9000:8080 \--link oap \-e SW_OAP_ADDRESS=zt_oap:12800 \apache/skywalking-ui:8.5.0

查看 SkyWalking-UI,SkyWalking-oap, ES 在 docker 容器里面都起来了

3.5 访问页面检查SkyWalking是否可以访问

Google 浏览器可以正常访问,Egde浏览器,却访问不了,需要注意避坑,能看到 ip:9000 端口访问到SkyWalking可以正常打开,接下来需要在项目里面插入 SkyWalking 插桩就能上报数据到 SkyWalking 监控中。
在这里插入图片描述

四、Python 项目接入SkyWalking

4.1 演示项目代码

这里演示使用,使用 Python fastapi 【注册,登录,查询用户列表】功能来演示。

python"># -*- coding: UTF-8 -*-from fastapi import FastAPI, HTTPException
from pydantic import BaseModel
from sqlalchemy import create_engine, Column, Integer, String
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.orm import sessionmakerfrom SkyWalkingimport agent, configconfig.init(agent_collector_backend_services="10.249.29.16:11800",agent_name="fastapi",
)
#config.SW_AGENT_LOGGING_LEVEL = "DEBUG"
config.plugin_fastapi_collect_http_params = True
#agent.start()app = FastAPI()# 创建数据库连接
# SQLALCHEMY_DATABASE_URL = "sqlite:///users.db"
SQLALCHEMY_DATABASE_URL = "mysql+pymysql://root:abc123456@10.249.29.16:3306/users" # 这里的数据库用于测试engine = create_engine(SQLALCHEMY_DATABASE_URL)
SessionLocal = sessionmaker(autocommit=False, autoflush=False, bind=engine)
Base = declarative_base()# 定义数据模型
class User(Base):__tablename__ = "users"id = Column(Integer, primary_key=True, index=True)username = Column(String(100), unique=True, index=True)password = Column(String(50))# 创建数据库表
Base.metadata.create_all(bind=engine)# 注册(Create User)
class CreateUserRequest(BaseModel):username: strpassword: str@app.post("/register")
def register(user: CreateUserRequest):db = SessionLocal()db_user = db.query(User).filter(User.username == user.username).first()if db_user:raise HTTPException(status_code=409, detail="Username already registered")new_user = User(username=user.username, password=user.password)db.add(new_user)db.commit()db.refresh(new_user)return {"message": "User registered successfully"}# 登录(User Login)
class UserLoginRequest(BaseModel):username: strpassword: str@app.post("/login")
def login(user: UserLoginRequest):db = SessionLocal()db_user = db.query(User).filter(User.username == user.username).first()if not db_user or db_user.password != user.password:raise HTTPException(status_code=401, detail="Invalid username or password")return {"message": "Login successful"}# 查询全部用户(Get All Users)
@app.get("/users")
def get_all_users():db = SessionLocal()users = db.query(User).all()return users# if __name__ == "__main__":
#     import uvicorn
#
#     uvicorn.run("main:app", host="127.0.0.1", port=8085, reload=True)

先上传代码至服务器上,安装依赖包。

Dockerfile:

pip3 install fastapi pydantic sqlalchemy pymysql apache-skywalking

python_215">4.2 验证 sw-python

验证环境是否可用,先验证 SkyWalking 的 Python 包是否安装成功。

4.3 配置依赖

官网介绍:https://skywalking.apache.org/docs/skywalking-python/next/en/setup/cli/

配置环境变量

Dockerfile:

export SW_AGENT_COLLECTOR_BACKEND_SERVICES=10.249.29.16:11800

4.4 启动fastapi 项目

Dockerfile:

sw-python run -p uvicorn main:app --host '0.0.0.0' --port 8083 --reload

在这里插入图片描述

访问ip:8083/docs。
在这里插入图片描述

3.5 发送请求

发送请求,注册,登录,查询用户列表,以下是命令行请求,也可以访问 ip:8083/docs swagger 接口去请求。

Dockerfile:

# 注册时需要注意 username 不能重复
curl -X 'POST' \'http://10.249.29.16:8083/register' \-H 'accept: application/json' \-H 'Content-Type: application/json' \-d '{"username": "test3","password": "123456"
}'# 登录
curl -X 'POST' \'http://10.249.29.16:8083/login' \-H 'accept: application/json' \-H 'Content-Type: application/json' \-d '{"username": "test3","password": "123456"
}'# 查询用户列表
curl -X 'GET' \'http://10.249.29.16:8083/users' \-H 'accept: application/json'

4.6 SkyWalking 查看请求信息

在这里插入图片描述
在这里插入图片描述

到这里已经全部演示完毕,看会不等于学会,实操才能战胜恐惧。


http://www.ppmy.cn/news/1530141.html

相关文章

关于wordPress中的用户登录注册等问题

前言 大家在做类似的功能的时候,有没有相关的疑问。那就是我都已经选择好了相应的主题和模版,但是为什么都没有用户注册和用户登录的页面存在呢? WordPress默认情况下不提供用户注册和登录功能的原因是它最初是作为一个博客平台开发的&…

AjAX(简介以及一些用法)

AJAX 1. 简介 什么是 Ajax Ajax 的全称是 Asynchronous JavaScript And XML (异步 JavaScript 和 XML )我们可以理解为:在网页中 利用 XMLHttpRequest 对象和服务器进行数据交互的方式就是 Ajax ,它可以帮助我们轻松实现网页…

Python画笔案例-059 绘制甩曲彩点动图

1、绘制甩曲彩点动图 通过 python 的turtle 库绘制 甩曲彩点动图,如下图: 2、实现代码 绘制甩曲彩点动图,以下为实现代码: """甩曲彩点动图.py """ import time import turtlecs = [red,orange,

优选算法之 分治-快排

目录 一、颜色分类 1. 题目链接:75. 颜色分类 2. 题目描述: 3. 解法(快排思想 - 三指针法使数组分三块) 🌴算法思路: 🌴算法流程: 🌴算法代码: 二、快…

多级目录SQL分层查询

需求&#xff1a;有多级目录&#xff0c;而目录的层级是不固定的&#xff0c;如下图所示&#xff1a; 数据结构&#xff1a; sql语句&#xff1a; <select id"getList" resultType"com.hikvision.idatafusion.dhidata.bean.vo.knowledgebase.KnowledgeBaseT…

ubuntu内网穿透后在公网使用ssh登录

需求&#xff1a; 我有一台内网可以通过ssh 22端口访问的设备操作系统是ubuntu server我还有1台拥有公网IP的服务器&#xff0c;IP地址是 6.66.666.6666我想随时从其他网段通过ssh访问我的ubuntu server设备 实现&#xff1a; 工具准备&#xff1a;frp 网址&#xff1a;https…

时间序列LSTM实现

这个代码参考了时间序列预测模型实战案例(三)(LSTM)(Python)(深度学习)时间序列预测(包括运行代码以及代码讲解)_lstm预测模型-CSDN博客 结合我之前所学的lstm-seq2seq里所学习到的知识对其进行预测 import time import numpy as np import pandas as pd import torch import…

【CentOS7】nginx部署前端 gunicorn部署flask后端并使用nginx反向代理

一、前端 将编译好的前端文件放入服务器中/usr/local/project/test_case/dist编辑/usr/local/webserver/nginx/conf/nginx.conf&#xff0c;此为nginx的配置文件 user nginx; worker_processes 2;error_log /logs/nginx/error.log crit;#pid logs/nginx.pid;events …