Membuat topik impor Azure Event Hubs

Topik impor Azure Event Hubs memungkinkan Anda terus-menerus menyerap data dari Azure Event Hubs sebagai sumber eksternal dan ke Pub/Sub. Kemudian, Anda dapat melakukan streaming data ke tujuan mana pun yang didukung Pub/Sub.

Dokumen ini menunjukkan cara membuat dan mengelola topik impor Azure Event Hubs. Untuk membuat topik standar, lihat Membuat topik standar.

Untuk mengetahui informasi selengkapnya tentang topik impor, lihat Tentang topik impor.

Sebelum memulai

• Ketahui lebih lanjut proses penerbitan Pub/Sub.

• Konfigurasi peran dan izin yang diperlukan untuk mengelola topik impor Azure Event Hubs, termasuk yang berikut:

  • Tambahkan peran Pub/Sub Publisher ke akun layanan Pub/Sub

  • Tambahkan peran agen layanan Pub/Sub ke akun layanan Pub/Sub, jika belum diberikan.

  • Menambahkan peran pengguna akun layanan ke akun layanan

• Siapkan workload identity federation agar Trusted Cloud dapat mengakses layanan streaming eksternal.

Peran dan izin yang diperlukan

Untuk mendapatkan izin yang Anda perlukan guna membuat dan mengelola topik impor Azure Event Hubs, minta administrator untuk memberi Anda peran IAM Pub/Sub Editor (roles/pubsub.editor) di topik atau 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 dan mengelola topik impor Azure Event Hubs. Untuk melihat izin yang benar-benar diperlukan, luaskan bagian Izin yang diperlukan:

Izin yang diperlukan

Izin berikut diperlukan untuk membuat dan mengelola topik impor Azure Event Hubs:

• Buat topik impor: pubsub.topics.create
• Menghapus topik impor: pubsub.topics.delete
• Dapatkan topik impor: pubsub.topics.get
• Cantumkan topik impor: pubsub.topics.list
• Memublikasikan ke topik impor: pubsub.topics.publish and pubsub.serviceAgent
• Perbarui topik impor: pubsub.topics.update
• Dapatkan kebijakan IAM untuk topik impor: pubsub.topics.getIamPolicy
• Konfigurasi kebijakan IAM untuk topik impor: pubsub.topics.setIamPolicy

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

Anda dapat mengonfigurasi kontrol akses di level project dan level resource individual.

Menyiapkan identitas gabungan untuk mengakses Azure Event Hubs

Workload Identity Federation memungkinkan Trusted Cloud layanan mengakses beban kerja yang berjalan di luar Trusted Cloud. Dengan federasi identitas, Anda tidak perlu memelihara atau meneruskan kredensial ke Trusted Cloud untuk mengakses resource Anda di cloud lain. Sebagai gantinya, Anda dapat menggunakan identitas workload itu sendiri untuk melakukan autentikasi ke Trusted Cloud dan mengakses resource.

Buat akun layanan di Trusted Cloud

Ini langkah opsional. Jika sudah memiliki akun layanan, Anda dapat menggunakannya dalam prosedur ini, bukan membuat akun layanan baru. Jika Anda menggunakan akun layanan yang sudah ada, buka Mencatat ID unik akun layanan untuk langkah berikutnya.

Untuk topik impor Azure Event Hubs, Pub/Sub menggunakan akun layanan sebagai identitas untuk mengakses resource dari Azure.

Untuk mengetahui informasi selengkapnya tentang cara membuat akun layanan, termasuk prasyarat, peran dan izin yang diperlukan, serta panduan penamaan, lihat Membuat akun layanan. Setelah membuat akun layanan, Anda mungkin perlu menunggu selama 60 detik atau lebih sebelum menggunakan akun layanan tersebut. Perilaku ini terjadi karena operasi baca pada akhirnya konsisten; perlu waktu hingga akun layanan baru terlihat.

Mencatat ID unik akun layanan

Anda memerlukan ID unik akun layanan untuk menyiapkan Pendaftaran aplikasi di Azure.

1. Di konsol Trusted Cloud , buka halaman detail Service account.

   Buka akun layanan

