首页 > 其他分享 >jenkins Job华为云EIP变更带宽

jenkins Job华为云EIP变更带宽

时间:2023-12-25 18:01:04浏览次数:34  
标签:EIP err nil eip fmt huaweicloud Job go jenkins

引言:

在数字化时代,云服务资源的弹性管理是企业降低运营成本、提高效率的关键手段。通过弹性公网IP(EIP)服务,企业可以实现按需计费,优化网络支出。然而,根据业务流量的不同阶段调整计费模式,则是提升成本效益的进阶策略。本人腾讯云快十年老用户乘机吐槽一下腾讯云(由于我在大有所为的某云上面已经简单实现了更改流程): 习惯了使用apiexplorer这样的工具生成代码进行修改,参考一下友商的: image.png 然后我的腾讯云弹性公网IP ?EIP 对吧? image.png 这是什么样的体验?完全搜索不到?关键词EIP **弹性公网 **完全搜索不到...... image.png image.png 最后我在这里找到了: 绑定弹性公网IP image.png 你可以归于私有网络?是不是应该好歹独立一下..... image.png 吐槽完毕,本文将详细介绍如何使用华为云Go SDK在流量高峰时自动调整EIP带宽设置,并在峰值过后恢复原计费模式。

业务背景:

考虑到一家在线互动应用提供商,主要架构是websockt 长链接,其流量在晚高峰时段飙升,观众涌入平台进行抢红包等互动活动。活动时常大概在一个小时。在流量高峰时,固定带宽的使用能保证用户的观看体验,且相对于按流量计费,成本更为可控。因此,我们面临一个机遇,通过智能化工具调整EIP的带宽计费模式,在需要时提供稳定的网络资源和更优的财务开支。

技术方案:

服务器场景搭建在华为云上,使用了cce kubernetes服务。绑定了应用型负载均衡(负载均衡有本身的EIP公网IP),为了实现这一目标,我们选择华为云的Elastic IP服务,它提供了一系列API,允许程序化管理EIP资源。通过Go语言编写的定时任务,我们可以精确控制带宽的调整时机和规模。在本方案中,使用华为云提供的SDK,我们将编写一个Go应用程序,当业务流量达到高峰时,自动将EIP的计费模式从按流量计费调整为按带宽计费,并固定带宽大小。一小时后,系统自动将设置恢复为按流量计费,以节省成本。

代码实现:

参照以下代码实例:UpdateBandwidth 更新带宽方法: image.png

package main

import (
	"fmt"
	"github.com/huaweicloud/huaweicloud-sdk-go-v3/core/auth/basic"
    eip "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/eip/v2"
	"github.com/huaweicloud/huaweicloud-sdk-go-v3/services/eip/v2/model"
    region "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/eip/v2/region"
)

func main() {
    // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great security risks. It is recommended that the AK and SK be stored in ciphertext in configuration files or environment variables and decrypted during use to ensure security.
    // In this example, AK and SK are stored in environment variables for authentication. Before running this example, set environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment
    ak := os.Getenv("CLOUD_SDK_AK")
    sk := os.Getenv("CLOUD_SDK_SK")

    auth := basic.NewCredentialsBuilder().
        WithAk(ak).
        WithSk(sk).
        Build()

    client := eip.NewEipClient(
        eip.EipClientBuilder().
            WithRegion(region.ValueOf("cn-east-3")).
            WithCredential(auth).
            Build())

    request := &model.UpdatePublicipRequest{}
	request.Body = &model.UpdatePublicipsRequestBody{
	}
	response, err := client.UpdatePublicip(request)
	if err == nil {
        fmt.Printf("%+v\n", response)
    } else {
        fmt.Println(err)
    }
}

最终实现代码如下:

package main

import (
	"fmt"
	"time"

	"github.com/huaweicloud/huaweicloud-sdk-go-v3/core/auth/basic"
	"github.com/huaweicloud/huaweicloud-sdk-go-v3/core/config"
	eip "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/eip/v2"
	"github.com/huaweicloud/huaweicloud-sdk-go-v3/services/eip/v2/model"
	region "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/eip/v2/region"
)

