当前位置：主页 > 查看内容

Go SDK 使用示例 - 弹性容器实例

发布时间：2021-09-17 00:00| 有 位朋友查看

简介：Go sdk 地址 样例： const.go package eci type ContainerGroupStatus string const ( Scheduling = ContainerGroupStatus ( "Scheduling" ) Pending = ContainerGroupStatus ( "Pending" ) Running = ContainerGroupStatus ( "Running" ) Succeeded = Conta……

Go sdk 地址

样例：

const.go

  1. package eci
  3. type ContainerGroupStatus string
  5. const (
  6.     Scheduling     = ContainerGroupStatus("Scheduling")
  7.     Pending        = ContainerGroupStatus("Pending")
  8.     Running        = ContainerGroupStatus("Running")
  9.     Succeeded      = ContainerGroupStatus("Succeeded")
  10.     Failed         = ContainerGroupStatus("Failed")
  11.     Restarting     = ContainerGroupStatus("Restarting")
  12.     Updating       = ContainerGroupStatus("Updating")
  13.     ScheduleFailed = ContainerGroupStatus("ScheduleFailed")
  14. )
  16. type ContainerStatus string
  18. const (
  19.     waiting    = ContainerStatus("Waiting")
  20.     running    = ContainerStatus("Running")
  21.     terminated = ContainerStatus("Terminated")
  22. )

config.conf

  1. [eci_conf]
  2. #测试账号ak
  3. access_key = xxx
  4. secret_key = xxx
  6. #region
  7. region_id=cn-hangzhou
  9. #每个region下的资源信息，json格式
  10. region_info={"cn-hangzhou": {"securityGroupId": "sg-bp118knl07ymorgzfhyw","vSwitchId": "vsw-bp1jrgfqqy54kg5hcf8bc","zoneId": "cn-hangzhou-h"},"cn-shanghai": {"securityGroupId": "sg-uf62jug0dt92nfy630cs","vSwitchId": "vsw-uf6cb39ub5urw82bv3w70","zoneId": "cn-shanghai-g"},"cn-beijing": {"securityGroupId": "sg-2ze6uv80a8s4yk04dmyu","vSwitchId": "vsw-2zegtxf8q29d8tt1xtcjk","zoneId": "cn-beijing-h"},"cn-shenzhen":{"securityGroupId": "sg-wz96x4kv4edy97q6jjzn","vSwitchId": "vsw-wz9rn33jwilodp24klo0q","zoneId": "cn-shenzhen-a"},"cn-hongkong":{"securityGroupId": "sg-j6cjajpf7f4ybda7h19w","vSwitchId": "vsw-j6c9c9fit5owbbc0ids6c","zoneId": "cn-hongkong-b"},"us-west-1":{"securityGroupId": "sg-u19hbpj9x","vSwitchId": "vsw-rj9h5vvzhb4fjkuzuyi8j","zoneId": "us-west-1a"},"us-east-1":{"securityGroupId": "sg-0xih51sfoldxzxfsbja5","vSwitchId": "vsw-0xisefewxoqe4f849jbnl","zoneId": "us-east-1b"},"ap-southeast-1":{"securityGroupId": "sg-t4n23ppw7fm5to7cnib9","vSwitchId": "vsw-t4nr1xt8zupxg00unnmg9","zoneId": "ap-southeast-1b"},"cn-zhangjiakou": {"securityGroupId": "sg-8vb96lku1dgq71ckh98g","vSwitchId": "vsw-8vbtnz5878r3bcio7cpyx", "nfs":"9cbb94a474-oav34.cn-zhangjiakou.nas.aliyuncs.com", "zoneId": "cn-zhangjiakou-a"}}

config.conf的region_info参数(仅供参考)：

  1. {
  2.     "cn-hangzhou": {
  3.         "securityGroupId": "sg-bp118knl07ymorgzfhyw",
  4.         "vSwitchId": "vsw-bp1jrgfqqy54kg5hcf8bc",
  5.         "zoneId": "cn-hangzhou-h"
  6.     },
  7.     "cn-shanghai": {
  8.         "securityGroupId": "sg-uf62jug0dt92nfy630cs",
  9.         "vSwitchId": "vsw-uf6cb39ub5urw82bv3w70",
  10.         "zoneId": "cn-shanghai-g"
  11.     },
  12.     "cn-beijing": {
  13.         "securityGroupId": "sg-2ze6uv80a8s4yk04dmyu",
  14.         "vSwitchId": "vsw-2zegtxf8q29d8tt1xtcjk",
  15.         "zoneId": "cn-beijing-h"
  16.     },
  17.     "cn-shenzhen": {
  18.         "securityGroupId": "sg-wz96x4kv4edy97q6jjzn",
  19.         "vSwitchId": "vsw-wz9rn33jwilodp24klo0q",
  20.         "zoneId": "cn-shenzhen-a"
  21.     },
  22.     "cn-hongkong": {
  23.         "securityGroupId": "sg-j6cjajpf7f4ybda7h19w",
  24.         "vSwitchId": "vsw-j6c9c9fit5owbbc0ids6c",
  25.         "zoneId": "cn-hongkong-b"
  26.     },
  27.     "us-west-1": {
  28.         "securityGroupId": "sg-u19hbpj9x",
  29.         "vSwitchId": "vsw-rj9h5vvzhb4fjkuzuyi8j",
  30.         "zoneId": "us-west-1a"
  31.     },
  32.     "ap-southeast-1": {
  33.         "securityGroupId": "sg-t4n23ppw7fm5to7cnib9",
  34.         "vSwitchId": "vsw-t4nr1xt8zupxg00unnmg9",
  35.         "zoneId": "ap-southeast-1b"
  36.     },
  37.     "cn-zhangjiakou": {
  38.         "securityGroupId": "sg-8vb96lku1dgq71ckh98g",
  39.         "vSwitchId": "vsw-8vbtnz5878r3bcio7cpyx",
  40.         "zoneId": "cn-zhangjiakou-a"
  41.     }
  42. }

eci.go

  1. package eci
  3. import (
  4.     "encoding/json"
  5.     "fmt"
  6.     "github.com/Unknwon/goconfig"
  7.     "github.com/aliyun/alibaba-cloud-sdk-go/sdk/requests"
  8.     "github.com/aliyun/alibaba-cloud-sdk-go/services/eci"
  9.     "math"
  10.     "os"
  11.     "reflect"
  12.     "strconv"
  13.     "time"
  14. )
  16. var accessKey string
  17. var secretKey string
  18. var regionId string
  19. var zoneId string
  20. var securityGroupId string
  21. var vSwitchId string
  23. var client *eci.Client
  25. /**
  26. 获取配置信息
  27.  */
  28. func init() {
  29.     var cfg *goconfig.ConfigFile
  30.     config, err := goconfig.LoadConfigFile("./eci/config.conf") //加载配置文件
  31.     if err != nil {
  32.         fmt.Println("get config file error:", err.Error())
  33.         os.Exit(-1)
  34.     }
  35.     cfg = config
  37.     accessKey, _ = cfg.GetValue("eci_conf", "access_key")
  38.     secretKey, _ = cfg.GetValue("eci_conf", "secret_key")
  39.     regionId, _ = cfg.GetValue("eci_conf", "region_id")
  41.     var regionInfo map[string](map[string](string));
  42.     value, _ := cfg.GetValue("eci_conf", "region_info")
  44.     json.Unmarshal([]byte(value), &regionInfo)
  46.     zoneId = regionInfo[regionId]["zoneId"]
  47.     securityGroupId = regionInfo[regionId]["securityGroupId"]
  48.     vSwitchId = regionInfo[regionId]["vSwitchId"]
  50.     fmt.Printf("init success[ access_key:%s, secret_key:%s, region_id:%s, zoneId:%s, vSwitchId:%s, securityGroupId:%s]\n",
  51.         accessKey, secretKey, regionId, zoneId, vSwitchId, securityGroupId)
  53.     //初始化client
  54.     client, err = eci.NewClientWithAccessKey(regionId, accessKey, secretKey)
  55.     if err != nil {
  56.         panic(err)
  57.     }
  58. }
  60. /**
  61. 创建
  62. */
  63. func createContainerGroup ()(string)  {
  64.     // Create Container Group
  65.     createContainerRequest := eci.CreateCreateContainerGroupRequest()
  66.     // required
  67.     createContainerRequest.RegionId = regionId;
  68.     createContainerRequest.SecurityGroupId = securityGroupId
  69.     createContainerRequest.VSwitchId = vSwitchId
  70.     createContainerRequest.ContainerGroupName = "test-go-sdk"
  71.     createContainerRequest.RestartPolicy = "Never"
  73.     createContainerRequestVolume := make([]eci.CreateContainerGroupVolume, 1)
  75.     volume1 := &eci.CreateContainerGroupNFSVolume{
  76.         Path:"/",
  77.         Server:"0a1bf4a604-jaq68.cn-hangzhou.nas.aliyuncs.com",
  78.     }
  80.     createContainerRequestVolume[0].Name = "volume1"
  81.     createContainerRequestVolume[0].Type ="NFSVolume"
  82.     createContainerRequestVolume[0].NFSVolume=*volume1
  84.     createContainerRequest.Volume = &createContainerRequestVolume
  86.     createContainerRequestContainer := make([]eci.CreateContainerGroupContainer, 1)
  87.     createContainerRequestContainer[0].Image = "nginx"
  88.     createContainerRequestContainer[0].Name = "nginx-liu"
  89.     // option
  90.     createContainerRequestContainer[0].Cpu = requests.NewFloat(0.25)
  91.     createContainerRequestContainer[0].Memory = requests.NewFloat(0.5)
  92.     createContainerRequestContainer[0].ImagePullPolicy = "IfNotPresent"
  94.     createContainerRequest.Container = &createContainerRequestContainer
  96.     //sdk-core默认的重试次数为3，在没有加幂等的条件下，资源创建的接口底层不需要自动重试
  97.     client.GetConfig().MaxRetryTime = 0
  98.     createContainerGroupResponse, err := client.CreateContainerGroup(createContainerRequest)
  99.     if err != nil {
  100.         panic(err)
  101.     }
  103.     containerGroupId := createContainerGroupResponse.ContainerGroupId
  105.     fmt.Println(containerGroupId)
  107.     return containerGroupId
  109. }
  111. /**
  112. 删除
  113. */
  114. func deleteContainerGroup(containerGroupId string) {
  115.     deleteContainerGroupRequest := eci.CreateDeleteContainerGroupRequest()
  116.     deleteContainerGroupRequest.RegionId = regionId
  117.     deleteContainerGroupRequest.ContainerGroupId = containerGroupId
  119.     _, err := client.DeleteContainerGroup(deleteContainerGroupRequest)
  120.     if err != nil {
  121.         panic(err)
  122.     }
  124.     fmt.Println("DeleteContainerGroup ContainerGroupId :", containerGroupId)
  125. }
  127. /**
  128. 查询
  129. */
  130. func describeContainerGroup(containerGroupId string) (eci.DescribeContainerGroupsContainerGroup0)  {
  131.     // Describe Container Groups
  132.     describeContainerGroupsRequest := eci.CreateDescribeContainerGroupsRequest()
  133.     describeContainerGroupsRequest.RegionId = regionId
  135.     containerGroupIds := append([]string{}, containerGroupId)
  136.     containerGroupIdsString, err := json.Marshal(containerGroupIds)
  137.     describeContainerGroupsRequest.ContainerGroupIds = string(containerGroupIdsString)
  139.     describeContainerGroupsResponse, err := client.DescribeContainerGroups(describeContainerGroupsRequest)
  140.     if err != nil {
  141.         panic(err)
  142.     }
  144.     describeContainerGroupNumber := len(describeContainerGroupsResponse.ContainerGroups)
  146.     if describeContainerGroupsResponse.TotalCount != 1 && describeContainerGroupNumber != 1 {
  147.         fmt.Println("Invalid ContainerGroups count", describeContainerGroupsResponse.TotalCount, describeContainerGroupNumber)
  148.         panic("Invalid ContainerGroups count")
  149.     }
  151.     fmt.Println("ContainerGroup status:", describeContainerGroupsResponse.ContainerGroups[0].Status, containerGroupId,)
  153.     // container groups
  154.     return describeContainerGroupsResponse.ContainerGroups[0]
  156. }
  158. func describeContainerGroupMetric(containerGroupId string)  {
  159.     describeContainerGroupMetricRequest :=eci.CreateDescribeContainerGroupMetricRequest()
  160.     describeContainerGroupMetricRequest.RegionId = regionId
  161.     describeContainerGroupMetricRequest.ContainerGroupId=containerGroupId
  163.     response, err := client.DescribeContainerGroupMetric(describeContainerGroupMetricRequest)
  164.     if err != nil {
  165.         panic(err)
  166.     }
  168.     data, _ :=json.Marshal(response)
  170.     fmt.Printf("Metrics for %s:%s\n", containerGroupId, string(data))
  171. }
  173. func describeMultiContainerGroupMetric(containerGroupIds []string)  {
  174.     describeContainerGroupMetricRequest
  175.     :=eci.CreateDescribeMultiContainerGroupMetricRequest()
  176.     describeContainerGroupMetricRequest.RegionId = regionId
  178.     data,_ :=json.Marshal(containerGroupIds)
  179.     describeContainerGroupMetricRequest.ContainerGroupIds=string(data)
  181.     response, err := client.DescribeMultiContainerGroupMetric(describeContainerGroupMetricRequest)
  182.     if err != nil {
  183.         panic(err)
  184.     }
  186.     data, _ = json.Marshal(response)
  188.     fmt.Printf("Metrics:%s\n", string(data))
  190. }
  192. func Test() {
  193.     containerGroupIds := make(chan string)
  195.     go func() {
  196.         for i := 0; i < 1; i++ {
  197.             containerGroupId := createContainerGroup()
  198.             containerGroupIds <- containerGroupId
  199.         }
  200.     }()
  202.     go func() {
  203.         for containerGroupId := range containerGroupIds {
  204.             for i := 0; i < 10; i++ {
  205.                 status := describeContainerGroup(containerGroupId).Status
  206.                 if Running == ContainerGroupStatus(status) {
  207.                     break
  208.                 } else {
  209.                     time.Sleep(5 * time.Second)
  210.                 }
  211.             }
  212.             //deleteContainerGroupById(containerGroupId)
  213.         }
  214.     }()
  216.     //阻塞等待异步执行完，不然会提前退出。
  217.     var input string
  218.     fmt.Println("waiting for input to finish:")
  219.     fmt.Scanln(&input)
  220.     fmt.Println("test done!")
  221. }

main.go

  1. func main() {
  2.     eci.Test()
  3. }

本站部分内容转载于网络，版权归原作者所有，转载之目的在于传播更多优秀技术内容，如有侵权请联系QQ/微信：153890879删除，谢谢！
上一篇：容器服务 获取集群RBAC管理员角色 - API 文档 下一篇：没有了

推荐图文

  • 周排行
  • 月排行
  • 总排行

随机推荐