2. Klik akun layanan yang baru saja Anda buat atau yang akan Anda gunakan.

3. Dari halaman Service account details, catat nomor ID Unik.

   Anda memerlukan ID sebagai bagian dari alur kerja untuk menyiapkan Pendaftaran aplikasi di Azure.

Tambahkan peran pembuat token akun layanan ke akun layanan Pub/Sub

Peran pembuat token akun layanan (roles/iam.serviceAccountTokenCreator) memungkinkan akun utama membuat kredensial berumur pendek untuk akun layanan. Token atau kredensial ini digunakan untuk meniru identitas akun layanan.

Untuk informasi selengkapnya tentang peniruan akun layanan, lihat Peniruan akun layanan.

Anda juga dapat menambahkan peran penerbit Pub/Sub (roles/pubsub.publisher) selama prosedur ini. Untuk mengetahui informasi selengkapnya tentang peran dan alasan Anda menambahkannya, lihat Menambahkan peran Pub/Sub Publisher ke akun layanan Pub/Sub.

1. Di konsol Trusted Cloud , buka halaman IAM.

   Buka IAM

2. Centang kotak Include S3NS-provided role grants.

3. Cari akun layanan yang memiliki format service-{PROJECT_NUMBER}@gcp-sa-pubsub.s3ns-system.iam.gserviceaccount.com.

4. Untuk akun layanan ini, klik tombol Edit Principal.

5. Jika diperlukan, klik Tambahkan peran lain.

6. Cari dan klik Service account token creator role (roles/iam.serviceAccountTokenCreator).

7. Klik Simpan.

Membuat Pendaftaran aplikasi dengan federasi identitas

Untuk menyerap data dari Azure Event Hubs, daftarkan aplikasi dengan platform Identitas Microsoft dan aktifkan federasi identitas untuk akun layanan Anda. Tindakan ini memungkinkan akun layanan Anda melakukan autentikasi ke Azure.

Untuk mengetahui informasi selengkapnya tentang cara mendaftarkan aplikasi dengan platform Identitas Microsoft, lihat mulai cepat pendaftaran aplikasi Azure.

1. Login ke portal Azure dan buka halaman Microsoft Entra ID.

2. Di panel navigasi, klik Kelola > Pendaftaran aplikasi.

3. Klik New registration.

4. Beri nama aplikasi dan tetapkan Jenis akun yang didukung ke selain Khusus akun Microsoft pribadi.

5. Untuk mendaftarkan aplikasi, klik Daftar.

6. Buka aplikasi, lalu klik Manage > Certificates & Secrets.

7. Klik Tambahkan kredensial.

8. Untuk mengonfigurasi kredensial gabungan, klik Penerbit lain.

9. Untuk kolom Issuer, masukkan https://accounts.google.com.

10. Untuk kolom Value, masukkan ID unik akun layanan Pub/Sub Anda.

    Anda dapat menemukan ID ini di Mencatat ID unik akun layanan.

11. Beri nama identitas gabungan, lalu klik Tambahkan.

Memberikan penetapan peran ke Aplikasi terdaftar

Untuk mengizinkan Pub/Sub membaca dari hub peristiwa Azure Anda, berikan peran yang diperlukan ke aplikasi terdaftar Anda.

1. Login ke portal Azure dan buka namespace Event Hubs Anda.

   Untuk membuka namespace, masukkan Event Hubs dalam penelusuran, lalu klik salah satu namespace.

2. Di sidebar, klik Access control (IAM).

3. Klik Tambahkan > Tambahkan penetapan peran.

4. Pilih peran Azure Event Hubs Data Receiver, lalu klik Berikutnya.

   Tindakan ini akan memberi akun layanan Pub/Sub akses baca ke hub peristiwa Azure Anda.

5. Klik +Pilih anggota, lalu telusuri aplikasi terdaftar Anda.

6. Ketik nama aplikasi terdaftar di kolom penelusuran.

7. Klik nama aplikasi Anda, lalu klik Pilih.

8. Klik Tinjau + Tetapkan.

