通过 OSS Go SDK V2 调用 DeleteDataPipelineConfiguration 删除指定的数据管道(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.DeleteDataPipelineConfiguration(context.TODO(), &dataprocess.DeleteDataPipelineConfigurationRequest{
DataPipelineName: oss.Ptr(dataPipelineName),
})
if err != nil {
log.Fatalf("failed to delete pipeline configuration %v", err)
}
log.Printf("delete pipeline configuration result:%#v\n", result)
}
相关文档
完整示例代码,请参见 delete_data_pipeline_configuration.go。