Membuat topik

Dalam Pub/Sub, topik adalah resource bernama yang mewakili feed pesan. Anda harus membuat topik sebelum dapat memublikasikan atau berlangganan ke topik tersebut. Pub/Sub mendukung dua jenis topik: topik standar dan topik impor.

Dokumen ini menjelaskan cara membuat topik standar Pub/Sub. Jika Anda ingin mempelajari lebih lanjut topik impor dan cara membuatnya, lihat Tentang topik impor.

Untuk membuat topik, Anda dapat menggunakan Trusted Cloud konsol, Google Cloud CLI, library klien, atau Pub/Sub API.

Sebelum memulai

• Pelajari layanan Pub/Sub dan terminologinya.

• Pelajari proses publikasi.

Peran dan izin yang diperlukan

Untuk mendapatkan izin yang diperlukan guna membuat topik, minta administrator Anda untuk memberi Anda peran IAM Pub/Sub Editor(roles/pubsub.editor) di project Anda. Untuk mengetahui informasi selengkapnya tentang cara memberikan peran, lihat Mengelola akses ke project, folder, dan organisasi.

Peran bawaan ini berisi izin yang diperlukan untuk membuat topik. Untuk melihat izin yang benar-benar diperlukan, luaskan bagian Izin yang diperlukan:

Anda mungkin juga bisa mendapatkan izin ini dengan peran khusus atau peran bawaan lainnya.

Anda dapat mengonfigurasi kontrol akses di tingkat project dan di tingkat resource individual. Anda dapat membuat langganan dalam satu project dan melampirkannya ke topik yang berada dalam project lain. Pastikan Anda memiliki izin yang diperlukan untuk setiap project.

Properti topik

Saat membuat atau memperbarui topik, Anda harus menentukan propertinya.

Tambahkan langganan default

Menambahkan langganan default ke topik Pub/Sub. Anda dapat membuat langganan lain untuk topik setelah topik dibuat. Langganan default memiliki properti berikut:

• ID langganan -sub
• Jenis pengiriman pull
• Durasi retensi pesan selama tujuh hari
• Berakhir setelah tidak aktif selama 31 hari
• Batas waktu konfirmasi 10 detik
• Kebijakan percobaan ulang langsung

Mengaktifkan penyerapan

Dengan mengaktifkan properti ini, Anda dapat menyerap data streaming dari sumber eksternal ke dalam topik sehingga Anda dapat menggunakan fitur Trusted Cloud. Untuk membuat topik impor untuk penyerapan, lihat bagian berikut:

• Membuat topik impor Amazon Kinesis Data Streams

• Membuat topik impor Cloud Storage

• Membuat topik Azure Event Hubs

• Membuat topik Amazon MSK

• Buat topik Confluent Cloud

Mengaktifkan retensi pesan

Menentukan berapa lama topik Pub/Sub menyimpan pesan setelah dipublikasikan. Setelah durasi retensi pesan berakhir, Pub/Sub dapat menghapus pesan terlepas dari status pengakuannya. Biaya penyimpanan pesan dikenakan untuk penyimpanan semua pesan yang dipublikasikan ke topik

• Default = Tidak diaktifkan
• Nilai minimum = 10 menit
• Nilai maksimum = 31 hari

Mengekspor data pesan ke BigQuery

Dengan mengaktifkan properti ini, Anda dapat membuat langganan BigQuery yang menulis pesan ke tabel BigQuery yang ada saat pesan diterima. Anda tidak perlu mengonfigurasi klien pelanggan terpisah. Untuk mengetahui informasi selengkapnya tentang langganan BigQuery, lihat Langganan BigQuery.

Mencadangkan data pesan ke Cloud Storage

Dengan mengaktifkan properti ini, Anda dapat membuat langganan Cloud Storage yang menulis pesan ke tabel Cloud Storage yang sudah ada saat pesan diterima. Anda tidak perlu mengonfigurasi klien pelanggan terpisah. Untuk mengetahui informasi selengkapnya tentang langganan Cloud Storage, lihat Langganan Cloud Storage.

