Python 探针接入

如果你的服务涉及到 Python，可以参考该文档。本文以 Flask 应用为例讲解如何将 Flask 的endpoints 接入到分布式链路追踪。

前置条件

依赖包与环境安装

• 环境 Python 3.7.9

• Python agent包被发布在Pypi, 你可以通过pip安装：

#安装最新的版本并使用gRPC协议传输数据到OPA
pip install "apache-skywalking"

#安装最新的版本并使用http协议传输数据到OPA
pip install "apache-skywalking[http]"

#安装最新的版本并使用kafka协议传输数据到OPA
pip install "apache-skywalking[kafka]"

#安装特定的版本 x.y.z
pip install apache-skywalking==0.1.0

本文档示例中需要的库：

Flask==1.1.2
redis==3.5.3

目前支持的Python库

目前只有以上列出的库能够被自动接入探针并接入到分布式链路追踪。

Demo项目的探针接入

• demo结构

Flask-Agent
├── app.py
├── service.py
└── userRepo.py

其中 userRepo.py 示例代码如下：

import json
import time
import redis
class redisConfig():
    def __init__(self,_host,_port,_db):
        self.r = redis.StrictRedis(host=_host, port=_port, db=_db)
        self.r.set('message', 'the message from redis')
        self.r.set('minquan','{"name":"minquan","passward":"123456","message":"redis cache data"}')
    def getConncet(self):
        return self.r

redisClient = redisConfig("localhost", 6379, 0)
class UserRepo:
    def __init__(self):
        pass
    def getUser(self,username):
        user = redisClient.r.get(username)
        if user is None:
            user = "no message";
        else:
            user = json.loads(user)
        time.sleep(0.5)
        return user

其中 service.py 示例代码如下：

from UserRepo import UserRepo
class UserServce:
    def __init__(self):
        self.userRepo = UserRepo()
    def getUser(self,userName):
        user = self.userRepo.getUser(username=userName)
        return user

其中 app.py 示例代码如下：

from flask import Flask, url_for, request
import time
import json
from service import UserServce
app = Flask(__name__)
@app.route('/')
def hello_world():
    time.sleep(0.5)
    return "Hello_world"

@app.route("/user")
def getUser():
    username = request.args.get("username") or None
    if username ==None:
        return "no message"
    else:
        userService = UserServce()
        user = userService.getUser(username)
        userString = json.dumps(user)
        return userString
"""
导入依赖库 Python agent SDK 需要SkyWalking 8.0+ and Python 3.5+
参数说明：
@ collector :SkyWalking 后端收集器地址
@ service :服务名字, 以 @结尾代表该服务所在 DMP 租户。
"""
from skywalking import agent, config
config.init(collector='127.0.0.1:11800', service='python-flask@devTenant')
agent.start()
if __name__ == '__main__':
    app.run()

python flask 探针的接入需要随着 flask 应用一起启动，如上面代码的展示，此外还可以通过环境变量的方式进行配置信息设置。

支持的环境变量