func main() {
	// Replace with your own AK/SK, Region, and Project ID.
	ak := "xxxxx"
	sk := "xxxxx"
	projectID := "xxxxx"

	// Authenticate using your Access Key and Secret Key.
	auth := basic.NewCredentialsBuilder().
		WithAk(ak).
		WithSk(sk).
		WithProjectId(projectID).
		Build()

	// Create EIP client configuration.
	eipClient := eip.NewEipClient(
		eip.EipClientBuilder().
			WithRegion(region.ValueOf("cn-east-3")).
			WithCredential(auth).
			WithHttpConfig(config.DefaultHttpConfig()).
			Build(),
	)

	// Replace the bandwidthId with your actual bandwidth ID.
	sizeBandwidth := int32(xxx)
	sizeTraefikBandwidth := int32(xxxx)

	// Update bandwidth to 10 Mbps and set to bandwidth billing mode.
	if err := updateBandwidth(eipClient, bandwidthId, "", sizeBandwidth, model.GetUpdateBandwidthOptionChargeModeEnum().BANDWIDTH); err != nil {
		fmt.Printf("Error updating bandwidth: %s\n", err)
		return
	}
	// Set a timer to switch back to traffic billing mode after 1 hour.
	time.AfterFunc(1*time.Hour, func() {
		if err := updateBandwidth(eipClient, bandwidthId, "", sizeTraefikBandwidth, model.GetUpdateBandwidthOptionChargeModeEnum().TRAFFIC); err != nil {
			fmt.Printf("Error reverting bandwidth: %s\n", err)
			return
		}
	})

	// Block the main goroutine to not exit immediately.
	select {}
}

// Function to update the bandwidth of an EIP.
func updateBandwidth(client *eip.EipClient, bandwidthId, name string, size int32, chargeMode model.UpdateBandwidthOptionChargeMode) error {
	request := &model.UpdateBandwidthRequest{
		BandwidthId: bandwidthId,
		Body: &model.UpdateBandwidthRequestBody{
			Bandwidth: &model.UpdateBandwidthOption{
				Name:       &name,
				Size:       &size,
				ChargeMode: &chargeMode,
			},
		},
	}

	response, err := client.UpdateBandwidth(request)
	if err != nil {
		return err
	}
	fmt.Printf("Update response: %+v\n", response)
	return nil
}

初始化EIP客户端

首先,需设置客户端认证,这涉及到基础的Access Key(AK)和Secret Key(SK)配置:

ak := "REPLACE_WITH_YOUR_AK"
sk := "REPLACE_WITH_YOUR_SK"
projectID := "REPLACE_WITH_YOUR_PROJECT_ID"

    auth := basic.NewCredentialsBuilder().
        WithAk(ak).
        WithSk(sk).
        Build()

    client := eip.NewEipClient(
        eip.EipClientBuilder().
            WithRegion(region.ValueOf("cn-east-3")).
            WithCredential(auth).
            Build())
...

务必保障这些敏感信息在环境变量或加密存储中,避免硬编码在应用程序中。

更新带宽函数

updateBandwidth 函数对EIP带宽大小和计费模式进行修改。

func updateBandwidth(client *eip.EipClient, bandwidthId, name string, size int32, chargeMode model.UpdateBandwidthOptionChargeMode) error {
	request := &model.UpdateBandwidthRequest{
		BandwidthId: bandwidthId,
		Body: &model.UpdateBandwidthRequestBody{
			Bandwidth: &model.UpdateBandwidthOption{
				Name:       &name,
				Size:       &size,
				ChargeMode: &chargeMode,
			},
		},
	}

	response, err := client.UpdateBandwidth(request)
	if err != nil {
		return err
	}
	fmt.Printf("Update response: %+v\n", response)
	return nil
}

这个函数构造了更新带宽的API请求,并处理响应或可能出现的错误。

使用协程和定时器

Go的并发模型让我们能够用协程(goroutines)和定时器轻松实现这个需求。

	go func() {
		if err := updateBandwidth(eipClient, bandwidthId, "xxxxx", sizeBandwidth, model.GetUpdateBandwidthOptionChargeModeEnum().BANDWIDTH); err != nil {
			fmt.Printf("更新带宽时出错: %s\n", err)
			return
		}

		// 设置计时器在10分钟后切换回流量计费模式。
		timer := time.NewTimer(1 * time.Minute)
		<-timer.C

		if err := updateBandwidth(eipClient, bandwidthId, "xxxxxx", sizeTrafficBandwidth, model.GetUpdateBandwidthOptionChargeModeEnum().TRAFFIC); err != nil {
			fmt.Printf("恢复带宽时出错: %s\n", err)
			return
		}
	}()

	// 使用通道阻塞主 goroutine 无限期。避免在空的 select 语句中旋转,这是不必要的。
	done := make(chan struct{})
	<-done
}

第一版代码

完整代码如下:

package main

import (
	"fmt"
	"time"

	"github.com/huaweicloud/huaweicloud-sdk-go-v3/core/auth/basic"
	"github.com/huaweicloud/huaweicloud-sdk-go-v3/core/config"
	eip "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/eip/v2"
	"github.com/huaweicloud/huaweicloud-sdk-go-v3/services/eip/v2/model"
	region "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/eip/v2/region"
)