Transformasi

SMT topik memungkinkan modifikasi ringan pada data dan atribut pesan secara langsung dalam Pub/Sub. Fitur ini memungkinkan pembersihan data, pemfilteran, atau konversi format sebelum pesan dipublikasikan ke topik.

Untuk mengetahui informasi selengkapnya tentang SMT, lihat Ringkasan SMT.

Google Cloud-powered encryption key

Menentukan bahwa topik dienkripsi menggunakan Google Cloud-powered encryption keys. Pub/Sub mengenkripsi pesan dengan Google Cloud-powered encryption keys secara default, jadi memilih opsi ini akan mempertahankan perilaku default. Google menangani pengelolaan dan rotasi kunci secara otomatis, sehingga memastikan pesan Anda selalu dilindungi dengan enkripsi terkuat yang tersedia. Opsi ini tidak memerlukan konfigurasi lebih lanjut. Untuk mengetahui informasi selengkapnya tentang Google Cloud-powered encryption keys, lihat Enkripsi default dengan Google Cloud-powered encryption keys.

Kunci Cloud KMS

Menentukan apakah topik dienkripsi dengan kunci enkripsi yang dikelola pelanggan (CMEK). Pub/Sub mengenkripsi pesan dengan Google Cloud-powered encryption keys secara default. Jika Anda menentukan opsi ini, Pub/Sub akan menggunakan pola enkripsi amplop dengan CMEK. Dalam pendekatan ini, Cloud KMS tidak mengenkripsi pesan. Sebagai gantinya, Cloud KMS mengenkripsi Kunci Enkripsi Data (DEK) yang dibuat Pub/Sub untuk setiap topik. Pub/Sub mengenkripsi pesan menggunakan DEK terbaru yang dibuat untuk topik. Pub/Sub mendekripsi pesan sesaat sebelum dikirim ke pelanggan. Untuk mengetahui informasi selengkapnya tentang cara membuat kunci, lihat Mengonfigurasi enkripsi pesan.

Membuat topik

Buat topik sebelum Anda dapat memublikasikan atau berlangganan ke topik tersebut.

gcloud pubsub topics create TOPIC_ID

PUT https://pubsub.googleapis.com/v1/projects/PROJECT_ID/topics/TOPIC_ID
Authorization: Bearer ACCESS_TOKEN

{
"name": "projects/PROJECT_ID/topics/TOPIC_ID"
}

namespace pubsub = ::google::cloud::pubsub;
namespace pubsub_admin = ::google::cloud::pubsub_admin;
[](pubsub_admin::TopicAdminClient client, std::string project_id,
   std::string topic_id) {
  auto topic = client.CreateTopic(
      pubsub::Topic(std::move(project_id), std::move(topic_id)).FullName());
  // Note that kAlreadyExists is a possible error when the library retries.
  if (topic.status().code() == google::cloud::StatusCode::kAlreadyExists) {
    std::cout << "The topic already exists\n";
    return;
  }
  if (!topic) throw std::move(topic).status();

  std::cout << "The topic was successfully created: " << topic->DebugString()
            << "\n";
}

using Google.Cloud.PubSub.V1;
using Grpc.Core;
using System;

public class CreateTopicSample
{
    public Topic CreateTopic(string projectId, string topicId)
    {
        PublisherServiceApiClient publisher = PublisherServiceApiClient.Create();
        var topicName = TopicName.FromProjectTopic(projectId, topicId);
        Topic topic = null;

        try
        {
            topic = publisher.CreateTopic(topicName);
            Console.WriteLine($"Topic {topic.Name} created.");
        }
        catch (RpcException e) when (e.Status.StatusCode == StatusCode.AlreadyExists)
        {
            Console.WriteLine($"Topic {topicName} already exists.");
        }
        return topic;
    }
}

import (
	"context"
	"fmt"
	"io"

	"cloud.google.com/go/pubsub/v2"
	"cloud.google.com/go/pubsub/v2/apiv1/pubsubpb"
)

