海外区域部署服务遇到的问题

⚠️问题1：在海外部署应用时遇到，海外区域的镜像仓库没有SDK，无法通过内部发布平台推送
⚠️问题2：海外区域镜像仓库没有触发器功能

获取本地最新版本进行推送

内部发布系统构建镜像后，没有变量声明，在推送镜像步骤中无法获取刚打包的镜像版本进行推送。

镜像打包的规则是分支+时间戳，编写脚本通过版本号进行时间排序，拿到最新镜像，进行推送

app="nmk-base"
docker images |grep $app
# 获取镜像的最新版本号
version=`docker images --format "{{.Repository}}:{{.Tag}}" | grep $app | awk -F ':release-' '{print $2}' | sort -nr | head -n 1 | awk '{print "release-" $0}'`
# 登陆镜像仓库
docker login -u nmk-p 29bsd2131 test.nmkapp.com
# 打tag
docker tag $app:$version test.nmkapp.com/prod-app/$app:$version
# 配置代理进行推送到海外镜像仓库
HTTP_PROXY="http://10.8.0.1:8118" HTTPS_PROXY="http://10.8.0.1:8118" docker push test.nmkapp.com/prod-app/$app:$version
sleep 3
# 删除本地镜像
docker rmi $app:$version
docker rmi test.nmkapp.com/prod-app/$app:$version

通过curl请求服务更新镜像

让kimi帮我生成go的脚本，修改好的脚本main.go如下

package main

import (
	"encoding/json"
	"fmt"
	"io/ioutil"
	"log"
	"net/http"
	"os/exec"
	"strings"
	"time"
)

// RequestData 定义请求的 JSON 数据结构
type RequestData struct {
	Image      string `json:"image"`
	Deployment string `json:"deployment"`
}

func main() {
	// 启动 HTTP 服务，监听 8080 端口
	http.HandleFunc("/update-image", handleUpdateImage)
	fmt.Println("服务已启动，监听 8080 端口...")
	log.Fatal(http.ListenAndServe(":8080", nil))
}

// handleUpdateImage 处理 HTTP POST 请求
func handleUpdateImage(w http.ResponseWriter, r *http.Request) {
	// 检查请求方法是否为 POST
	if r.Method != http.MethodPost {
		http.Error(w, "仅支持 POST 请求", http.StatusMethodNotAllowed)
		return
	}

	// 读取请求体
	body, err := ioutil.ReadAll(r.Body)
	if err != nil {
		http.Error(w, "读取请求体失败", http.StatusBadRequest)
		return
	}
	defer r.Body.Close()

	// 解析 JSON 数据
	var data RequestData
	if err := json.Unmarshal(body, &data); err != nil {
		http.Error(w, "解析 JSON 失败", http.StatusBadRequest)
		return
	}

	// 验证请求数据
	if data.Image == "" || data.Deployment == "" {
		http.Error(w, "请求参数不完整", http.StatusBadRequest)
		return
	}

	// 执行 kubectl set image 命令
	cmd := exec.Command("kubectl", "set", "image", "deployment/"+data.Deployment, data.Deployment+"="+data.Image)
	output, err := cmd.CombinedOutput()
	fmt.Println("kubectl", "set", "image", "deployment/"+data.Deployment, data.Deployment+"="+data.Image)
	if err != nil {
		// 如果命令执行失败，返回错误信息
		http.Error(w, fmt.Sprintf("执行 kubectl 命令失败: %s", string(output)), http.StatusInternalServerError)
		return
	}

	// 等待服务启动
	fmt.Printf("Deployment %s 正在启动，等待 1 分钟...\n", data.Deployment)
	time.Sleep(60 * time.Second)

	// 获取 Pod 名称
	podName, err := getPodName(data.Deployment)
	if err != nil {
		http.Error(w, fmt.Sprintf("获取 Pod 名称失败: %s", err.Error()), http.StatusInternalServerError)
		return
	}

	// 打印获取到的 Pod 名称
	fmt.Printf("获取到的 Pod 名称: %s\n", podName)

	// 获取 Pod 日志
	logOutput, err := getPodLogs(podName)
	if err != nil {
		http.Error(w, fmt.Sprintf("获取 Pod 日志失败: %s", err.Error()), http.StatusInternalServerError)
		return
	}

	// 将日志添加到输出
	output = append(output, []byte("\nPod Logs:\n")...)
	output = append(output, logOutput...)

	// 返回成功响应
	w.WriteHeader(http.StatusOK)
	fmt.Fprintf(w, "镜像已更新为 %s，Deployment 名称: %s\n输出: %s", data.Image, data.Deployment, string(output))
}