func main() {
	// Replace with your own AK/SK, Region, and Project ID.
	ak := "xxxxxx"
	sk := "xxxxxx"
	projectID := "xxxxxx"

	// Authenticate using your Access Key and Secret Key.
	auth := basic.NewCredentialsBuilder().
		WithAk(ak).
		WithSk(sk).
		WithProjectId(projectID).
		Build()

	// Create EIP client configuration.
	eipClient := eip.NewEipClient(
		eip.EipClientBuilder().
			WithRegion(region.ValueOf("cn-east-3")).
			WithCredential(auth).
			WithHttpConfig(config.DefaultHttpConfig()).
			Build(),
	)

	// Replace the bandwidthId with your actual bandwidth ID.
	bandwidthId := "xxxx"
	sizeBandwidth := int32(xxx)
    sizeTrafficBandwidth := int32(xxx)

	// Update bandwidth to 10 Mbps and set to bandwidth billing mode.
	if err := updateBandwidth(eipClient, bandwidthId, "xxxx", sizeBandwidth, model.GetUpdateBandwidthOptionChargeModeEnum().BANDWIDTH); err != nil {
		fmt.Printf("Error updating bandwidth: %s\n", err)
		return
	}
	// Set a timer to switch back to traffic billing mode after 1 hour.
	time.AfterFunc(1*time.Hour, func() {
		if err := updateBandwidth(eipClient, bandwidthId, "xxxxx", sizeBandwidth, model.GetUpdateBandwidthOptionChargeModeEnum().TRAFFIC); err != nil {
			fmt.Printf("Error reverting bandwidth: %s\n", err)
			return
		}
	})

	// Block the main goroutine to not exit immediately.
	select {}
}

// Function to update the bandwidth of an EIP.
func updateBandwidth(client *eip.EipClient, bandwidthId, name string, size int32, chargeMode model.UpdateBandwidthOptionChargeMode) error {
	request := &model.UpdateBandwidthRequest{
		BandwidthId: bandwidthId,
		Body: &model.UpdateBandwidthRequestBody{
			Bandwidth: &model.UpdateBandwidthOption{
				Name:       &name,
				Size:       &size,
				ChargeMode: &chargeMode,
			},
		},
	}

	response, err := client.UpdateBandwidth(request)
	if err != nil {
		return err
	}
	fmt.Printf("Update response: %+v\n", response)
	return nil
}

运行main.go xreUAjVvck.png 可以在控制台查看代码操作,控制台对应实例生效!

继续完善代码:

上面的代码是用户传入bandwidthId,这关键一般用户不知道bandwidthId 阿?控制台用户来说一般能知道的是公网IPimage.png 我这里想到的是使用ListPublicips-查询弹性公网IP列表获取bandwidth_name bandwidth_id。 创建两个函数:getBandwidthIdByPublicIP getBandwidthNameByPublicIP

// 这里假设有一个通过公网IP获取带宽ID的函数
func getBandwidthIdByPublicIP(client *eip.EipClient, publicIP string) (string, error) {
	// 首先构造查询请求
	request := &model.ListPublicipsRequest{
		// 根据需要设置查询参数
	}

	// 调用SDK方法查询EIP详情
	response, err := client.ListPublicips(request)
	if err != nil {
		return "", err
	}

	// 遍历响应中的公共IP地址
	for _, publicip := range *response.Publicips { // 假设返回的是指针指向的切片
		// 检查 PublicIpAddress 是否为nil,并解引用来比较值
		if publicip.PublicIpAddress != nil && *publicip.PublicIpAddress == publicIP {
			// 检查 BandwidthId 是否为nil,并解引用来返回值
			if publicip.BandwidthId != nil {
				return *publicip.BandwidthId, nil
			}
			break // 如果 BandwidthId 为nil,则结束循环
		}
	}

	// 如果没有找到匹配的公共IP地址或带宽ID是nil,则返回错误
	return "", errors.New("public IP not found or bandwidth ID is nil")
}
func getBandwidthNameByPublicIP(client *eip.EipClient, publicIP string) (string, error) {
	// 首先构造查询请求
	request := &model.ListPublicipsRequest{
		// 根据需要设置查询参数
	}

	// 调用SDK方法查询EIP详情
	response, err := client.ListPublicips(request)
	if err != nil {
		return "", err
	}

	// 遍历响应中的公共IP地址
	for _, publicip := range *response.Publicips { // 假设返回的是指针指向的切片
		// 检查 PublicIpAddress 是否为nil,并解引用来比较值
		if publicip.PublicIpAddress != nil && *publicip.PublicIpAddress == publicIP {
			// 检查 BandwidthId 是否为nil,并解引用来返回值
			if publicip.BandwidthName != nil {
				return *publicip.BandwidthName, nil
			}
			break // 如果 BandwidthId 为nil,则结束循环
		}
	}

	// 如果没有找到匹配的公共IP地址或带宽ID是nil,则返回错误
	return "", errors.New("public IP not found or bandwidth ID is nil")
}

继续完善一下,通过运行main.go传入公网IP,固定带宽恢复按量计费后的带宽大小,以及修改为固定带宽的持续时间 。

