Function Compute：使用Function Compute對RocketMQ的訊息資料進行清洗

例如，需要將原始訊息學生名單[張三，男，4班|李四，女，3班|王五，男，4班]拆分為三條獨立訊息，然後分三條訊息推送至各目標服務。在實現上，可以使用內容分割運算元，分割後的訊息如下所示：

message:
    [張三，男，4班]
message:
    [李四，女，3班]
message:
    [王五，男，4班]

實現效果如下圖。

例如，以下是一份牙膏資訊清單。

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

需要按照自訂動態規則，將列表路由至目標Topic。規則描述如下所示。

• 如果訊息以BrandA開頭，發送至BrandA-item-topic和BrandA-discount-topic這兩個topic。

• 如果訊息以BrandB開頭，發送至BrandB-item-topic和BrandB-discount-topic這兩個topic。

• 其餘訊息發送至Unknown-brand-topic。

規則的JSON描述如下。

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

本文以一個IP位址區段處理的情境富化為例。假設某服務的訪問日誌如下所示。

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

需要統計IP地址的來源，並且映射關係儲存於資料庫MySQL。

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

處理後的訊息結果如下所示。

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

實現效果如下圖。

例如，以下是某公司員工登記資訊，涉及了員工工號、電話號碼等隱私內容。

張三，工號1，131 1111 1111
李四，工號2，132 2222 2222
王五，工號3，133 3333 3333

需要將以上訊息中員工隱私資訊進行屏蔽，然後推送至目標服務。如下所示。

張*，工號*，*** **** ****
李*，工號*，*** **** ****
王*，工號*，*** **** ****

實現效果如下圖。