// getPodName 获取 Pod 名称
func getPodName(deployment string) (string, error) {
	// 使用 grep 和 awk 获取 Pod 名称
	cmd := exec.Command("bash", "-c", fmt.Sprintf("kubectl get pods | grep %s | awk '{print $1}'", deployment))
	output, err := cmd.CombinedOutput()
	fmt.Println("bash", "-c", fmt.Sprintf("kubectl get pods | grep %s | awk '{print $1}'", deployment))
	if err != nil {
		return "", fmt.Errorf("获取 Pod 名称失败: %s", string(output))
	}
	// 去除多余的空格和换行符
	return strings.TrimSpace(string(output)), nil
}

// getPodLogs 获取 Pod 日志
func getPodLogs(podName string) ([]byte, error) {
	cmd := exec.Command("kubectl", "logs", podName, "--tail=200")
	output, err := cmd.CombinedOutput()
	fmt.Println("kubectl", "logs", podName, "--tail=200")
	if err != nil {
		return nil, fmt.Errorf("获取 Pod 日志失败: %s", string(output))
	}
	return output, nil
}

更新历史:

1. 通过标签获取pod名称，发现多云服务标签不一致，改为grep获取，也可配置服务标签一致解决
2. 打印执行的命令和服务启动日志

下载相关依赖

go init update-image
go mod tidy

启动服务

go run main.go
服务已启动，监听 8080 端口...

本地测试请求服务

➜  ~ curl -X POST -H "Content-Type: application/json" -d '{"image":"test.nmkapp.com/prod-app/nginx:1.27","deployment":"nginx-deployment"}' http://localhost:8080/update-image
镜像已更新为 test.nmkapp.com/prod-app/nginx:1.27，Deployment 名称: nginx-deployment
输出: deployment.apps/nginx-deployment image updated

# 查看服务已经更新镜像
➜  ~ kubectl get deployments.apps -o yaml |grep image:
        - image: test.nmkapp.com/prod-app/nginx:1.27

打包出linux脚本

GOOS=linux GOARCH=amd64 go build -o update-image

服务器端配置

# 安装Kubectl
curl -LO "https://dl.k8s.io/release/$(curl -L -s https://dl.k8s.io/release/stable.txt)/bin/linux/amd64/kubectl"
chmod +x kubectl
mv -f kubectl /usr/local/bin
mkdir -p $HOME/.kube
# 配置kubeconfig
mv -f kubeconfig $HOME/.kube/config
kubectl config use-context internal

把打包出的update-image上传到服务器,启动服务

nohup ./update-image &

配置公网elb转发到服务器内，并设置白名单

本地请求服务

curl -X POST -H Content-Type: application/json -d {"image":"test.nmkapp.com/prod-app/nmk-base:release-20250331154728","deployment":"nmk-base"} http://181.71.101.211:8080/update-image
% Total    % Received % Xferd  Average Speed   Time    Time     Time  Current
Dload  Upload   Total   Spent    Left  Speed
0     0    0     0    0     0      0      0 --:--:-- --:--:-- --:--:--     0 100   297  100   181  100   116    314    201 --:--:-- --:--:-- --:--:--   314
镜像已更新为 test.nmkapp.com/prod-app/nmk-base:release-20250331154728，Deployment 名称: nmk-base
输出: deployment.apps/nmk-base image updated

查看是否更新完成