go run main.go publicIP  sizeBandwidth sizeTrafficBandwidth timerMinutes
package main

import (
	"errors"
	"fmt"
	"os"
	"strconv"
	"time"

	"github.com/huaweicloud/huaweicloud-sdk-go-v3/core/auth/basic"
	"github.com/huaweicloud/huaweicloud-sdk-go-v3/core/config"
	eip "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/eip/v2"
	"github.com/huaweicloud/huaweicloud-sdk-go-v3/services/eip/v2/model"
	region "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/eip/v2/region"
)

func main() {
	// Replace with your own AK/SK, Region, and Project ID.
	ak := "xxxxxx"
	sk := "xxxxxx"
	projectID := "xxxxxx"
	if len(os.Args) != 5 {
		fmt.Println("Usage: go run main.go <publicIP> <sizeBandwidth> <sizeTrafficBandwidth> <timerMinutes>")
		return
	}

	publicIP := os.Args[1]
	sizeBandwidth, err := strconv.Atoi(os.Args[2])
	if err != nil {
		fmt.Println("Invalid sizeBandwidth:", err)
		return
	}
	sizeTrafficBandwidth, err := strconv.Atoi(os.Args[3])
	if err != nil {
		fmt.Println("Invalid sizeTrafficBandwidth:", err)
		return
	}
	timerMinutes, err := strconv.Atoi(os.Args[4])
	if err != nil {
		fmt.Println("Invalid timerMinutes:", err)
		return
	}
	// Authenticate using your Access Key and Secret Key.
	auth := basic.NewCredentialsBuilder().
		WithAk(ak).
		WithSk(sk).
		WithProjectId(projectID).
		Build()

	// Create EIP client configuration.
	eipClient := eip.NewEipClient(
		eip.EipClientBuilder().
			WithRegion(region.ValueOf("cn-east-3")).
			WithCredential(auth).
			WithHttpConfig(config.DefaultHttpConfig()).
			Build(),
	)

	bandwidthId, err := getBandwidthIdByPublicIP(eipClient, publicIP)
	if err != nil {
		fmt.Println(err)
		return
	}
	bandwidthName, err := getBandwidthNameByPublicIP(eipClient, publicIP)
	if err != nil {
		fmt.Println(err)
		return
	}
	go func() {
		if err := updateBandwidth(eipClient, bandwidthId, bandwidthName, int32(sizeBandwidth), model.GetUpdateBandwidthOptionChargeModeEnum().BANDWIDTH); err != nil {
			fmt.Printf("更新带宽时出错: %s\n", err)
			return
		}

		// 设置计时器在10分钟后切换回流量计费模式。
		timer := time.NewTimer(time.Duration(timerMinutes) * time.Minute)
		<-timer.C

		if err := updateBandwidth(eipClient, bandwidthId, bandwidthName, int32(sizeTrafficBandwidth), model.GetUpdateBandwidthOptionChargeModeEnum().TRAFFIC); err != nil {
			fmt.Printf("恢复带宽时出错: %s\n", err)
			return
		}
	}()

	// 使用通道阻塞主 goroutine 无限期。避免在空的 select 语句中旋转,这是不必要的。
	done := make(chan struct{})
	<-done
}

// 这里假设有一个通过公网IP获取带宽ID的函数
func getBandwidthIdByPublicIP(client *eip.EipClient, publicIP string) (string, error) {
	// 首先构造查询请求
	request := &model.ListPublicipsRequest{
		// 根据需要设置查询参数
	}

	// 调用SDK方法查询EIP详情
	response, err := client.ListPublicips(request)
	if err != nil {
		return "", err
	}

	// 遍历响应中的公共IP地址
	for _, publicip := range *response.Publicips { // 假设返回的是指针指向的切片
		// 检查 PublicIpAddress 是否为nil,并解引用来比较值
		if publicip.PublicIpAddress != nil && *publicip.PublicIpAddress == publicIP {
			// 检查 BandwidthId 是否为nil,并解引用来返回值
			if publicip.BandwidthId != nil {
				return *publicip.BandwidthId, nil
			}
			break // 如果 BandwidthId 为nil,则结束循环
		}
	}

	// 如果没有找到匹配的公共IP地址或带宽ID是nil,则返回错误
	return "", errors.New("public IP not found or bandwidth ID is nil")
}
func getBandwidthNameByPublicIP(client *eip.EipClient, publicIP string) (string, error) {
	// 首先构造查询请求
	request := &model.ListPublicipsRequest{
		// 根据需要设置查询参数
	}

	// 调用SDK方法查询EIP详情
	response, err := client.ListPublicips(request)
	if err != nil {
		return "", err
	}

	// 遍历响应中的公共IP地址
	for _, publicip := range *response.Publicips { // 假设返回的是指针指向的切片
		// 检查 PublicIpAddress 是否为nil,并解引用来比较值
		if publicip.PublicIpAddress != nil && *publicip.PublicIpAddress == publicIP {
			// 检查 BandwidthId 是否为nil,并解引用来返回值
			if publicip.BandwidthName != nil {
				return *publicip.BandwidthName, nil
			}
			break // 如果 BandwidthId 为nil,则结束循环
		}
	}

	// 如果没有找到匹配的公共IP地址或带宽ID是nil,则返回错误
	return "", errors.New("public IP not found or bandwidth ID is nil")
}