9. Ulangi langkah 3–6 dan tambahkan peran Pengirim Data Azure Event Hubs.

   Peran ini memberikan izin Akun Layanan Google Cloud untuk mengambil metadata dari hub peristiwa Azure Anda.

Untuk mengetahui informasi selengkapnya tentang cara menetapkan peran Azure, buka halaman Menetapkan peran Azure.

Tambahkan peran penerbit Pub/Sub ke akun utama Pub/Sub

Untuk mengaktifkan publikasi, Anda harus menetapkan peran publisher ke akun layanan Pub/Sub agar Pub/Sub dapat memublikasikan ke topik impor Azure Event Hubs.

Menambahkan peran agen layanan Pub/Sub ke akun layanan Pub/Sub

Agar Pub/Sub dapat menggunakan kuota publikasi project topik impor Anda, agen layanan Pub/Sub memerlukan izin serviceusage.services.use di project topik impor Anda.

Untuk memberikan izin ini, sebaiknya tambahkan peran agen layanan Pub/Sub ke akun layanan Pub/Sub.

Jika akun layanan Pub/Sub tidak memiliki peran agen layanan Pub/Sub, peran tersebut dapat diberikan sebagai berikut:

1. Di konsol Trusted Cloud , buka halaman IAM.

   Buka IAM

2. Centang kotak Include S3NS-provided role grants.

3. Cari akun layanan yang memiliki format service-{PROJECT_NUMBER}@gcp-sa-pubsub.s3ns-system.iam.gserviceaccount.com.

4. Untuk akun layanan ini, klik tombol Edit principal.

5. Jika diperlukan, klik Tambahkan peran lain.

6. Cari dan klik peran Pub/Sub Service Agent (roles/pubsub.serviceAgent).

7. Klik Simpan.

Mengaktifkan publikasi dari semua topik

Gunakan metode ini jika Anda belum membuat topik impor Azure Event Hubs.

1. Di konsol Trusted Cloud , buka halaman IAM.

   Buka IAM

2. Centang kotak Include S3NS-provided role grants.

3. Cari akun layanan yang memiliki format service-{PROJECT_NUMBER}@gcp-sa-pubsub.s3ns-system.iam.gserviceaccount.com.

4. Untuk akun layanan ini, klik tombol Edit principal.

5. Jika diperlukan, klik Tambahkan peran lain.

6. Cari dan klik Pub/Sub publisher role (roles/pubsub.publisher).

7. Klik Simpan.

Mengaktifkan publikasi dari satu topik

Gunakan metode ini hanya jika topik impor Azure Event Hubs sudah ada.

1. In the Trusted Cloud console, activate Cloud Shell.

   Activate Cloud Shell

   At the bottom of the Trusted Cloud console, a Cloud Shell session starts and displays a command-line prompt. Cloud Shell is a shell environment with the Google Cloud CLI already installed and with values already set for your current project. It can take a few seconds for the session to initialize.

2. Jalankan perintah gcloud pubsub topics add-iam-policy-binding:

   gcloud pubsub topics add-iam-policy-binding TOPIC_ID \
      --member="serviceAccount:service-PROJECT_NUMBER@gcp-sa-pubsub.s3ns-system.iam.gserviceaccount.com" \
      --role="roles/pubsub.publisher"

   Ganti kode berikut:

   • TOPIC_ID: ID topik dari topik impor Azure Event Hubs.

   • PROJECT_NUMBER: nomor project. Untuk melihat nomor project, lihat Mengidentifikasi project.

Menambahkan peran pengguna akun layanan ke akun layanan

Peran Pengguna Akun Layanan (roles/iam.serviceAccountUser) mencakup izin iam.serviceAccounts.actAs yang memungkinkan akun utama melampirkan akun layanan ke setelan penyerapan topik impor Azure Event Hubs dan menggunakan akun layanan tersebut untuk identitas gabungan.

1. Di konsol Trusted Cloud , buka halaman IAM.

   Buka IAM

2. Untuk akun utama yang mengeluarkan panggilan buat atau perbarui topik, klik tombol Edit akun utama.

3. Jika diperlukan, klik Tambahkan peran lain.

