Function Compute：Bersihkan data pesan ApsaraMQ for RocketMQ menggunakan Function Compute

Sebagai contoh, Anda perlu memisahkan pesan asli—daftar siswa [Zhang San, male, Class 4|Li Si, female, Class 3|Wang Wu, male, Class 4]—menjadi tiga pesan terpisah, lalu mendorongnya ke layanan tujuan masing-masing. Untuk melakukannya, gunakan operator content splitting. Pesan hasil pemisahan adalah sebagai berikut:

message:
    [Zhang San, male, Class 4]
message:
    [Li Si, female, Class 3]
message:
    [Wang Wu, male, Class 4]

Gambar berikut menunjukkan hasilnya.

Sebagai contoh, berikut ini adalah daftar informasi pasta gigi.

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

Anda perlu mengarahkan daftar tersebut ke topik tujuan berdasarkan aturan dinamis kustom. Aturan tersebut dijelaskan sebagai berikut.

• Jika pesan dimulai dengan BrandA, kirimkan ke topik BrandA-item-topic dan BrandA-discount-topic.

• Jika pesan dimulai dengan BrandB, kirimkan ke topik BrandB-item-topic dan BrandB-discount-topic.

• Kirimkan semua pesan lainnya ke Unknown-brand-topic.

Aturan tersebut dituliskan dalam format JSON sebagai berikut.

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

Topik ini menggunakan contoh enriching data dari skenario pemrosesan segmen alamat IP. Asumsikan bahwa log akses untuk suatu layanan adalah sebagai berikut.

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

Anda perlu menghitung sumber alamat IP. Hubungan pemetaan tersebut disimpan 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`)
    -> );

Pesan yang telah diproses adalah sebagai berikut.

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

Gambar berikut menunjukkan hasilnya.

Sebagai contoh, berikut ini adalah informasi pendaftaran karyawan perusahaan, yang mencakup informasi pribadi seperti ID karyawan dan nomor telepon.

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

Anda perlu menyamarkan informasi pribadi karyawan dalam pesan tersebut, lalu mendorongnya ke layanan tujuan. Hasilnya adalah sebagai berikut.

Zhang*, Employee ID *, *** **** ****
Li*, Employee ID *, *** **** ****
Wang*, Employee ID *, *** **** ****

Gambar berikut menunjukkan hasilnya.