Realtime Compute for Apache Flink:Règles CEP dynamiques : format JSON et utilisation

Définition d'un nœud

Un nœud représente un motif unique et complet.

Définition du quantificateur

Un quantificateur décrit le nombre de fois où les événements doivent correspondre à un motif, ainsi que la stratégie de contiguïté au sein de ce motif. Par exemple, le motif A* possède une valeur properties définie sur LOOPING et une consumingStrategy définie sur SKIP_TILL_ANY.

Exemple de valeur times :

"times": {
  "from": 3,
  "to": 3,
  "windowTime": {
    "unit": "MINUTES",
    "size": 12
  }
}

Les champs from et to sont des entiers. Le champ unit dans windowTime accepte les valeurs DAYS, HOURS, MINUTES, SECONDS ou MILLISECONDS. Définissez windowTime sur null pour omettre toute contrainte de temps par correspondance.

Définition de la condition

Une condition filtre les événements qui répondent à des critères spécifiques. Par exemple, « navigation pendant plus de 5 minutes » constitue une condition qui filtre les clients selon la durée de leur session.

Définition d'une arête

Une arête relie deux nœuds de motif et définit la stratégie de sélection des événements pour cette transition.

Définition de GraphNode

Un GraphNode représente une séquence de motifs complète. Il étend le nœud de base avec des champs de structure de graphe (nodes et edges) et des champs de politique (window et afterMatchSkipStrategy). Comme GraphNode est traité comme un sous-type de Node, un GraphNode peut être imbriqué dans un autre GraphNode pour créer des motifs groupés (GroupPattern).

Champ Window :

Le champ window contraint le temps autorisé pour une correspondance complète. Le champ type contrôle l'application de la limite de temps :

• FIRST_AND_LAST : temps maximal entre le premier et le dernier événement d'une correspondance complète.

• PREVIOUS_AND_CURRENT : temps maximal entre les correspondances de deux motifs enfants adjacents quelconques.

Exemple :

"window": {
  "type": "FIRST_AND_LAST",
  "time": {
    "unit": "DAYS",
    "size": 1
  }
}

Le champ unit accepte les valeurs DAYS, HOURS, MINUTES, SECONDS ou MILLISECONDS. La valeur size est un entier long ou integer.

Définition de la stratégie de saut après correspondance

La stratégie de saut après correspondance contrôle les correspondances partielles à rejeter une fois qu'une correspondance complète a été trouvée.

Les stratégies ont les comportements suivants :

• NO_SKIP (par défaut) : chaque correspondance réussie est émise sans rejet.

• SKIP_TO_NEXT : rejette chaque correspondance partielle qui a commencé avec le même événement que la correspondance actuelle.

• SKIP_PAST_LAST_EVENT : rejette chaque correspondance partielle qui a commencé entre le début et la fin de la correspondance actuelle.

• SKIP_TO_FIRST : rejette chaque correspondance partielle qui a commencé entre le début de la correspondance actuelle et la première occurrence de l'événement nommé par patternName.

• SKIP_TO_LAST : rejette chaque correspondance partielle qui a commencé entre le début de la correspondance actuelle et la dernière occurrence de l'événement nommé par patternName.

Pour plus d'informations, consultez Stratégie de saut après correspondance.

Définition de la contiguïté

La contiguïté contrôle la rigueur avec laquelle les événements doivent se suivre au sein d'un motif ou le long d'une arête.

Pour plus d'informations, consultez FlinkCEP — Traitement complexe d'événements pour Flink.

Valeurs des propriétés du quantificateur

Les propriétés du quantificateur décrivent la cardinalité et la stratégie de correspondance d'un motif.

Pattern<Event, Event> pattern =
    Pattern.<Event>begin("start")
            .where(new StartCondition())
            .optional()
            .followedBy("middle")
            .where(new MiddleCondition())
            .timesOrMore(3)
            .notFollowedBy("end")
            .where(new EndCondition())
            .within(Time.minutes(10));

{
  "name": "end",
  "quantifier": {
    "consumingStrategy": "SKIP_TILL_NEXT",
    "properties": [
      "SINGLE"
    ],
    "times": null,
    "untilCondition": null
  },
  "condition": null,
  "nodes": [
    {
      "name": "end",
      "quantifier": {
        "consumingStrategy": "SKIP_TILL_NEXT",
        "properties": [
          "SINGLE"
        ],
        "times": null,
        "untilCondition": null
      },
      "condition": {
        "className": "com.alibaba.ververica.cep.demo.condition.EndCondition",
        "type": "CLASS"
      },
      "type": "ATOMIC"
    },
    {
      "name": "middle",
      "quantifier": {
        "consumingStrategy": "SKIP_TILL_NEXT",
        "properties": [
          "LOOPING"
        ],
        "times": {
          "from": 3,
          "to": 3,
          "windowTime": null
        },
        "untilCondition": null
      },
      "condition": {
        "className": "com.alibaba.ververica.cep.demo.condition.MiddleCondition",
        "type": "CLASS"
      },
      "type": "ATOMIC"
    },
    {
      "name": "start",
      "quantifier": {
        "consumingStrategy": "SKIP_TILL_NEXT",
        "properties": [
          "SINGLE",
          "OPTIONAL"
        ],
        "times": null,
        "untilCondition": null
      },
      "condition": {
        "className": "com.alibaba.ververica.cep.demo.condition.StartCondition",
        "type": "CLASS"
      },
      "type": "ATOMIC"
    }
  ],
  "edges": [
    {
      "source": "middle",
      "target": "end",
      "type": "NOT_FOLLOW"
    },
    {
      "source": "start",
      "target": "middle",
      "type": "SKIP_TILL_NEXT"
    }
  ],
  "window": {
    "type": "FIRST_AND_LAST",
    "time": {
      "unit": "MINUTES",
      "size": 10
    }
  },
  "afterMatchStrategy": {
    "type": "NO_SKIP",
    "patternName": null
  },
  "type": "COMPOSITE",
  "version": 1
}

"condition": {
    "args": [
        "A", "B"
    ],
    "className": "org.apache.flink.cep.pattern.conditions.CustomMiddleCondition",
    "type": "CLASS"
}

"condition": {
    "args": [
        "A", "B", "C"
    ],
    "className": "org.apache.flink.cep.pattern.conditions.CustomMiddleCondition",
    "type": "CLASS"
}