4. Cari dan klik Service account user role (roles/iam.serviceAccountUser).

5. Klik Simpan.

Menggunakan topik impor Azure Event Hubs

Anda dapat membuat topik impor baru atau mengedit topik yang ada.

Pertimbangan

• Membuat topik dan langganan secara terpisah, meskipun dilakukan secara berurutan dengan cepat, dapat menyebabkan hilangnya data. Ada jendela singkat tempat topik tersedia tanpa langganan. Jika ada data yang dikirim ke topik selama waktu ini, data tersebut akan hilang. Dengan membuat topik terlebih dahulu, membuat langganan, lalu mengonversi topik menjadi topik impor, Anda menjamin bahwa tidak ada pesan yang terlewat selama proses impor.

• Jika perlu membuat ulang hub peristiwa Azure dari topik impor yang ada dengan nama yang sama, Anda tidak dapat hanya menghapus hub peristiwa Azure dan membuatnya ulang. Tindakan ini dapat membatalkan pengelolaan offset Pub/Sub, yang dapat menyebabkan kehilangan data. Untuk memitigasi hal ini, ikuti langkah-langkah berikut:

  • Menghapus topik impor Pub/Sub
  • Menghapus hub peristiwa Azure
  • Buat hub peristiwa Azure
  • Buat topik impor Pub/Sub

• Data dari hub peristiwa Azure selalu dibaca dari offset paling awal.

Membuat topik impor Azure Event Hubs

Untuk mengetahui lebih lanjut properti yang terkait dengan topik, lihat Properti topik.

Pastikan Anda telah menyelesaikan prosedur berikut:

• Menyiapkan identitas gabungan untuk mengakses Azure Event Hubs

• Tambahkan peran Pub/Sub Publisher ke akun layanan Pub/Sub

• Menambahkan peran pengguna akun layanan ke akun utama IAM

Untuk membuat topik impor Azure Event Hubs, ikuti langkah-langkah berikut:

Konsol

1. Di konsol Trusted Cloud , buka halaman Topics.

   Buka Topik

2. Klik Create topic.

3. Di kolom Topic ID, masukkan ID untuk topik impor Azure Event Hubs Anda. Untuk mengetahui informasi selengkapnya tentang penamaan topik, lihat panduan penamaan.

4. Pilih Tambahkan langganan default.

5. Pilih Aktifkan penyerapan.

6. Untuk sumber penyerapan, pilih Azure Event Hubs.

7. Masukkan detail berikut:

   • Grup resource: nama Grup Resource Azure yang berisi namespace Azure Event Hubs yang akan Anda masukkan ke Pub/Sub.
   • Namespace Event Hub: nama namespace Azure Event Hubs yang berisi hub peristiwa Azure yang akan Anda rencanakan untuk di-ingest ke Pub/Sub.
   • Event Hub: nama Azure Event Hub yang akan Anda ingest ke Pub/Sub.
   • Client ID: ID aplikasi (klien) dari Aplikasi terdaftar di Azure yang berisi identitas gabungan Akun Layanan Google Cloud. Nilai ini harus berupa UUID. Untuk mengetahui informasi selengkapnya, buka halaman Pendaftaran Aplikasi Azure.
   • Tenant ID: ID direktori (tenant) dari tenant yang memiliki Azure Event Hub yang akan Anda masukkan ke Pub/Sub. Nilai ini harus berupa UUID. Untuk menemukan ID tenant Anda, buka halaman Azure Get subscription and tenant IDs.
   • ID Langganan: ID langganan yang memiliki grup resource Azure Event Hubs. Nilai ini harus berupa UUID. Untuk menemukan ID langganan Anda, buka halaman Azure Get subscription and tenant IDs.
   • Akun layanan: akun layanan yang Anda buat di Membuat akun layanan di Trusted Cloud.

8. Biarkan kolom lainnya dengan nilai default.

9. Klik Create topic.

gcloud

1. In the Trusted Cloud console, activate Cloud Shell.

   Activate Cloud Shell

   At the bottom of the Trusted Cloud console, a Cloud Shell session starts and displays a command-line prompt. Cloud Shell is a shell environment with the Google Cloud CLI already installed and with values already set for your current project. It can take a few seconds for the session to initialize.