// Function to update the bandwidth of an EIP.
func updateBandwidth(client *eip.EipClient, bandwidthId, name string, size int32, chargeMode model.UpdateBandwidthOptionChargeMode) error {
	request := &model.UpdateBandwidthRequest{
		BandwidthId: bandwidthId,
		Body: &model.UpdateBandwidthRequestBody{
			Bandwidth: &model.UpdateBandwidthOption{
				Name:       &name,
				Size:       &size,
				ChargeMode: &chargeMode,
			},
		},
	}

	response, err := client.UpdateBandwidth(request)
	if err != nil {
		return err
	}
	fmt.Printf("Update response: %+v\n", response)
	return nil
}

jenkins运行以上代码实例

最终我需要在jenkins中运行这个更改流量的任务,我将引用ak,sk引用jenkins凭据的方式: 参照之前刷新cdn时候引用凭据的方式: image.png 最终代码如下:

package main

import (
	"errors"
	"fmt"
	"os"
	"strconv"
	"time"

	"github.com/huaweicloud/huaweicloud-sdk-go-v3/core/auth/basic"
	"github.com/huaweicloud/huaweicloud-sdk-go-v3/core/config"
	eip "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/eip/v2"
	"github.com/huaweicloud/huaweicloud-sdk-go-v3/services/eip/v2/model"
	region "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/eip/v2/region"
)

func main() {
	// Replace with your own AK/SK, Region, and Project ID.
	// 尝试从环境变量中获取ak和sk
	creds := os.Getenv("huaweiyun-hn-cdn")
	if creds == "" {
		fmt.Fprintln(os.Stderr, "Error: Credentials environment variable is not set.")
		os.Exit(1)
	}

	parts := strings.SplitN(creds, ":", 2)
	if len(parts) != 2 {
		fmt.Fprintln(os.Stderr, "Error: Invalid credential format. Expected 'AK:SK'.")
		os.Exit(1)
	}

	ak, sk := parts[0], parts[1]
	projectID := "xxxxxx"
	if len(os.Args) != 5 {
		fmt.Println("Usage: go run main.go <publicIP> <sizeBandwidth> <sizeTrafficBandwidth> <timerMinutes>")
		return
	}

	publicIP := os.Args[1]
	sizeBandwidth, err := strconv.Atoi(os.Args[2])
	if err != nil {
		fmt.Println("Invalid sizeBandwidth:", err)
		return
	}
	sizeTrafficBandwidth, err := strconv.Atoi(os.Args[3])
	if err != nil {
		fmt.Println("Invalid sizeTrafficBandwidth:", err)
		return
	}
	timerMinutes, err := strconv.Atoi(os.Args[4])
	if err != nil {
		fmt.Println("Invalid timerMinutes:", err)
		return
	}
	// Authenticate using your Access Key and Secret Key.
	auth := basic.NewCredentialsBuilder().
		WithAk(ak).
		WithSk(sk).
		WithProjectId(projectID).
		Build()

	// Create EIP client configuration.
	eipClient := eip.NewEipClient(
		eip.EipClientBuilder().
			WithRegion(region.ValueOf("cn-east-3")).
			WithCredential(auth).
			WithHttpConfig(config.DefaultHttpConfig()).
			Build(),
	)

	bandwidthId, err := getBandwidthIdByPublicIP(eipClient, publicIP)
	if err != nil {
		fmt.Println(err)
		return
	}
	bandwidthName, err := getBandwidthNameByPublicIP(eipClient, publicIP)
	if err != nil {
		fmt.Println(err)
		return
	}
	go func() {
		if err := updateBandwidth(eipClient, bandwidthId, bandwidthName, int32(sizeBandwidth), model.GetUpdateBandwidthOptionChargeModeEnum().BANDWIDTH); err != nil {
			fmt.Printf("更新带宽时出错: %s\n", err)
			return
		}

		// 设置计时器在10分钟后切换回流量计费模式。
		timer := time.NewTimer(time.Duration(timerMinutes) * time.Minute)
		<-timer.C

		if err := updateBandwidth(eipClient, bandwidthId, bandwidthName, int32(sizeTrafficBandwidth), model.GetUpdateBandwidthOptionChargeModeEnum().TRAFFIC); err != nil {
			fmt.Printf("恢复带宽时出错: %s\n", err)
			return
		}
	}()

	// 使用通道阻塞主 goroutine 无限期。避免在空的 select 语句中旋转,这是不必要的。
	done := make(chan struct{})
	<-done
}