func create(w io.Writer, projectID, topicID string) error {
	// projectID := "my-project-id"
	// topicID := "my-topic"
	ctx := context.Background()
	client, err := pubsub.NewClient(ctx, projectID)
	if err != nil {
		return fmt.Errorf("pubsub.NewClient: %w", err)
	}
	defer client.Close()

	topic := &pubsubpb.Topic{
		Name: fmt.Sprintf("projects/%s/topics/%s", projectID, topicID),
	}
	t, err := client.TopicAdminClient.CreateTopic(ctx, topic)
	if err != nil {
		return fmt.Errorf("CreateTopic: %w", err)
	}
	fmt.Fprintf(w, "Topic created: %v\n", t)
	return nil
}

import com.google.cloud.pubsub.v1.TopicAdminClient;
import com.google.pubsub.v1.Topic;
import com.google.pubsub.v1.TopicName;
import java.io.IOException;

public class CreateTopicExample {
  public static void main(String... args) throws Exception {
    // TODO(developer): Replace these variables before running the sample.
    String projectId = "your-project-id";
    String topicId = "your-topic-id";

    createTopicExample(projectId, topicId);
  }

  public static void createTopicExample(String projectId, String topicId) throws IOException {
    try (TopicAdminClient topicAdminClient = TopicAdminClient.create()) {
      TopicName topicName = TopicName.of(projectId, topicId);
      Topic topic = topicAdminClient.createTopic(topicName);
      System.out.println("Created topic: " + topic.getName());
    }
  }
}

/**
 * TODO(developer): Uncomment this variable before running the sample.
 */
// const topicNameOrId = 'YOUR_TOPIC_NAME_OR_ID';

// Imports the Google Cloud client library
const {PubSub} = require('@google-cloud/pubsub');

// Creates a client; cache this for further use
const pubSubClient = new PubSub();

async function createTopic(topicNameOrId) {
  // Creates a new topic
  await pubSubClient.createTopic(topicNameOrId);
  console.log(`Topic ${topicNameOrId} created.`);
}

/**
 * TODO(developer): Uncomment this variable before running the sample.
 */
// const topicNameOrId = 'YOUR_TOPIC_NAME_OR_ID';

// Imports the Google Cloud client library
import {PubSub} from '@google-cloud/pubsub';

// Creates a client; cache this for further use
const pubSubClient = new PubSub();

async function createTopic(topicNameOrId: string) {
  // Creates a new topic
  await pubSubClient.createTopic(topicNameOrId);
  console.log(`Topic ${topicNameOrId} created.`);
}

use Google\Cloud\PubSub\PubSubClient;

/**
 * Creates a Pub/Sub topic.
 *
 * @param string $projectId  The Google project ID.
 * @param string $topicName  The Pub/Sub topic name.
 */
function create_topic($projectId, $topicName)
{
    $pubsub = new PubSubClient([
        'projectId' => $projectId,
    ]);
    $topic = $pubsub->createTopic($topicName);

    printf('Topic created: %s' . PHP_EOL, $topic->name());
}

from google.cloud import pubsub_v1

# TODO(developer)
# project_id = "your-project-id"
# topic_id = "your-topic-id"

publisher = pubsub_v1.PublisherClient()
topic_path = publisher.topic_path(project_id, topic_id)

topic = publisher.create_topic(request={"name": topic_path})

print(f"Created topic: {topic.name}")

# topic_id = "your-topic-id"

pubsub = Google::Cloud::PubSub.new
topic_admin = pubsub.topic_admin

topic = topic_admin.create_topic name: pubsub.topic_path(topic_id)

puts "Topic #{topic.name} created."

Langkah berikutnya

• Pilih jenis langganan untuk topik Anda.

• Pelajari cara memublikasikan pesan ke topik.

• Pecahkan masalah topik.

• Buat atau ubah topik dengan gcloud CLI, REST API, atau Library klien.