2. Jalankan perintah gcloud pubsub topics create:

     gcloud pubsub topics create TOPIC_ID \
         --azure-event-hubs-ingestion-resource-group RESOURCE_GROUP \
         --azure-event-hubs-ingestion-namespace NAMESPACE \
         --azure-event-hubs-ingestion-event-hub EVENT_HUB \
         --azure-event-hubs-ingestion-client-id CLIENT_ID \
         --azure-event-hubs-ingestion-tenant-id TENANT_ID \
         --azure-event-hubs-ingestion-subscription-id SUBSCRIPTION_ID \
         --azure-event-hubs-ingestion-service-account SERVICE_ACCOUNT
   

   Ganti kode berikut:

   • TOPIC_ID: nama atau ID topik Pub/Sub Anda.
   • RESOURCE_GROUP: nama grup resource Azure Event Hubs yang berisi namespace Azure Event Hubs yang akan Anda masukkan ke Pub/Sub.
   • NAMESPACE: nama namespace Azure Event Hubs yang berisi hub peristiwa Azure yang akan Anda masukkan ke Pub/Sub.
   • EVENT_HUB: nama Azure event hub yang akan Anda masukkan ke Pub/Sub.
   • CLIENT_ID: ID aplikasi (klien) dari Aplikasi terdaftar di Azure yang berisi identitas gabungan Trusted Cloud Akun Layanan. Nilai ini harus berupa UUID. Untuk informasi selengkapnya, buka halaman Pendaftaran Aplikasi Azure.
   • TENANT_ID: ID direktori (tenant) tenant yang memiliki hub peristiwa Azure yang akan Anda masukkan ke Pub/Sub. Nilai ini harus berupa UUID. Untuk menemukan ID tenant Anda, buka halaman Azure Get subscription and tenant IDs page.
   • SUBSCRIPTION_ID: ID langganan langganan yang memiliki hub peristiwa Azure yang akan Anda masukkan ke Pub/Sub. Nilai ini harus berupa UUID. Untuk menemukan ID langganan Anda, buka halaman Azure Get subscription and tenant IDs.
   • SERVICE_ACCOUNT: akun layanan yang Anda buat di Membuat akun layanan di Trusted Cloud

C++

Sebelum mencoba contoh ini, ikuti petunjuk penyiapan C++ di Panduan memulai: Menggunakan Library Klien. Untuk mengetahui informasi selengkapnya, lihat dokumentasi referensi Pub/Sub C++ API.

namespace pubsub = ::google::cloud::pubsub;
namespace pubsub_admin = ::google::cloud::pubsub_admin;
[](pubsub_admin::TopicAdminClient client, std::string project_id,
   std::string topic_id, std::string const& resource_group,
   std::string const& event_hubs_namespace, std::string const& event_hub,
   std::string const& client_id, std::string const& tenant_id,
   std::string const& subscription_id,
   std::string const& gcp_service_account) {
  google::pubsub::v1::Topic request;
  request.set_name(
      pubsub::Topic(std::move(project_id), std::move(topic_id)).FullName());
  auto* azure_event_hubs = request.mutable_ingestion_data_source_settings()
                               ->mutable_azure_event_hubs();
  azure_event_hubs->set_resource_group(resource_group);
  azure_event_hubs->set_namespace_(event_hubs_namespace);
  azure_event_hubs->set_event_hub(event_hub);
  azure_event_hubs->set_client_id(client_id);
  azure_event_hubs->set_tenant_id(tenant_id);
  azure_event_hubs->set_subscription_id(subscription_id);
  azure_event_hubs->set_gcp_service_account(gcp_service_account);

  auto topic = client.CreateTopic(request);
  // 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";
}

Go

Contoh berikut menggunakan library klien Go Pub/Sub versi utama (v2). Jika Anda masih menggunakan library v1, lihat panduan migrasi ke v2. Untuk melihat daftar contoh kode v1, lihat contoh kode yang tidak digunakan lagi.