// 这里假设有一个通过公网IP获取带宽ID的函数
func getBandwidthIdByPublicIP(client *eip.EipClient, publicIP string) (string, error) {
	// 首先构造查询请求
	request := &model.ListPublicipsRequest{
		// 根据需要设置查询参数
	}

	// 调用SDK方法查询EIP详情
	response, err := client.ListPublicips(request)
	if err != nil {
		return "", err
	}

	// 遍历响应中的公共IP地址
	for _, publicip := range *response.Publicips { // 假设返回的是指针指向的切片
		// 检查 PublicIpAddress 是否为nil,并解引用来比较值
		if publicip.PublicIpAddress != nil && *publicip.PublicIpAddress == publicIP {
			// 检查 BandwidthId 是否为nil,并解引用来返回值
			if publicip.BandwidthId != nil {
				return *publicip.BandwidthId, nil
			}
			break // 如果 BandwidthId 为nil,则结束循环
		}
	}

	// 如果没有找到匹配的公共IP地址或带宽ID是nil,则返回错误
	return "", errors.New("public IP not found or bandwidth ID is nil")
}
func getBandwidthNameByPublicIP(client *eip.EipClient, publicIP string) (string, error) {
	// 首先构造查询请求
	request := &model.ListPublicipsRequest{
		// 根据需要设置查询参数
	}

	// 调用SDK方法查询EIP详情
	response, err := client.ListPublicips(request)
	if err != nil {
		return "", err
	}

	// 遍历响应中的公共IP地址
	for _, publicip := range *response.Publicips { // 假设返回的是指针指向的切片
		// 检查 PublicIpAddress 是否为nil,并解引用来比较值
		if publicip.PublicIpAddress != nil && *publicip.PublicIpAddress == publicIP {
			// 检查 BandwidthId 是否为nil,并解引用来返回值
			if publicip.BandwidthName != nil {
				return *publicip.BandwidthName, nil
			}
			break // 如果 BandwidthId 为nil,则结束循环
		}
	}

	// 如果没有找到匹配的公共IP地址或带宽ID是nil,则返回错误
	return "", errors.New("public IP not found or bandwidth ID is nil")
}

// Function to update the bandwidth of an EIP.
func updateBandwidth(client *eip.EipClient, bandwidthId, name string, size int32, chargeMode model.UpdateBandwidthOptionChargeMode) error {
	request := &model.UpdateBandwidthRequest{
		BandwidthId: bandwidthId,
		Body: &model.UpdateBandwidthRequestBody{
			Bandwidth: &model.UpdateBandwidthOption{
				Name:       &name,
				Size:       &size,
				ChargeMode: &chargeMode,
			},
		},
	}

	response, err := client.UpdateBandwidth(request)
	if err != nil {
		return err
	}
	fmt.Printf("Update response: %+v\n", response)
	return nil
}

go build main.go,编译为可执行程序!将可执行程序放在工作节点上,jenkins 做了一个demo 参数化构建,字符参数image.png 绑定密钥文件: image.png Build Steps 执行shell

cd /home/eip-hw&&./main $publicIP $sizeBandwidth $sizeTrafficBandwidth $timerMinutes

image.png 输入publicIP运行程序: image.png 程序运行生效,但是进程没有退出:

image.png

最终go相关代码:

继续完善一下代码,当程序运行完成后,退出程序。输出Bandwidth update successful, exiting:

package main

import (
	"errors"
	"fmt"
	"os"
	"strconv"
	"time"
        "strings"
	"github.com/huaweicloud/huaweicloud-sdk-go-v3/core/auth/basic"
	"github.com/huaweicloud/huaweicloud-sdk-go-v3/core/config"
	eip "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/eip/v2"
	"github.com/huaweicloud/huaweicloud-sdk-go-v3/services/eip/v2/model"
	region "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/eip/v2/region"
)

