Panggil DeleteDataPipelineConfiguration menggunakan OSS Go SDK V2 untuk menghapus aturan pipa data (DataPipeline) tertentu. Anda dapat menghapus aturan yang berada dalam status initializing, paused, atau failed.
Prasyarat
OSS Go SDK V2 telah diinstal. Anda dapat menginstalnya dengan menjalankan
go get github.com/aliyun/alibabacloud-oss-go-sdk-v2.Kredensial akses dikonfigurasi melalui variabel lingkungan. Contoh dalam topik ini menggunakan
credentials.NewEnvironmentVariableCredentialsProvider()untuk membaca kredensial dari variabel lingkunganOSS_ACCESS_KEY_IDdanOSS_ACCESS_KEY_SECRET.
Kode contoh
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)
}
Referensi
Untuk kode contoh lengkap, lihat delete_data_pipeline_configuration.go.