Sebelum mencoba contoh ini, ikuti petunjuk penyiapan Go di Panduan memulai: Menggunakan Library Klien. Untuk mengetahui informasi selengkapnya, lihat dokumentasi referensi Pub/Sub Go API.

import (
	"context"
	"fmt"
	"io"

	"cloud.google.com/go/pubsub"
)

func createTopicWithAzureEventHubsIngestion(w io.Writer, projectID, topicID, resourceGroup, namespace, eventHub, clientID, tenantID, subID, gcpSA string) error {
	// projectID := "my-project-id"
	// topicID := "my-topic"

	// // Azure Event Hubs ingestion settings.
	// resourceGroup := "resource-group"
	// namespace := "namespace"
	// eventHub := "event-hub"
	// clientID := "client-id"
	// tenantID := "tenant-id"
	// subID := "subscription-id"
	// gcpSA := "gcp-service-account"

	ctx := context.Background()
	client, err := pubsub.NewClient(ctx, projectID)
	if err != nil {
		return fmt.Errorf("pubsub.NewClient: %w", err)
	}
	defer client.Close()

	cfg := &pubsub.TopicConfig{
		IngestionDataSourceSettings: &pubsub.IngestionDataSourceSettings{
			Source: &pubsub.IngestionDataSourceAzureEventHubs{
				ResourceGroup:     resourceGroup,
				Namespace:         namespace,
				EventHub:          eventHub,
				ClientID:          clientID,
				TenantID:          tenantID,
				SubscriptionID:    subID,
				GCPServiceAccount: gcpSA,
			},
		},
	}
	t, err := client.CreateTopicWithConfig(ctx, topicID, cfg)
	if err != nil {
		return fmt.Errorf("CreateTopic: %w", err)
	}
	fmt.Fprintf(w, "Created topic with azure event hubs ingestion: %v\n", t)
	return nil
}

Java

Sebelum mencoba contoh ini, ikuti petunjuk penyiapan Java di Panduan memulai: Menggunakan Library Klien. Untuk mengetahui informasi selengkapnya, lihat dokumentasi referensi Pub/Sub Java API.

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

public class CreateTopicWithAzureEventHubsIngestionExample {
  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";
    // Azure Event Hubs ingestion settings.
    String resourceGroup = "resource-group";
    String namespace = "namespace";
    String eventHub = "event-hub";
    String clientId = "client-id";
    String tenantId = "tenant-id";
    String subscriptionId = "subscription-id";
    String gcpServiceAccount = "gcp-service-account";

    createTopicWithAzureEventHubsIngestionExample(
        projectId,
        topicId,
        resourceGroup,
        namespace,
        eventHub,
        clientId,
        tenantId,
        subscriptionId,
        gcpServiceAccount);
  }

  public static void createTopicWithAzureEventHubsIngestionExample(
      String projectId,
      String topicId,
      String resourceGroup,
      String namespace,
      String eventHub,
      String clientId,
      String tenantId,
      String subscriptionId,
      String gcpServiceAccount)
      throws IOException {
    try (TopicAdminClient topicAdminClient = TopicAdminClient.create()) {
      TopicName topicName = TopicName.of(projectId, topicId);

      IngestionDataSourceSettings.AzureEventHubs azureEventHubs =
          IngestionDataSourceSettings.AzureEventHubs.newBuilder()
              .setResourceGroup(resourceGroup)
              .setNamespace(namespace)
              .setEventHub(eventHub)
              .setClientId(clientId)
              .setTenantId(tenantId)
              .setSubscriptionId(subscriptionId)
              .setGcpServiceAccount(gcpServiceAccount)
              .build();
      IngestionDataSourceSettings ingestionDataSourceSettings =
          IngestionDataSourceSettings.newBuilder().setAzureEventHubs(azureEventHubs).build();

      Topic topic =
          topicAdminClient.createTopic(
              Topic.newBuilder()
                  .setName(topicName.toString())
                  .setIngestionDataSourceSettings(ingestionDataSourceSettings)
                  .build());

      System.out.println(
          "Created topic with Azure Event Hubs ingestion settings: " + topic.getAllFields());
    }
  }
}

