Principy filtrování událostí pro Event Grid předplatná

Článek
06/07/2021
13 min ke čtení

Tento článek popisuje různé způsoby filtrování událostí odesílaných do vašeho koncového bodu. Při vytváření odběru událostí máte tři možnosti filtrování:

Typy událostí
Předmět začíná na nebo končí na
Pokročilá pole a operátory

Filtrování typů událostí

Ve výchozím nastavení se všechny typy událostí pro zdroj událostí odesílané do koncového bodu. Můžete se rozhodnout, že do koncového bodu odešlete jenom určité typy událostí. Můžete například dostávat oznámení o aktualizacích vašich prostředků, ale ne na jiné operace, jako je odstranění. V takovém případě filtrujte podle Microsoft.Resources.ResourceWriteSuccess typu události. Zadejte pole s typy událostí nebo zadejte , abyste All získali všechny typy událostí pro zdroj událostí.

Syntaxe JSON pro filtrování podle typu události je:

"filter": {
  "includedEventTypes": [
    "Microsoft.Resources.ResourceWriteFailure",
    "Microsoft.Resources.ResourceWriteSuccess"
  ]
}

Filtrování předmětu

Pro jednoduché filtrování podle předmětu zadejte počáteční nebo koncovou hodnotu předmětu. Můžete například zadat předmět končící na a získat pouze události související s nahrání .txt textového souboru do účtu úložiště. Nebo můžete filtrovat předmět, který začíná na , a získat všechny události pro tento kontejner, ale ne jiné kontejnery /blobServices/default/containers/testcontainer v účtu úložiště.

Při publikování událostí do vlastních témat vytvořte pro své události předměty, které předplatitelům udělují informace o tom, jestli se o událost zajímají. Odběratelé používají vlastnost subject k filtrování a směrování událostí. Zvažte přidání cesty pro místo, kde došlo k události, aby odběratelé mohli filtrovat podle segmentů této cesty. Cesta umožňuje odběratelům úzce nebo obecně filtrovat události. Pokud v předmětu zadáte cestu se třemi segmenty, jako je , mohou odběratelé filtrovat podle prvního segmentu a získat tak širokou /A/B/C /A škálu událostí. Tito odběratelé se dočtou událostí s tématy, jako /A/B/C jsou nebo /A/D/E . Ostatní odběratelé mohou filtrovat podle /A/B a získat užší sadu událostí.

Syntaxe JSON pro filtrování podle předmětu je:

"filter": {
  "subjectBeginsWith": "/blobServices/default/containers/mycontainer/log",
  "subjectEndsWith": ".jpg"
}

Rozšířené filtrování

Pokud chcete filtrovat podle hodnot v datových polích a zadat operátor porovnání, použijte možnost rozšířeného filtrování. V rozšířeném filtrování zadáte:

operator type – typ porovnání.
key – pole v datech událostí, které používáte k filtrování. Může to být číslo, logická hodnota, řetězec nebo pole.
values – hodnota nebo hodnoty, které se budou porovnávat s klíčem.

Klíč

Klíč je pole v datech událostí, které používáte k filtrování. Může to být jeden z následujících typů:

Číslo
Logická hodnota
Řetězec

Pole. Abyste tuto funkci enableAdvancedFilteringOnArrays měli, musíte vlastnost nastavit na true.

"filter":
{
    "subjectBeginsWith": "/blobServices/default/containers/mycontainer/log",
    "subjectEndsWith": ".jpg",
    "enableAdvancedFilteringOnArrays": true
}

Pro události ve schématu Event Grid použijte pro klíč následující ID hodnoty: , Topic , , , , nebo data událostí Subject EventType DataVersion (například data.key1 ).

Pro události ve schématu cloudových událostí použijte pro klíč následující eventid hodnoty: , source , , nebo data událostí eventtype eventtypeversion (například data.key1 ).

