暂停数据管道（Go SDK V2） - 对象存储 OSS

通过 OSS Go SDK V2 调用 PauseDataPipeline 暂停指定的数据管道（DataPipeline）规则。可暂停处于初始化或运行中状态下的规则。

前提条件

已安装 OSS Go SDK V2，可通过 go get github.com/aliyun/alibabacloud-oss-go-sdk-v2 获取。
已通过环境变量配置访问凭证。本文示例使用 credentials.NewEnvironmentVariableCredentialsProvider() 从环境变量 OSS_ACCESS_KEY_ID 和 OSS_ACCESS_KEY_SECRET 读取凭证。

示例代码

package main

import (
	"context"
	"log"
	"github.com/aliyun/alibabacloud-oss-go-sdk-v2/oss"
	"github.com/aliyun/alibabacloud-oss-go-sdk-v2/oss/credentials"
	"github.com/aliyun/alibabacloud-oss-go-sdk-v2/oss/dataprocess"
)

func main() {
	region := "cn-hangzhou"
	dataPipelineName := "my-data-pipeline"

	cfg := oss.LoadDefaultConfig().
		WithCredentialsProvider(credentials.NewEnvironmentVariableCredentialsProvider()).
		WithRegion(region)

	client := dataprocess.NewClient(cfg)

	result, err := client.PauseDataPipeline(context.TODO(), &dataprocess.PauseDataPipelineRequest{
		DataPipelineName: oss.Ptr(dataPipelineName),
	})

	if err != nil {
		log.Fatalf("failed to pause pipeline %v", err)
	}
	log.Printf("pause pipeline result:%#v\n", result)
}

对象存储 OSS：暂停数据管道（Go SDK V2）

前提条件

示例代码

相关文档