引言：
在持续集成和持续部署（CI/CD）中，Jenkins作为一个强大的自动化工具，可以集成AWS SDK和Python脚本，实现ECS服务的自动重启并通过DingDing机器人发送通知。本文将介绍如何搭建这个自动化流程，并将其整合到Jenkins中。
一、前期准备：
1. 配置AWS凭证：
确保Jenkins中配置了AWS凭证，以便能够访问ECS和Secrets Manager服务。
2. 创建Din服务器托管网gDing机器人：
在DingDing中创建一个机器人，获取机器人的Token，用于发送通知。
二、编写Python脚本：
创建一个名为 ecs_restart_notification.py 的Python脚本，该脚本使用AWS SDK和DingDing机器人Token执行ECS服务的重启和通知。
#!/usr/bin/python3
import boto3
import os
import requests
import json
def get_secret(secret_name, region_name):
"""
从AWS Secrets Manager获取指定的secret。
"""
session = boto3.session.Session()
client = session.client(service_name='secretsmanager', region_name=region_name)
get_secret_value_response = client.get_secret_value(SecretId=secret_name)
return json.loads(get_secret_value_response['SecretString'])
def send_dingding_message(service_name, token):
"""
向DingDing发送一条消息，通知服务重启成功。
"""
headers = {'Content-Type': 'application/json'}
data = {
"msgtype": "markdown",
"markdown": {
"title": f"Restart {service_name} Success",
"text": f"Restart {service_name} Successn"
}
}
response = requests.post(f"https://oapi.dingtalk.com/robot/send?access_token={token}", headers=headers, data=json.dumps(data))
print(response.text)
def restart_services(cluster_name, service_names, task_definition, token):
"""
重启指定的ECS服务，并向DingDing发送通知。
"""
client = boto3.client('ecs')
for service_name in service_names:
client.update_service(
cluster=cluster_name,
service=service_name,
taskDefinition=task_definition,
forceNewDeployment=True
)
send_dingding_message(service_name, token)
def get_task_definition(cluster_name, service_name):
"""
获取指定服务的任务定义。
"""
client = boto3.client('ecs')
response = client.describe_services(
cluster=cluster_name,
services=[service_name]
)
return response['services'][0]['taskDefinition']
def get_task_name(task_definition):
"""
从任务定义的ARN中获取任务名称。
"""
return task_definition.split('/')[-1].split(':')[0]
# 从环境变量获取集群名称和服务名称列表
cluster_name = 'govee-test'
service_names = os.environ['SERVICE_NAMES'].split(',')
service_name = service_names[0] # 获取第一个服务名称以获取任务定义
task_definition = get_task_definition(cluster_name, service_name)
task_name = get_task_name(task_definition)
# 从Secrets Manager获取DingDing token
secrets = get_secret('base', 'us-east-1')
token = secrets['BUILD1_TOKEN']
restart_services(cluster_name, service_names, task_name, token)注解：
-
get_secret函数： 通过AWS Secrets Manager获取指定的Secret，并将其解析为JSON格式。 -
send_dingding_message函数： 向DingDing机器人发送Markdown格式的消息，用于通知服务重启成功。 -
restart_services函数： 使用AWS SDK的update_service方法重启指定的ECS服务，并调用发送通知的函数。 -
get_task_definition函数： 获取指定ECS服务的任务定义。 -
get_task_name函数： 从任务定义的ARN中提取任务名称。 - 环境变量： 通过Jenkins Pipeline或其他方式设置的环境变量，包括ECS集群名称和服务名称列表。
- 获取任务定义和任务名称： 通过调用相关函数获取ECS服务的任务定义和任务名称。
-
获取DingDing Token： 通过调用
get_secret函数获取DingDing机器人的Token。 -
重启服务并发送通知： 调用
restart_services函数实现ECS服务的重启，并通过DingDing机器人发送通知。
三、在Jenkins中创建Pipeline：
在Jenkins中创建一个Pipeline，将上述Python脚本整合到Jenkins的CI/CD流程中。以下是一个简单的Pipeline示例：
pipeline {
agent any
environment {
SERVICE_NAMES = 'your-service-names' // 替换为实际的服务名称
}
stages {
stage('Restart ECS Service') {
steps {
script {
// 安装所需的Python库
sh 'pip install boto3 requests'
// 执行Python脚本
sh './ecs_restart_notification.py'
}
}
}
}
}
确保将上述Pipeline中的 your-service-names 替换为实际的服务名称。
注解：
-
environment部分：定义了Jenkins Pipeline中的环境变量，包括ECS服务的名称。 -
stage('Restart ECS Service')部分：定义了Jenkins Pipeline中的一个阶段，用于执行ECS服务的重启。
四、运行Jenkins Pipeline：
运行Jenkins Pipeline，观察Jenkins的控制台输出，确保Python脚本成功执行，ECS服务重启并通过DingDing机器人发送了通知。
五、总结：
通过整合Jenkins、Python脚本、AWS SDK和DingDing机器人，我们建立了一个自动化流程，实现了ECS服务的自动重启和通知。这种自动化流程有助于提高运维效率，及时发现并解决潜在的问题，保障服务的稳定性。
服务器托管，北京服务器托管，服务器租用 http://www.fwqtg.net
机房租用，北京机房租用，IDC机房托管， http://www.f服务器托管网wqtg.net
相关推荐: # yyds干货盘点 # 有一个数据对应表，遍历df数据只要df存在对应的数据就替换掉，但是这个一直报错
大家好，我是皮皮。 一、前言 前几天在Python最强王者交流群【哎呦喂 是豆子～】问了一个Pandas数据处理的问题，一起来服务器托管网看看吧。问题描述： 大佬们 请问下这个问题 有一个数据对应表，然后遍历df数据只要df存在对应的数据就替换掉 但是这个一直…
