Menghapus kueri terjadwal

Menghapus konfigurasi untuk kueri terjadwal, sehingga akan menghentikan operasi pada masa mendatang.

Contoh kode

Go

Sebelum mencoba contoh ini, ikuti petunjuk penyiapan Go di Panduan memulai BigQuery menggunakan library klien. Untuk mengetahui informasi selengkapnya, lihat Dokumentasi referensi BigQuery Go API.

Untuk melakukan autentikasi ke BigQuery, siapkan Kredensial Default Aplikasi. Untuk mengetahui informasi selengkapnya, lihat Menyiapkan autentikasi untuk library klien.

import (
	"context"
	"fmt"

	datatransfer "cloud.google.com/go/bigquery/datatransfer/apiv1"
	datatransferpb "google.golang.org/genproto/googleapis/cloud/bigquery/datatransfer/v1"
)

// deleteScheduledQuery delete a scheduled query based on
// the config ID, stopping any future runs.
// transferConfigID follows the format:
//
//	`projects/{project_id}/locations/{location_id}/transferConfigs/{config_id}`
//	or `projects/{project_id}/transferConfigs/{config_id}`
func deleteScheduledQuery(transferConfigID string) error {
	// transferConfigID := "projects/{project_id}/transferConfigs/{config_id}"
	ctx := context.Background()
	dtc, err := datatransfer.NewClient(ctx)
	if err != nil {
		return fmt.Errorf("datatransfer.NewClient: %w", err)
	}
	defer dtc.Close()

	req := &datatransferpb.DeleteTransferConfigRequest{
		Name: transferConfigID,
	}
	err = dtc.DeleteTransferConfig(ctx, req)
	if err != nil {
		return fmt.Errorf("dtc.DeleteTransferConfig: %w", err)
	}

	return nil
}

Java

Sebelum mencoba contoh ini, ikuti petunjuk penyiapan Java di Panduan memulai BigQuery menggunakan library klien. Untuk mengetahui informasi selengkapnya, lihat Dokumentasi referensi BigQuery Java API.

Untuk melakukan autentikasi ke BigQuery, siapkan Kredensial Default Aplikasi. Untuk mengetahui informasi selengkapnya, lihat Menyiapkan autentikasi untuk library klien.

import com.google.api.gax.rpc.ApiException;
import com.google.cloud.bigquery.datatransfer.v1.DataTransferServiceClient;
import com.google.cloud.bigquery.datatransfer.v1.DeleteTransferConfigRequest;
import java.io.IOException;

// Sample to delete a scheduled query
public class DeleteScheduledQuery {

  public static void main(String[] args) throws IOException {
    // TODO(developer): Replace these variables before running the sample.
    // i.e projects/{project_id}/transferConfigs/{config_id}` or
    // `projects/{project_id}/locations/{location_id}/transferConfigs/{config_id}`
    String name = "MY_CONFIG_ID";
    deleteScheduledQuery(name);
  }

  public static void deleteScheduledQuery(String name) throws IOException {
    try (DataTransferServiceClient dataTransferServiceClient = DataTransferServiceClient.create()) {
      DeleteTransferConfigRequest request =
          DeleteTransferConfigRequest.newBuilder().setName(name).build();
      dataTransferServiceClient.deleteTransferConfig(request);
      System.out.print("Scheduled query deleted successfully.\n");
    } catch (ApiException ex) {
      System.out.print("Scheduled query was not deleted." + ex.toString());
    }
  }
}

Langkah selanjutnya

Untuk menelusuri dan memfilter contoh kode untuk produk Google Cloud lainnya, lihat browser contoh Google Cloud.