Node.js

Sebelum mencoba contoh ini, ikuti petunjuk penyiapan Node.js di Panduan memulai: Menggunakan Library Klien. Untuk mengetahui informasi selengkapnya, lihat dokumentasi referensi API Node.js Pub/Sub.

/**
 * TODO(developer): Uncomment these variables before running the sample.
 */
// const topicNameOrId = 'YOUR_TOPIC_NAME_OR_ID';
// const resourceGroup = 'YOUR_RESOURCE_GROUP';
// const namespace = 'YOUR_NAMESPACE';
// const eventHub = 'YOUR_EVENT_HUB';
// const clientId = 'YOUR_CLIENT_ID';
// const tenantId = 'YOUR_TENANT_ID';
// const subscriptionId = 'YOUR_SUBSCRIPTION_ID';
// const gcpServiceAccount = 'ingestion-account@...';

// 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 createTopicWithAzureEventHubsIngestion(
  topicNameOrId,
  resourceGroup,
  namespace,
  eventHub,
  clientId,
  tenantId,
  subscriptionId,
  gcpServiceAccount,
) {
  // Creates a new topic with Azure Event Hubs ingestion.
  await pubSubClient.createTopic({
    name: topicNameOrId,
    ingestionDataSourceSettings: {
      azureEventHubs: {
        resourceGroup,
        namespace,
        eventHub,
        clientId,
        tenantId,
        subscriptionId,
        gcpServiceAccount,
      },
    },
  });
  console.log(
    `Topic ${topicNameOrId} created with Azure Event Hubs ingestion.`,
  );
}

Node.ts

Sebelum mencoba contoh ini, ikuti petunjuk penyiapan Node.js di Panduan memulai: Menggunakan Library Klien. Untuk mengetahui informasi selengkapnya, lihat dokumentasi referensi API Node.js Pub/Sub.

/**
 * TODO(developer): Uncomment these variables before running the sample.
 */
// const topicNameOrId = 'YOUR_TOPIC_NAME_OR_ID';
// const resourceGroup = 'YOUR_RESOURCE_GROUP';
// const namespace = 'YOUR_NAMESPACE';
// const eventHub = 'YOUR_EVENT_HUB';
// const clientId = 'YOUR_CLIENT_ID';
// const tenantId = 'YOUR_TENANT_ID';
// const subscriptionId = 'YOUR_SUBSCRIPTION_ID';
// const gcpServiceAccount = 'ingestion-account@...';

// 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 createTopicWithAzureEventHubsIngestion(
  topicNameOrId: string,
  resourceGroup: string,
  namespace: string,
  eventHub: string,
  clientId: string,
  tenantId: string,
  subscriptionId: string,
  gcpServiceAccount: string,
) {
  // Creates a new topic with Azure Event Hubs ingestion.
  await pubSubClient.createTopic({
    name: topicNameOrId,
    ingestionDataSourceSettings: {
      azureEventHubs: {
        resourceGroup,
        namespace,
        eventHub,
        clientId,
        tenantId,
        subscriptionId,
        gcpServiceAccount,
      },
    },
  });
  console.log(
    `Topic ${topicNameOrId} created with Azure Event Hubs ingestion.`,
  );
}

Python

Sebelum mencoba contoh ini, ikuti petunjuk penyiapan Python di Panduan memulai: Menggunakan Library Klien. Untuk mengetahui informasi selengkapnya, lihat dokumentasi referensi Pub/Sub Python API.

from google.cloud import pubsub_v1
from google.pubsub_v1.types import Topic
from google.pubsub_v1.types import IngestionDataSourceSettings

# TODO(developer)
# project_id = "your-project-id"
# topic_id = "your-topic-id"
# resource_group = "your-resource-group"
# namespace = "your-namespace"
# event_hub = "your-event-hub"
# client_id = "your-client-id"
# tenant_id = "your-tenant-id"
# subscription_id = "your-subscription-id"
# gcp_service_account = "your-gcp-service-account"

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

