Locust를 이용한 과부하 테스트

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18

# git clone  
git clone https://github.com/HanHoRang31/blog-share.git
cd blog-chare/k8s-app/vote-app
tree

# 네임스페이스 생성 후 변경
kubectl create ns vote

# 서비스 배포 
kubectl apply -f .

# ExternaDNS 추가 (없으면 생략) 
## 각자 자신의 도메인 정보 입력
MyDOMAIN1=<각자 자신의 nginx 도메인 지정>
MyDOMAIN1=vote.hanhorang.link
MyDOMAIN2=result.hanhorang.link
kubectl annotate service vote "external-dns.alpha.kubernetes.io/hostname=$MyDOMAIN1."
kubectl annotate service result "external-dns.alpha.kubernetes.io/hostname=$MyDOMAIN2."

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45

# repo 설치
helm repo add deliveryhero  https://charts.deliveryhero.io/ 
helm repo update 
helm repo list 
---
NAME            URL                            
deliveryhero    https://charts.deliveryhero.io/ 

# 매개 변수 확인 
helm show values deliveryhero/locust > values.yaml
---
loadtest:
  # loadtest.name -- 이 부하 테스트에 사용될 리소스 및 설정의 이름
  name: example
  # loadtest.locust_locustfile -- locustfile의 이름
  locust_locustfile: main.py
  # loadtest.locust_locustfile_path -- locustfile의 경로 (끝에 슬래시 제외)
  locust_locustfile_path: "/mnt/locust"
  # loadtest.locust_locustfile_configmap -- locustfile을 포함하는 configmap의 이름 (기본값은 예제 locustfile 사용)
  locust_locustfile_configmap: "example-locustfile"
  # loadtest.locust_lib_configmap -- 라이브러리를 포함하는 configmap의 이름 (기본값은 예제 라이브러리 사용)
  locust_lib_configmap: "example-lib"
  # loadtest.locust_host -- 부하 테스트할 대상 호스트
  locust_host: https://www.google.com
  # loadtest.pip_packages -- 설치할 추가 파이썬 pip 패키지의 목록
  pip_packages: []
  # loadtest.environment -- 마스터와 워커 모두에게 적용될 환경 변수
  environment: {}
    # VAR: VALUE
.
.
worker:
  # worker.image -- 사용자 정의 도커 이미지를 포함한 태그
  image: ""
  # worker.logLevel -- 로그 레벨. INFO 또는 DEBUG 가능
  logLevel: INFO
  replicas: 1
  # worker.pdb.enabled -- worker 파드에 대한 PodDisruptionBudget를 생성할지 여부
  pdb:
    enabled: false
  hpa:
    enabled: false
    minReplicas: 1
    maxReplicas: 100
    targetCPUUtilizationPercentage: 40

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18

# Execute in root of repository, and maybe this file has existed.
cat <<EOF > locustfile.py && cat locustfile.py
from locust import HttpUser, task, between
import random

class UserBehavior(HttpUser):
    wait_time = between(1, 2.5)

    @task(1)
    def get_home_page(self):
        self.client.get("http://result.hanhorang.link/")

    @task(2)
    def post_vote(self):
        vote = ['a', 'b'] # a represents 'Cats', b represents 'Dogs'
        self.client.post("http://vote.hanhorang.link/",
                         data={'vote': random.choice(vote)})
EOF

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35

# 스크립트 배포 
kubectl create configmap eks-loadtest-locustfile --from-file ./locustfile.py

# locust 배포 
helm upgrade --install locust deliveryhero/locust \
 --set loadtest.name=eks-loadtest \
 --set loadtest.locust_locustfile_configmap=eks-loadtest-locustfile \
 --set loadtest.locust_locustfile=locustfile.py \
 --set worker.hpa.enabled=true \
 --set worker.hpa.minReplicas=5

# 서비스 ALB 배포 
cat <<EOF > locust-ingress.yaml && cat locust-ingress.yaml
apiVersion: networking.k8s.io/v1
kind: Ingress
metadata:
  annotations:
    alb.ingress.kubernetes.io/scheme: internet-facing
    alb.ingress.kubernetes.io/target-type: ip
    kubernetes.io/ingress.class: alb
  finalizers:
  - ingress.k8s.aws/resources
  labels:
    app: ingress
  name: ingress-locust-dashboard
  namespace: default
spec:
  defaultBackend:
    service:
      name: locust
      port:
        number: 8089
EOF

kubectl apply -f locust-ingress.yaml

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20

cat <<EOF > locustfile.py && cat locustfile.py
from locust import HttpUser, task, between, SequentialTaskSet
import random

class UserBehavior(SequentialTaskSet):

    @task
    def post_vote(self):
        vote = ['a', 'b'] # a represents 'Cats', b represents 'Dogs'
        self.client.post("http://vote.hanhorang.link/",
                         data={'vote': random.choice(vote)})

    @task
    def get_home_page(self):
        self.client.get("http://result.hanhorang.link/")

class MyUser(HttpUser):
    tasks = [UserBehavior]
    wait_time = between(1, 2.5)
EOF