func main() {
	// Replace with your own AK/SK, Region, and Project ID.
	// 尝试从环境变量中获取ak和sk
	creds := os.Getenv("xxxxxx")
	if creds == "" {
		fmt.Fprintln(os.Stderr, "Error: Credentials environment variable is not set.")
		os.Exit(1)
	}

	parts := strings.SplitN(creds, ":", 2)
	if len(parts) != 2 {
		fmt.Fprintln(os.Stderr, "Error: Invalid credential format. Expected 'AK:SK'.")
		os.Exit(1)
	}

	ak, sk := parts[0], parts[1]
	projectID := "xxxxxx"
	if len(os.Args) != 5 {
		fmt.Println("Usage: go run main.go <publicIP> <sizeBandwidth> <sizeTrafficBandwidth> <timerMinutes>")
		return
	}

	publicIP := os.Args[1]
	sizeBandwidth, err := strconv.Atoi(os.Args[2])
	if err != nil {
		fmt.Println("Invalid sizeBandwidth:", err)
		return
	}
	sizeTrafficBandwidth, err := strconv.Atoi(os.Args[3])
	if err != nil {
		fmt.Println("Invalid sizeTrafficBandwidth:", err)
		return
	}
	timerMinutes, err := strconv.Atoi(os.Args[4])
	if err != nil {
		fmt.Println("Invalid timerMinutes:", err)
		return
	}
	// Authenticate using your Access Key and Secret Key.
	auth := basic.NewCredentialsBuilder().
		WithAk(ak).
		WithSk(sk).
		WithProjectId(projectID).
		Build()

	// Create EIP client configuration.
	eipClient := eip.NewEipClient(
		eip.EipClientBuilder().
			WithRegion(region.ValueOf("cn-east-3")).
			WithCredential(auth).
			WithHttpConfig(config.DefaultHttpConfig()).
			Build(),
	)

	bandwidthId, err := getBandwidthIdByPublicIP(eipClient, publicIP)
	if err != nil {
		fmt.Println(err)
		return
	}
	bandwidthName, err := getBandwidthNameByPublicIP(eipClient, publicIP)
	if err != nil {
		fmt.Println(err)
		return
	}
	go func() {
		if err := updateBandwidth(eipClient, bandwidthId, bandwidthName, int32(sizeBandwidth), model.GetUpdateBandwidthOptionChargeModeEnum().BANDWIDTH); err != nil {
			fmt.Printf("更新带宽时出错: %s\n", err)
			 os.Exit(1)
			return
		}

		// 设置计时器在10分钟后切换回流量计费模式。
		timer := time.NewTimer(time.Duration(timerMinutes) * time.Minute)
		<-timer.C

		if err := updateBandwidth(eipClient, bandwidthId, bandwidthName, int32(sizeTrafficBandwidth), model.GetUpdateBandwidthOptionChargeModeEnum().TRAFFIC); err != nil {
			fmt.Printf("恢复带宽时出错: %s\n", err)
			os.Exit(1)
			return
		}
		fmt.Println("Bandwidth update successful, exiting.") // Log success message
                os.Exit(0) // Exit the process after success
	}()

	// 使用通道阻塞主 goroutine 无限期。避免在空的 select 语句中旋转,这是不必要的。
	done := make(chan struct{})
	<-done
}

// 这里假设有一个通过公网IP获取带宽ID的函数
func getBandwidthIdByPublicIP(client *eip.EipClient, publicIP string) (string, error) {
	// 首先构造查询请求
	request := &model.ListPublicipsRequest{
		// 根据需要设置查询参数
	}

	// 调用SDK方法查询EIP详情
	response, err := client.ListPublicips(request)
	if err != nil {
		return "", err
	}

	// 遍历响应中的公共IP地址
	for _, publicip := range *response.Publicips { // 假设返回的是指针指向的切片
		// 检查 PublicIpAddress 是否为nil,并解引用来比较值
		if publicip.PublicIpAddress != nil && *publicip.PublicIpAddress == publicIP {
			// 检查 BandwidthId 是否为nil,并解引用来返回值
			if publicip.BandwidthId != nil {
				return *publicip.BandwidthId, nil
			}
			break // 如果 BandwidthId 为nil,则结束循环
		}
	}

	// 如果没有找到匹配的公共IP地址或带宽ID是nil,则返回错误
	return "", errors.New("public IP not found or bandwidth ID is nil")
}
func getBandwidthNameByPublicIP(client *eip.EipClient, publicIP string) (string, error) {
	// 首先构造查询请求
	request := &model.ListPublicipsRequest{
		// 根据需要设置查询参数
	}

	// 调用SDK方法查询EIP详情
	response, err := client.ListPublicips(request)
	if err != nil {
		return "", err
	}

	// 遍历响应中的公共IP地址
	for _, publicip := range *response.Publicips { // 假设返回的是指针指向的切片
		// 检查 PublicIpAddress 是否为nil,并解引用来比较值
		if publicip.PublicIpAddress != nil && *publicip.PublicIpAddress == publicIP {
			// 检查 BandwidthId 是否为nil,并解引用来返回值
			if publicip.BandwidthName != nil {
				return *publicip.BandwidthName, nil
			}
			break // 如果 BandwidthId 为nil,则结束循环
		}
	}

	// 如果没有找到匹配的公共IP地址或带宽ID是nil,则返回错误
	return "", errors.New("public IP not found or bandwidth ID is nil")
}

