Skip to content

Commit 8ac4e3d

Browse files
lieguliegu
committed
Add features in bcc,cdn,aihc and hpas
1 parent 7ad2a3e commit 8ac4e3d

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

49 files changed

+4360
-477
lines changed

‎Changelog

+10-1
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,14 @@
11
发行说明:记录每次SDK更新的说明,最新版本的SDK包含以前所有版本的更新内容。
22
---------------------------------------------------------------------
3+
【版本:v0.9.215】
4+
涉及产品:BCC
5+
变配相关接口新增是否开启Jumbo帧参数、创建相关接口支持传递超线程和numa参数
6+
涉及产品:CDN
7+
新增查询海外全部和海外国家维度的流量、pv、状态码方法
8+
涉及产品:AIHC
9+
增加查询训练任务列表、创建训练任务、查询训练任务详情、更新训练任务、停止训练任务、删除训练任务、查询训练任务事件、查询训练任务日志、查询训练任务Pod事件、查询训练任务监控、查询训练任务所在节点列表、获取训练任务WebTerminal地址的方法。
10+
涉及产品:HPAS
11+
增加创建实例、创建券、查询实例、查询券、查询镜像列表、关闭实例、启动实例、重启实例、改密实例、重装实例等操作的方法
312
【版本:v0.9.214】
413
涉及产品:AIHC
514
增加资源池列表，资源池详情，节点列表，队列列表和队列详情的方法
@@ -26,4 +35,4 @@
2635
涉及产品:CCE
2736
支持申请 CCE 集群临时授权
2837
涉及产品:BLB
29-
BLB支持计费变更、变配。HTTPS类型监听器支持扩展域名
38+
BLB支持计费变更、变配。HTTPS类型监听器支持扩展域名