Pro vlastní vstupní schéma použijte datová pole události (například data.key1 ). Pokud chcete získat přístup k polím v datové části, použijte . zápis (tečka). Například pro data.sitename přístup k nebo pro následující data.appEventTypeDetail.action sitename action ukázkovou událost.

    "data": {
        "appEventTypeDetail": {
            "action": "Started"
        },
        "siteName": "<site-name>",
        "clientRequestId": "None",
        "correlationRequestId": "None",
        "requestId": "292f499d-04ee-4066-994d-c2df57b99198",
        "address": "None",
        "verb": "None"
    },

Hodnoty

Hodnoty mohou být: číslo, řetězec, logická hodnota nebo pole.

Operátory

Dostupné operátory pro čísla jsou:

Číslo v

Operátor NumberIn se vyhodnotí jako true, pokud je hodnota klíče jednou ze zadaných hodnot filtru. V následujícím příkladu zkontroluje, jestli je hodnota atributu v counter data oddílu 5 nebo 1.

"advancedFilters": [{
    "operatorType": "NumberIn",
    "key": "data.counter",
    "values": [
        5,
        1
    ]
}]

Pokud je klíč pole, budou se všechny hodnoty v poli kontrolovat oproti poli hodnot filtru. Tady je pseudokód s klíčem a [v1, v2, v3] filtrem: [a, b, c] . Všechny hodnoty klíčů s datovými typy, které neodpovídají datovému typu filtru, se ignorují.

FOR_EACH filter IN (a, b, c)
    FOR_EACH key IN (v1, v2, v3)
        IF filter == key
            MATCH

NumberNotIn

NumberNotIn se vyhodnotí jako true, pokud hodnota klíče není žádná ze zadaných hodnot filtru. V následujícím příkladu zkontroluje, jestli hodnota atributu v oddílu není counter data 41 a 0.

"advancedFilters": [{
    "operatorType": "NumberNotIn",
    "key": "data.counter",
    "values": [
        41,
        0
    ]
}]

FOR_EACH filter IN (a, b, c)
    FOR_EACH key IN (v1, v2, v3)
        IF filter == key
            FAIL_MATCH

NumberLessThan

Operátor NumberLessThan se vyhodnotí jako true, pokud je hodnota klíče menší než zadaná hodnota filtru. V následujícím příkladu zkontroluje, jestli je hodnota atributu v counter oddílu menší než data 100.

"advancedFilters": [{
    "operatorType": "NumberLessThan",
    "key": "data.counter",
    "value": 100
}]

Pokud je klíč pole, budou se všechny hodnoty v poli kontrolovat oproti hodnotě filtru. Tady je pseudokód s klíčem : [v1, v2, v3] . Všechny hodnoty klíčů s datovými typy, které neodpovídají datovému typu filtru, se ignorují.

FOR_EACH key IN (v1, v2, v3)
    IF key < filter
        MATCH

NumberGreaterThan

Operátor NumberGreaterThan se vyhodnotí jako true, pokud je hodnota klíče větší než zadaná hodnota filtru. V následujícím příkladu zkontroluje, jestli je hodnota atributu v counter oddílu větší než data 20.

"advancedFilters": [{
    "operatorType": "NumberGreaterThan",
    "key": "data.counter",
    "value": 20
}]

FOR_EACH key IN (v1, v2, v3)
    IF key > filter
        MATCH

NumberLessThanOrEquals

Operátor NumberLessThanOrEquals se vyhodnotí jako true, pokud je hodnota klíče menší nebo rovna zadané hodnotě filtru. V následujícím příkladu zkontroluje, jestli je hodnota atributu v oddílu menší než nebo rovna counter data 100.

"advancedFilters": [{
    "operatorType": "NumberLessThanOrEquals",
    "key": "data.counter",
    "value": 100
}]

FOR_EACH key IN (v1, v2, v3)
    IF key <= filter
        MATCH

NumberGreaterThanOrEquals

Operátor NumberGreaterThanOrEquals se vyhodnotí jako true, pokud je hodnota klíče větší nebo rovna zadané hodnotě filtru. V následujícím příkladu zkontroluje, jestli je hodnota atributu v oddílu větší než nebo counter data rovna 30.

