ApsaraMQ for Kafka：Buat konektor sink Layanan Log Sederhana

Langkah 1: Buat sumber daya Layanan Log Sederhana

• Buat proyek Layanan Log Sederhana. Untuk informasi lebih lanjut, lihat Buat Proyek.

• Buat penyimpanan log Layanan Log Sederhana. Untuk informasi lebih lanjut, lihat Buat Penyimpanan Log.

Dalam contoh ini, sebuah proyek bernama guide-sls-sink-project dan penyimpanan log bernama guide-sls-sink-logstore dibuat.

Langkah 2: Buat dan mulai konektor sink Layanan Log Sederhana

1. Masuk ke Konsol ApsaraMQ for Kafka. Di bagian Resource Distribution pada halaman Overview, pilih wilayah tempat instance ApsaraMQ for Kafka yang ingin Anda kelola berada.

2. Di panel navigasi di sebelah kiri, pilih Connector Ecosystem Integration > Tasks.

3. Pada halaman Tasks, klik Create Task.

   • Pembuatan Tugas

   1. Di langkah Source, atur parameter Data Provider menjadi ApsaraMQ for Kafka dan ikuti petunjuk di layar untuk mengonfigurasi parameter lainnya. Lalu, klik Next Step. Tabel berikut menjelaskan parameter tersebut.

      Parameter	Deskripsi	Contoh
      Region	Wilayah tempat instance sumber ApsaraMQ for Kafka berada.	Tiongkok (Beijing)
      ApsaraMQ for Kafka Instance	Instance ApsaraMQ for Kafka tempat pesan yang ingin Anda rutekan diproduksi.	alikafka_post-cn-jte3****
      Topic	Topik pada instance ApsaraMQ for Kafka tempat pesan yang ingin Anda rutekan diproduksi.	demo-topic
      Group ID	Nama grup konsumen pada instance sumber ApsaraMQ for Kafka. Quickly Create: Sistem secara otomatis membuat grup konsumen dengan nama dalam format GID_EVENTBRIDGE_xxx. Kami merekomendasikan agar Anda memilih nilai ini. Use Existing Group: Pilih ID grup yang ada yang tidak sedang digunakan. Jika Anda memilih grup yang ada yang sedang digunakan, publikasi dan langganan pesan yang ada akan terpengaruh.	Buat Cepat
      Consumer Offset	Offset dari mana pesan dikonsumsi. Nilai valid: Latest Offset Earliest Offset	Offset Terbaru
      Network Configuration	Jenis jaringan tempat Anda ingin merutekan pesan. Nilai valid: Basic Network Self-managed Internet	Jaringan Dasar
      VPC	ID virtual private cloud (VPC) tempat instance ApsaraMQ for Kafka diterapkan. Parameter ini hanya diperlukan jika Anda mengatur parameter Network Configuration menjadi Internet Mandiri.	vpc-bp17fapfdj0dwzjkd****
      vSwitch	ID vSwitch tempat instance ApsaraMQ for Kafka termasuk. Parameter ini hanya diperlukan jika Anda mengatur parameter Network Configuration menjadi Internet Mandiri.	vsw-bp1gbjhj53hdjdkg****
      Security Group	ID grup keamanan tempat instance ApsaraMQ for Kafka termasuk. Parameter ini hanya diperlukan jika Anda mengatur parameter Network Configuration menjadi Internet Mandiri.	alikafka_pre-cn-7mz2****
      Data Format	Fitur format data digunakan untuk mengkodekan data biner yang dikirim dari sumber ke dalam format data tertentu. Beberapa format data didukung. Jika Anda tidak memiliki persyaratan khusus untuk pengkodean, tentukan Json sebagai nilainya. Json: Data biner dikodekan menjadi data berformat JSON berdasarkan pengkodean UTF-8 dan kemudian dimasukkan ke dalam payload. Text: Data biner dikodekan menjadi string berdasarkan pengkodean UTF-8 dan kemudian dimasukkan ke dalam payload. Ini adalah nilai default. Binary: Data biner dikodekan menjadi string berdasarkan pengkodean Base64 dan kemudian dimasukkan ke dalam payload.	Json
      Messages	Jumlah maksimum pesan yang dapat dikirim dalam setiap pemanggilan fungsi. Permintaan hanya dikirim ketika jumlah pesan dalam backlog mencapai nilai yang ditentukan. Nilai valid: 1 hingga 10000.	100
      Interval (Unit: Seconds)	Interval waktu saat fungsi dipanggil. Sistem mengirimkan pesan agregat ke Function Compute pada interval waktu yang ditentukan. Nilai valid: 0 hingga 15. Satuan: detik. Nilai 0 menentukan bahwa pesan dikirim segera setelah agregasi.	3

   2. Di langkah Filtering, definisikan pola data di editor kode Pattern Content untuk menyaring data. Untuk informasi lebih lanjut, lihat Pola Peristiwa.

   3. Di langkah Transformation, tentukan metode pembersihan data untuk mengimplementasikan kemampuan pemisahan, pemetaan, pengayaan, dan pengarahan data. Untuk informasi lebih lanjut, lihat Gunakan Function Compute untuk Melakukan Pembersihan Pesan.

   4. Di langkah Sink, atur parameter Service Type menjadi Simple Log Service dan ikuti petunjuk di layar untuk mengonfigurasi parameter lainnya. Lalu, klik Save. Tabel berikut menjelaskan parameter tersebut.

   Tabel 1. Layanan Log Sederhana

   Parameter	Deskripsi	Contoh
   Project	Proyek Layanan Log Sederhana yang Anda buat.	guide-sls-sink-project
   Logstore	Penyimpanan log Layanan Log Sederhana yang Anda buat.	guide-sls-sink-logstore
   Topic	Metode yang digunakan untuk menghasilkan topik di Layanan Log Sederhana. Empty Fixed Value Partial Data Template	Kosong
   Content	Default Format (JSON) Custom Format (Key/Value)	Format Default (JSON)
   Role Name	Peran yang dapat diasumsikan oleh EventBridge untuk menulis data ke Layanan Log Sederhana. Jika tidak ada peran yang tersedia, Anda dapat mengikuti petunjuk di layar untuk membuat peran.	sls_eb

4. Kembali ke halaman Tasks, temukan konektor sink OSS yang Anda buat, lalu klik Enable di kolom Actions.

5. Di pesan Note, klik OK.

   Konektor sink membutuhkan waktu 30 hingga 60 detik untuk diaktifkan. Anda dapat melihat kemajuannya di kolom Status pada halaman Tasks.

Langkah 3: Uji konektor sink Layanan Log Sederhana

1. Pada halaman Tasks, temukan konektor sink Layanan Log Sederhana yang Anda buat dan klik topik sumber di kolom Event Source.

2. Pada halaman Detail Topik, klik Send Message.

3. Di panel Start to Send and Consume Message, konfigurasikan parameter berdasarkan gambar berikut dan klik OK.

   

4. Pada halaman Tasks, temukan konektor sink Layanan Log Sederhana yang Anda buat dan klik proyek tujuan di kolom Event Target.

5. Pada halaman Penyimpanan Log, lihat isi log.