Function Compute：Gunakan Function Compute untuk membersihkan data pesan di RocketMQ

Misalnya, Anda perlu memisahkan pesan daftar siswa asli [Jack, Male, Class 4|Alice, Female, Class 3|John, Male, Class 4] menjadi tiga pesan terpisah, lalu mengirim ketiganya ke layanan tujuan masing-masing. Untuk menerapkan hal ini, Anda dapat menggunakan operator content splitting. Pesan hasil pemisahan adalah sebagai berikut:

message:
    [Jack, Male, Class 4]
message:
    [Alice, Female, Class 3]
message:
    [John, Male, Class 4]

Gambar berikut menunjukkan prosesnya.

Pesan berikut berisi informasi pasta gigi dari tiga merek:

message:
[BrandA, toothpaste, $12.98, 100g
 BrandB, toothpaste, $7.99, 80g
 BrandC, toothpaste, $1.99, 100g]

Daftar tersebut perlu dikirim ke topik tujuan berdasarkan aturan dinamis kustom. Aturan tersebut dijelaskan sebagai berikut:

• Kirim pesan yang dimulai dengan BrandA ke topik BrandA-item-topic dan BrandA-discount-topic.

• Kirim pesan yang dimulai dengan BrandB ke topik BrandB-item-topic dan BrandB-discount-topic.

• Kirim pesan lainnya ke topik Unknown-brand-topic.

Kode contoh berikut menunjukkan format JSON dari aturan tersebut:

{
  "defaultTopic": "Unknown-brand-topic",
  "rules": [
    {
      "regex": "^BrandA",
      "targetTopics": [
        "BrandA-item-topic",
        "BrandA-discount-topic"
      ]
    },
    {
      "regex": "^BrandB",
      "targetTopics": [
        "BrandB-item-topic",
        "BrandB-discount-topic"
      ]
    }
  ]
}

Pada contoh ini, sebuah Blok CIDR diperkaya. Kode contoh berikut memberikan contoh log akses suatu layanan:

{
  "accountID": "164901546557****",
  "hostIP": "192.168.XX.XX"
}

Kode contoh berikut menunjukkan cara melakukan kueri sumber alamat IP dan menyimpan hubungan pemetaan tersebut dalam database MySQL:

CREATE TABLE `tb_ip` (
    ->      `IP` VARCHAR(256) NOT NULL,
    ->     `Region` VARCHAR(256) NOT NULL,
    ->      `ISP` VARCHAR(256) NOT NULL,
    ->      PRIMARY KEY (`IP`)
    -> );

Kode contoh berikut menunjukkan pesan yang telah diproses:

{
  "accountID": "164901546557****",
  "hostIP": "192.168.XX.XX",
  "region": "beijing"
}

Gambar berikut menunjukkan prosesnya.

Pesan berikut berisi informasi pendaftaran karyawan suatu perusahaan.

Zhang San, Employee ID 1, 131 1111 1111
Li Si, Employee ID 2, 132 2222 2222
Wang Wu, Employee ID 3, 133 3333 3333

Nama, ID, dan nomor telepon karyawan dalam pesan di atas bersifat rahasia. Oleh karena itu, Anda perlu menyamarkan nama, ID, dan nomor telepon tersebut sebelum mengirim pesan ke layanan tujuan. Kode contoh berikut menunjukkan hasilnya:

Ja*, Employee ID *, ***********
Ma*, Employee ID *, ***********
Dav*, Employee ID *, *********** 

Gambar berikut menunjukkan prosesnya.