request = Topic(
    name=topic_path,
    ingestion_data_source_settings=IngestionDataSourceSettings(
        azure_event_hubs=IngestionDataSourceSettings.AzureEventHubs(
            resource_group=resource_group,
            namespace=namespace,
            event_hub=event_hub,
            client_id=client_id,
            tenant_id=tenant_id,
            subscription_id=subscription_id,
            gcp_service_account=gcp_service_account,
        )
    ),
)

topic = publisher.create_topic(request=request)

print(f"Created topic: {topic.name} with Azure Event Hubs Ingestion Settings")

Jika Anda mengalami masalah, lihat Memecahkan masalah topik impor Azure Event Hubs.

Mengedit topik impor Azure Event Hubs

Untuk mengedit setelan sumber data penyerapan topik impor Azure Event Hubs, ikuti langkah-langkah berikut:

Konsol

1. Di konsol Trusted Cloud , buka halaman Topics.

   Buka Topik

2. Klik topik impor Azure Event Hubs.

3. Di halaman detail topik, klik Edit.

4. Perbarui kolom yang ingin Anda ubah.

5. Klik Perbarui.

gcloud

1. In the Trusted Cloud console, activate Cloud Shell.

   Activate Cloud Shell

   At the bottom of the Trusted Cloud console, a Cloud Shell session starts and displays a command-line prompt. Cloud Shell is a shell environment with the Google Cloud CLI already installed and with values already set for your current project. It can take a few seconds for the session to initialize.

2. Jalankan perintah gcloud pubsub topics update dengan semua flag yang disebutkan dalam contoh berikut:

   gcloud pubsub topics update TOPIC_ID \
       --azure-event-hubs-ingestion-resource-group RESOURCE_GROUP \
       --azure-event-hubs-ingestion-namespace NAMESPACE \
       --azure-event-hubs-ingestion-event-hub EVENT_HUB \
       --azure-event-hubs-ingestion-client-id CLIENT_ID \
       --azure-event-hubs-ingestion-tenant-id TENANT_ID \
       --azure-event-hubs-ingestion-subscription-id SUBSCRIPTION_ID \
       --azure-event-hubs-ingestion-service-account SERVICE_ACCOUNT
   

   Ganti kode berikut:

   • TOPIC_ID: nama atau ID topik Pub/Sub Anda.
   • RESOURCE_GROUP: nama grup resource Azure Event Hubs yang berisi namespace Azure Event Hubs yang Anda masukkan ke Pub/Sub.
   • NAMESPACE: nama namespace Azure Event Hubs yang berisi Azure Event Hub yang Anda masukkan ke Pub/Sub.
   • EVENT_HUB: nama hub peristiwa Azure yang Anda masukkan ke Pub/Sub.
   • CLIENT_ID: ID aplikasi (klien) dari Aplikasi terdaftar di Azure yang berisi identitas gabungan Trusted Cloud Akun Layanan. Nilai ini harus berupa UUID. Untuk mengetahui informasi selengkapnya, lihat halaman Pendaftaran Aplikasi Azure.
   • TENANT_ID: ID direktori (tenant) tenant yang memiliki Azure Event Hubs yang Anda masukkan ke Pub/Sub. Nilai ini harus berupa UUID. Untuk menemukan ID tenant Anda, lihat buka halaman Azure Get subscription and tenant IDs.
   • SUBSCRIPTION_ID: ID langganan langganan yang memiliki hub peristiwa Azure yang Anda lakukan penyerapan ke Pub/Sub. Nilai ini harus berupa UUID. Untuk menemukan ID langganan Anda, lihat Azure Get subscription and tenant IDs.
   • SERVICE_ACCOUNT: akun layanan yang Anda buat di Membuat akun layanan di Trusted Cloud

Kuota dan batas

Throughput penayang untuk topik impor dibatasi oleh kuota publikasi topik. Untuk mengetahui informasi selengkapnya, lihat Kuota dan batas Pub/Sub.

Langkah berikutnya

• Memantau topik impor.

• Pilih jenis langganan untuk topik Anda.

• Pelajari cara memublikasikan pesan ke topik.

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

• Memecahkan masalah topik impor Azure Event Hubs.