【Kubernetes的DevOps自动化，Jenkins上的Pipeline实现自动化构建、测试、部署、发布以及Bookinginfo实例的部署灰度发布故障注入流量】

pipeline {
    agent {
        kubernetes {
            label 'my-pipeline'
            defaultContainer 'jnlp'
            yaml '''
apiVersion: v1
kind: Pod
metadata:
  labels:
    jenkins: slave
spec:
  securityContext:
    runAsUser: 1000
    fsGroup: 1000
  containers:
  - name: jnlp
    image: jenkins/jnlp-slave:latest
    imagePullPolicy: Always
'''
        }
    }
    stages {
        stage('Checkout') {
            steps {
                git branch: 'master', url: 'https://github.com/my-org/my-repo.git'
            }
        }
        stage('Build') {
            steps {
                container('docker') {
                    sh 'docker build -t my-image .'
                    sh 'docker push my-registry/my-image:${env.BUILD_NUMBER}'
                }
            }
        }
        stage('Deploy') {
            steps {
                container('kubectl') {
                    sh 'kubectl apply -f deployment.yml'
                }
            }
        }
        stage('Test') {
            steps {
                container('kubectl') {
                    sh 'kubectl rollout status deployment/my-app'
                }
                container('test') {
                    sh './run-tests.sh'
                }
            }
        }
        stage('Promote') {
            steps {
                container('kubectl') {
                    sh 'kubectl set image deployment/my-app my-app=my-registry/my-image:${env.BUILD_NUMBER}'
                }
            }
        }
    }
}

import requests
import time
import random
# 模拟网络异常
def network_error():
    # 10%概率出现网络异常
    if random.randint(1, 10) == 1:
        raise requests.exceptions.Timeout
# 模拟数据库错误
def database_error():
    # 5%概率出现数据库错误
    if random.randint(1, 20) == 1:
        raise requests.exceptions.ConnectionError
# 模拟服务器宕机
def server_down():
    # 1%概率出现服务器宕机
    if random.randint(1, 100) == 1:
        raise requests.exceptions.HTTPError(500)
# 发送请求
def send_request(url):
    try:
        # 模拟异常情况
        network_error()
        database_error()
        server_down()
        r = requests.get(url)
        print('[INFO] Request success. Response:', r.text)
    except requests.exceptions.Timeout:
        print('[ERROR] Network timeout.')
    except requests.exceptions.ConnectionError:
        print('[ERROR] Database connection error.')
    except requests.exceptions.HTTPError:
        print('[ERROR] Server is down.')
    except Exception as ex:
        print('[ERROR] Unknown error:', ex)
if __name__ == '__main__':
    url = 'http://bookinginfo.com/api'
    # 模拟发送100次请求
    for i in range(100):
        send_request(url)
        time.sleep(1)  # 间隔1秒