// Function to update the bandwidth of an EIP.
func updateBandwidth(client *eip.EipClient, bandwidthId, name string, size int32, chargeMode model.UpdateBandwidthOptionChargeMode) error {
	request := &model.UpdateBandwidthRequest{
		BandwidthId: bandwidthId,
		Body: &model.UpdateBandwidthRequestBody{
			Bandwidth: &model.UpdateBandwidthOption{
				Name:       &name,
				Size:       &size,
				ChargeMode: &chargeMode,
			},
		},
	}

	response, err := client.UpdateBandwidth(request)
	if err != nil {
		return err
	}
	fmt.Printf("Update response: %+v\n", response)
	return nil
}

image.png ok这样就简单实现了! 注:以上代码chatgpt生成,个人进行了更改整理.

其他想到的

  1. 修改一下程序,检测流量计费,当带宽到xxx的时候自动切换带宽?
  2. 支持一下更多类型的切换方式?比如固定带宽的直接10变更 5 20,不恢复流量计费?

标签:EIP,err,nil,eip,fmt,huaweicloud,Job,go,jenkins
From: https://blog.51cto.com/saynaihe/8970837

相关文章

  • Jenkins项目控制台输出结果乱码
    解决方法:1、设置全局配置,添加键和值键:LANG值:zh.CH.UTF-82、修改jenkins.xml文档(在Jenkins的安装目录下)搜索定位到<arguments>-Xrs-Xmx256m这一行,添加-Dfile.encoding=utf-83、重启Jenkins,使配置生效4、查看Jenkins配置,file.encoding为utf-8,配置生效5、重新尝试执行......
  • python Django项目在jenkins中部署
    1.在jenkins中创建一个自由风格的job: 配置git源代码仓库:构建机制的配置: 配置执行shell脚本: ps-ef|grep0.0.0.0:8088|grep-vgrep|awk'{print$2}'|xargskill-9echo"=============Finishtokillreleasewikirealprocess=================="BUIL......
  • Jenkins版本升级后Job的迁移
    场景在平时使用中apt-update不小心把jenkins由原来的2.303.2升级到2.414.3,造成原有的job无法工作解决方法只需要通过直接复制job对应目录下config.xml文件实现迁移旧的Job。config.xml文件包含了JenkinsJob的配置信息,包括源码配置、触发条件、构建步骤等等。迁移过程如下:1.......
  • xxlJob Cron表达式 0 0 8,13 * * ?
    xxlJobCron表达式 008,13**?Cron有如下两种语法格式:(1)SecondsMinutesHoursDayofMonthMonthDayofWeekYear(2)SecondsMinutesHoursDayofMonthMonthDayofWeekcorn从左到右(用空格隔开):秒分小时月份中的日期月份星期中的日期年份字段 允许值 允许的特殊字......
  • dokcer m1 jenkins dokcer-compsose部署
    version:"3.0"services:jenkins:image:jenkins/jenkins:ltscontainer_name:jenkinsprivileged:trueuser:rootrestart:alwaysports:-9090:9090volumes:-/Users/jackson/myapp/jenkins:/var/jenkins_homen......
  • XXL-JOB 2.3的升级使用
    XXL-JOB是一个轻量级分布式任务调度平台,其核心设计目标是开发迅速、学习简单、轻量级、易扩展。现已开放源代码并接入多家公司线上产品线,开箱即用。XXL-JOB2.3的升级点:1、【新增】调度过期策略:调度中心错过调度时间的补偿处理策略,包括:忽略、立即补偿触发一次等;2、【新增】触发策略......
  • Jenkins设置中文
    一、下载插件访问jenkins,选择【ManageJenkins】->【Plugins】->【AvailablePlugins】搜索【locale】,勾选进行安装相关插件 二、重启在URL的后面加上restart,例如:http://lP地址:端口号/restart三、配置【ManageJenkins】->【ConfigureSystem】->【Locale】输入"zh_CN",勾......
  • Jenkins中配置项目的运行频率
    【配置】->【构建触发器】->勾选【Buildperiodically】,在出现的日程表中,输入内容,观察下方出现的信息构建频率包含5个参数,其含义如下:分钟:取值范围为0~59(建议用H来标记,以均匀传播负载)。小时:取值范围为0~23。天:取值范围为1~31。月:取值范围为1~12。星期:取值范围为0~7。参考实......
  • Pytest+Request+Allure+Jenkins实现接口自动化
    利用Pytest+Request+Allure+Jenkins实现接口自动化;实现一套脚本多套环境执行;利用参数化数据驱动模式,实现接口与测试数据分离使用logger定制实现自动化测试日志记录实现步骤:框架结构:1、接口自动化项目代码编写(先在window实现)1.1项目准备先在window安装响应的环境依赖安装python3.7(......
  • 关于C#定时任务 job
    ////创建调度单元//Task<IScheduler>tsk=StdSchedulerFactory.GetDefaultScheduler();//ISchedulerscheduler=tsk.Result;////2.创建一个具体的作业即job(具体的job需要单独在一个文件中执行)//IJobDetailjob=JobBuil......