All Products
Search

This Product

    Object Storage Service:Menjeda pipa data (Go SDK V2)

    Document Center

    Object Storage Service:Menjeda pipa data (Go SDK V2)

    Last Updated:Jul 09, 2026

    Gunakan OSS Go SDK V2 untuk memanggil PauseDataPipeline guna menjeda aturan pipa data (DataPipeline) tertentu. Anda dapat menjeda aturan yang berada dalam status initializing atau running.

    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 lingkungan OSS_ACCESS_KEY_ID dan OSS_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.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)
}

    Referensi