"advancedFilters": [{
    "operatorType": "NumberGreaterThanOrEquals",
    "key": "data.counter",
    "value": 30
}]

FOR_EACH key IN (v1, v2, v3)
    IF key >= filter
        MATCH

NumberInRange

Operátor NumberInRange se vyhodnotí jako true, pokud je hodnota klíče v jednom ze zadaných rozsahů filtru. V následujícím příkladu zkontroluje, jestli je hodnota atributu v oddílu v jednom ze dvou key1 data rozsahů: 3,14159 – 999,95, 3000 – 4000.

{
    "operatorType": "NumberInRange",
    "key": "data.key1",
    "values": [[3.14159, 999.95], [3000, 4000]]
}

Vlastnost values je pole rozsahů. V předchozím příkladu je to pole dvou rozsahů. Tady je příklad pole s jedním rozsahem ke kontrole.

Pole s jedním rozsahem:

{
    "operatorType": "NumberInRange",
    "key": "data.key1",
    "values": [[3000, 4000]]
}

Pokud je klíč pole, budou se všechny hodnoty v poli kontrolovat oproti poli hodnot filtru. Tady je pseudokód s klíčem a [v1, v2, v3] filtrem: pole rozsahů. V tomto pseudokódu a jsou a nízké a vysoké hodnoty každého rozsahu v b poli. Všechny hodnoty klíčů s datovými typy, které neodpovídají datovému typu filtru, se ignorují.

FOR_EACH (a,b) IN filter.Values
    FOR_EACH key IN (v1, v2, v3)
       IF key >= a AND key <= b
           MATCH

NumberNotInRange

Operátor NumberNotInRange se vyhodnotí jako true, pokud hodnota klíče není v žádném ze zadaných rozsahů filtru. V následujícím příkladu zkontroluje, jestli je hodnota atributu v oddílu v jednom ze dvou key1 data rozsahů: 3,14159 – 999,95, 3000 – 4000. Pokud je, vrátí operátor hodnotu false.

{
    "operatorType": "NumberNotInRange",
    "key": "data.key1",
    "values": [[3.14159, 999.95], [3000, 4000]]
}

Vlastnost values je pole rozsahů. V předchozím příkladu je to pole dvou rozsahů. Tady je příklad pole s jedním rozsahem ke kontrole.

Pole s jedním rozsahem:

{
    "operatorType": "NumberNotInRange",
    "key": "data.key1",
    "values": [[3000, 4000]]
}

FOR_EACH (a,b) IN filter.Values
    FOR_EACH key IN (v1, v2, v3)
        IF key >= a AND key <= b
            FAIL_MATCH

Operátor dostupný pro logické hodnoty je:

BoolEquals

Operátor BoolEquals se vyhodnotí jako true, pokud je hodnota klíče zadaným logickým filtrem . V následujícím příkladu zkontroluje, jestli je hodnota isEnabled atributu v data oddílu true .

"advancedFilters": [{
    "operatorType": "BoolEquals",
    "key": "data.isEnabled",
    "value": true
}]

Pokud je klíč pole, budou se všechny hodnoty v poli kontrolovat oproti logické hodnotě filtru. Tady je pseudokód s klíčem : [v1, v2, v3] . Všechny hodnoty klíčů s datovými typy, které neodpovídají datovému typu filtru, se ignorují.

FOR_EACH key IN (v1, v2, v3)
    IF filter == key
        MATCH

Dostupné operátory pro řetězce jsou:

StringContains

Hodnota StringContains se vyhodnotí jako true, pokud hodnota klíče obsahuje libovolnou zadanou hodnotu filtru (jako podřetězce). V následujícím příkladu zkontroluje, jestli hodnota atributu v oddílu obsahuje jeden ze key1 data zadaných podřetězců: microsoft nebo azure . Například obsahuje azure data factory azure .

"advancedFilters": [{
    "operatorType": "StringContains",
    "key": "data.key1",
    "values": [
        "microsoft", 
        "azure"
    ]
}]