ApsaraMQ for RocketMQ:データクレンジング

次のメッセージには、学生のリストが含まれています。

メッセージ:
[ジャック、男性、17、クラス4; アリス、女性、17、クラス3; ジョン、男性、17、クラス4] 

指定した宛先サービスにメッセージを送信する前に、メッセージを次のメッセージに分割します。各メッセージには1人の学生に関する情報が含まれています。

メッセージ:
    [ジャック、男性、17、クラス4]
メッセージ:
    [アリス、女性、17、クラス3]
メッセージ:
    [ジョン、男性、クラス17、クラス4] 

次の図にプロセスを示します。

次のメッセージには歯磨き粉のリストが含まれています。

メッセージ:
[BrandA、歯磨き粉、$12.98、100g
 BrandB、歯磨き粉、$7.99、80g
 BrandC、歯磨き粉、$1.99、100g] 

カスタム動的ルールに基づいて、指定した宛先トピックにリストを送信する必要があります。 次の項目は、ルールを説明します。

• BrandAで始まるメッセージをBrandA-item-topicおよびBrandA-discount-topic topicsに送信します。

• BrandBで始まるメッセージをBrandB-item-topicおよびBrandB-discount-topicトピックに送信します。

• Unknown-brand-topicトピックに他のメッセージを送信します。

次のサンプルコードは、ルールのJSON形式を示しています。

{
  "defaultTopic": "Unknown-brand-topic" 、
  "rules": [
    {
      "regex": "^ BrandA" 、
      "targetTopics": [
        "BrandA-item-topic" 、
        "BrandA-割引-トピック"
      ]
    },
    {
      "regex": "^ BrandB" 、
      "targetTopics": [
        "BrandB-item-topic" 、
        "BrandB-割引-トピック"
      ]
    }
  ]
}

この例では、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、
    -> プライマリーキー ('IP')
    -> ); 

次のコードスニペットは、処理されたメッセージを示します。

{
  "accountID": "164901546557 ****" 、
  "hostIP": "192.168.XX.XX" 、
  "region": "北京"
} 

次の図にプロセスを示します。

次のメッセージには、会社の従業員に関する登録情報が含まれています。 情報には、従業員IDや携帯電話番号などの機密コンテンツが含まれます。

James、従業員ID 1、131 1111 1111
メアリー、従業員ID 2、132 2222 2222
デビッド、従業員ID 3、133 3333 3333 

メッセージが宛先サービスに送信される前に、前のメッセージの機密コンテンツをマスクする必要があります。 次のサンプルコードに例を示します。

Ja * 、従業員ID * 、**********
Ma * 、従業員ID * 、**********
Dav * 、従業員ID * 、*********** 

次の図にプロセスを示します。