‎bce/config.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,7 @@ import (
2626

2727
// Constants and default values for the package bce
2828
const (
29-
SDK_VERSION = "0.9.214"
29+
SDK_VERSION = "0.9.215"
3030
URI_PREFIX = "/" // now support uri without prefix "v1" so just set root path
3131
DEFAULT_DOMAIN = "baidubce.com"
3232
DEFAULT_PROTOCOL = "http"

‎doc/AIHC.md

+340
Original file line numberDiff line numberDiff line change
@@ -314,6 +314,346 @@ if err != nil {
314314
> 注意:
315315
> - 根据接口文档去填写具体的访问参数，接口链接为[队列详情](https://cloud.baidu.com/doc/AIHC/s/Hm569qc26)
316316
317+
## 训练
318+
### 查询训练任务列表
319+
使用以下代码可以查询训练任务列表。
320+
```go
321+
// import "github.com/baidubce/bce-sdk-go/services/aihc"
322+
// import "github.com/baidubce/bce-sdk-go/services/aihc/api/v1"
323+
ak, sk, endpoint := ak_test, sk_test, endpoint_test
324+
client, _ := aihc.NewClient(ak, sk, endpoint)
325+
req := &v1.OpenAPIJobListRequest{
326+
ResourcePoolID: RESOURCE_POOL_ID,
327+
PageNo: 1,
328+
PageSize: 3,
329+
}
330+
result, err := client.ListJobs(req)
331+
332+
if err != nil {
333+
panic(err)
334+
}
335+
jsonBytes, _ := json.Marshal(result)
336+
fmt.Println(string(jsonBytes))
337+
```
338+
339+
> 注意:
340+
> - 根据接口文档去填写具体的访问参数，接口链接为[查询训练任务列表](https://cloud.baidu.com/doc/AIHC/s/rm56ipjsz)
341+
342+
### 创建训练任务
343+
使用以下代码可以创建训练任务。
344+
```go
345+
// import "github.com/baidubce/bce-sdk-go/services/aihc"
346+
// import "github.com/baidubce/bce-sdk-go/services/aihc/api/v1"
347+
ak, sk, endpoint := ak_test, sk_test, endpoint_test
348+
resourcePoolID := RESOURCE_POOL_ID
349+
350+
jobConfig := &v1.OpenAPIJobCreateRequest{
351+
Name: AIJobName,
352+
JobSpec: v1.OpenAPIAIJobSpec{
353+
Command: `echo "hello sdk"; sleep infinity`,
354+
Replicas: 1,
355+
Image: ImageID,
356+
Resources: []v1.OpenAPIResource{
357+
{
358+
Name: "cpu",
359+
Quantity: 1,
360+
},
361+
},
362+
EnableRDMA: false,
363+
},
364+
EnableBccl: false,
365+
}
366+
client, _ := aihc.NewClient(ak, sk, endpoint)
367+
result, err := client.CreateJob(jobConfig, resourcePoolID)
368+
369+
if err != nil {
370+
panic(err)
371+
}
372+
373+
jsonBytes, _ := json.Marshal(result)
374+
fmt.Println(string(jsonBytes))
375+
```
376+
377+
> 注意:
378+
> - 根据接口文档去填写具体的访问参数，接口链接为[创建训练任务](https://cloud.baidu.com/doc/AIHC/s/jm56inxn7)
379+
380+
381+
### 查询训练任务详情
382+
使用以下代码可以查询训练任务详情。
383+
```go
384+
// import "github.com/baidubce/bce-sdk-go/services/aihc"
385+
// import "github.com/baidubce/bce-sdk-go/services/aihc/api/v1"
386+
ak, sk, endpoint := ak_test, sk_test, endpoint_test
387+
resourcePoolID, JobID := RESOURCE_POOL_ID, AIJobID
388+
389+
client, _ := aihc.NewClient(ak, sk, endpoint)
390+
result, err := client.GetJob(JobID, resourcePoolID)
391+
392+
if err != nil {
393+
panic(err)
394+
}
395+
396+
jsonBytes, _ := json.Marshal(result)
397+
fmt.Println(string(jsonBytes))
398+
```
399+
400+
> 注意:
401+
> - 根据接口文档去填写具体的访问参数，接口链接为[查询训练任务详情](https://cloud.baidu.com/doc/AIHC/s/Cm56ir6ui)
402+
403+
404+
### 更新训练任务
405+
使用以下代码可以更新训练任务。
406+
```go
407+
// import "github.com/baidubce/bce-sdk-go/services/aihc"
408+
// import "github.com/baidubce/bce-sdk-go/services/aihc/api/v1"
409+
ak, sk, endpoint := ak_test, sk_test, endpoint_test
410+
resourcePoolID := RESOURCE_POOL_ID
411+
jobID := AIJobID
412+
413+
jobConfig := &v1.OpenAPIJobUpdateRequest{
414+
Priority: "high",
415+
}
416+
client, _ := aihc.NewClient(ak, sk, endpoint)
417+
result, err := client.UpdateJob(jobConfig, jobID, resourcePoolID)
418+
419+
if err != nil {
420+
panic(err)
421+
}
422+
jsonBytes, _ := json.Marshal(result)
423+
fmt.Println(string(jsonBytes))
424+
```
425+
426+
> 注意:
427+
> - 根据接口文档去填写具体的访问参数，接口链接为[更新训练任务](https://cloud.baidu.com/doc/AIHC/s/um56issf8)
428+
429+
### 停止训练任务
430+
使用以下代码可以停止训练任务。
431+
```go
432+
// import "github.com/baidubce/bce-sdk-go/services/aihc"
433+
// import "github.com/baidubce/bce-sdk-go/services/aihc/api/v1"
434+
ak, sk, endpoint := ak_test, sk_test, endpoint_test
435+
resourcePoolID := RESOURCE_POOL_ID
436+
jobID := AIJobID
437+
438+
client, _ := aihc.NewClient(ak, sk, endpoint)
439+
result, err := client.StopJob(jobID, resourcePoolID)
440+
log.Infof("stop job result: %v", result)
441+
if err != nil {
442+
panic(err)
443+
}
444+
jsonBytes, _ := json.Marshal(result)
445+
fmt.Println(string(jsonBytes))
446+
```
447+
448+
> 注意:
449+
> - 根据接口文档去填写具体的访问参数，接口链接为[停止训练任务](https://cloud.baidu.com/doc/AIHC/s/hm56izyfa)
450+
451+
452+
453+
### 删除训练任务
454+
使用以下代码可以删除训练任务。
455+
```go
456+
// import "github.com/baidubce/bce-sdk-go/services/aihc"
457+
// import "github.com/baidubce/bce-sdk-go/services/aihc/api/v1"
458+
ak, sk, endpoint := ak_test, sk_test, endpoint_test
459+
resourcePoolID, JobID := RESOURCE_POOL_ID, AIJobID
460+
461+
client, _ := aihc.NewClient(ak, sk, endpoint)
462+
result, err := client.DeleteJob(JobID, resourcePoolID)
463+
464+
if err != nil {
465+
panic(err)
466+
}
467+
468+
jsonBytes, _ := json.Marshal(result)
469+
fmt.Println(string(jsonBytes))
470+
```
471+
472+
> 注意:
473+
> - 根据接口文档去填写具体的访问参数，接口链接为[删除训练任务](https://cloud.baidu.com/doc/AIHC/s/Sm56iuodq)
474+
475+
476+
477+
### 查询训练任务事件
478+
使用以下代码可以查询训练任务事件。
479+
```go
480+
// import "github.com/baidubce/bce-sdk-go/services/aihc"
481+
// import "github.com/baidubce/bce-sdk-go/services/aihc/api/v1"
482+
ak, sk, endpoint := ak_test, sk_test, endpoint_test
483+
484+
req := &v1.GetJobEventsRequest{
485+
Namespace: "",
486+
JobFramework: "PyTorchJob",
487+
StartTime: "",
488+
EndTime: "",
489+
JobID: AIJobID,
490+
ResourcePoolID: RESOURCE_POOL_ID,
491+
}
492+
493+
client, _ := aihc.NewClient(ak, sk, endpoint)
494+
result, err := client.GetTaskEvent(req)
495+
496+
if err != nil {
497+
panic(err)
498+
}
499+
jsonBytes, _ := json.Marshal(result)
500+
fmt.Println(string(jsonBytes))
501+
```
502+
503+
> 注意:
504+
> - 根据接口文档去填写具体的访问参数，接口链接为[查询训练任务事件](https://cloud.baidu.com/doc/AIHC/s/Km56iw5oj)
505+
506+
507+
### 查询训练任务日志
508+
使用以下代码可以查询训练任务日志。
509+
```go
510+
// import "github.com/baidubce/bce-sdk-go/services/aihc"
511+
// import "github.com/baidubce/bce-sdk-go/services/aihc/api/v1"
512+
ak, sk, endpoint := ak_test, sk_test, endpoint_test
513+
514+
req := &v1.GetPodLogsRequest{
515+
JobID: AIJobID,
516+
ResourcePoolID: RESOURCE_POOL_ID,
517+
PodName: PodName,
518+
Namespace: "default",
519+
StartTime: "",
520+
EndTime: "",
521+
MaxLines: "",
522+
Container: "",
523+
Chunk: "",
524+
}
525+
526+
client, _ := aihc.NewClient(ak, sk, endpoint)
527+
result, err := client.GetPodLogs(req)
528+
529+
if err != nil {
530+
panic(err)
531+
}
532+
jsonBytes, _ := json.Marshal(result)
533+
fmt.Println(string(jsonBytes))
534+
```
535+
536+
> 注意:
537+
> - 根据接口文档去填写具体的访问参数，接口链接为[查询训练任务日志](https://cloud.baidu.com/doc/AIHC/s/wm56ixjus)
538+
539+
540+
### 查询训练任务Pod事件
541+
使用以下代码可以查询训练任务Pod事件。
542+
```go
543+
// import "github.com/baidubce/bce-sdk-go/services/aihc"
544+
// import "github.com/baidubce/bce-sdk-go/services/aihc/api/v1"
545+
ak, sk, endpoint := ak_test, sk_test, endpoint_test
546+
req := &v1.GetPodEventsRequest{
547+
JobID: AIJobID,
548+
ResourcePoolID: RESOURCE_POOL_ID,
549+
Namespace: "",
550+
JobFramework: "PyTorchJob",
551+
StartTime: "",
552+
EndTime: "",
553+
PodName: PodName,
554+
}
555+
556+
client, _ := aihc.NewClient(ak, sk, endpoint)
557+
result, err := client.GetPodEvents(req)
558+
559+
if err != nil {
560+
panic(err)
561+
}
562+
jsonBytes, _ := json.Marshal(result)
563+
fmt.Println(string(jsonBytes))
564+
```
565+
566+
> 注意:
567+
> - 根据接口文档去填写具体的访问参数，接口链接为[查询训练任务Pod事件](https://cloud.baidu.com/doc/AIHC/s/vm56iypch)
568+
569+
570+
571+
### 查询训练任务监控
572+
使用以下代码可以查询训练任务监控。
573+
```go
574+
// import "github.com/baidubce/bce-sdk-go/services/aihc"
575+
// import "github.com/baidubce/bce-sdk-go/services/aihc/api/v1"
576+
ak, sk, endpoint := ak_test, sk_test, endpoint_test
577+
req := &v1.GetTaskMetricsRequest{
578+
StartTime: "",
579+
ResourcePoolID: RESOURCE_POOL_ID,
580+
EndTime: "",
581+
TimeStep: "",
582+
MetricType: MetricType,
583+
JobID: AIJobID,
584+
Namespace: "",
585+
RateInterval: "",
586+
}
587+
588+
client, _ := aihc.NewClient(ak, sk, endpoint)
589+
result, err := client.GetTaskMetrics(req)
590+
591+
if err != nil {
592+
panic(err)
593+
}
594+
jsonBytes, _ := json.Marshal(result)
595+
fmt.Println(string(jsonBytes))
596+
```
597+
598+
> 注意:
599+
> - 根据接口文档去填写具体的访问参数，接口链接为[查询训练任务监控](https://cloud.baidu.com/doc/AIHC/s/Um56j1bo8)
600+
601+
602+
### 查询训练任务所在节点列表
603+
使用以下代码可以查询训练任务所在节点列表。
604+
```go
605+
// import "github.com/baidubce/bce-sdk-go/services/aihc"
606+
// import "github.com/baidubce/bce-sdk-go/services/aihc/api/v1"
607+
ak, sk, endpoint := ak_test, sk_test, endpoint_test
608+
resourcePoolID := RESOURCE_POOL_ID
609+
jobID := AIJobID
610+
namespace := ""
611+
612+
client, _ := aihc.NewClient(ak, sk, endpoint)
613+
result, err := client.GetJobNodesList(jobID, resourcePoolID, namespace)
614+
615+
if err != nil {
616+
panic(err)
617+
}
618+
jsonBytes, _ := json.Marshal(result)
619+
fmt.Println(string(jsonBytes))
620+
```
621+
622+
> 注意:
623+
> - 根据接口文档去填写具体的访问参数，接口链接为[查询训练任务所在节点列表](https://cloud.baidu.com/doc/AIHC/s/Mm56j2j2c)
624+
625+
626+
627+
### 获取训练任务WebTerminal地址
628+
使用以下代码可以获取训练任务WebTerminal地址。
629+
```go
630+
// import "github.com/baidubce/bce-sdk-go/services/aihc"
631+
// import "github.com/baidubce/bce-sdk-go/services/aihc/api/v1"
632+
ak, sk, endpoint := ak_test, sk_test, endpoint_test
633+
634+
req := &v1.GetWebShellURLRequest{
635+
JobID: AIJobID,
636+
ResourcePoolID: RESOURCE_POOL_ID,
637+
PodName: PodName,
638+
Namespace: "",
639+
PingTimeoutSecond: "",
640+
HandshakeTimeoutSecond: "",
641+
}
642+
643+
client, _ := aihc.NewClient(ak, sk, endpoint)
644+
result, err := client.GetWebSSHUrl(req)
645+
646+
if err != nil {
647+
panic(err)
648+
}
649+
jsonBytes, _ := json.Marshal(result)
650+
fmt.Println(string(jsonBytes))
651+
```
652+
653+
> 注意:
654+
> - 根据接口文档去填写具体的访问参数，接口链接为[获取训练任务WebTerminal地址](https://cloud.baidu.com/doc/AIHC/s/Im56j3op4)
655+
656+
317657
## 自定义部署
318658
### 创建服务
319659
使用以下代码可以创建服务。

‎doc/BCC.md

+6
Original file line numberDiff line numberDiff line change
@@ -1480,6 +1480,12 @@ if err := bccClient.ResizeInstance(instanceId, resizeInstanceArgs); err != nil {
14801480
resizeInstanceArgs := &ResizeInstanceArgs{
14811481
// 实例套餐规格
14821482
Spec string "spec"
1483+
// 是否开启Jumbo帧，true开启，false不开启。
1484+
// 默认为空，为空时：
1485+
// 变配到不支持Jumbo帧的规格时，不开启Jumbo帧；
1486+
// 从不支持变配到支持的规格时，不开启Jumbo帧；
1487+
// 从支持到支持得规格是，若实例变配前开启Jumbo帧，变配后也开启Jumbo帧，若变配前不开启，则变配后也不开启。
1488+
EnableJumboFrame *bool enableJumboFrame,
14831489
}
14841490
// 设置你要操作的instanceId
14851491
instanceId := "your-choose-instance-id"

0 commit comments

Comments
 (0)