Event Grid abonelikleri için olay filtrelemeyi anlama

Bu makalede, uç noktanıza hangi olayların gönderileceğini filtrelemenin farklı yolları açıklanmaktadır. Olay aboneliği oluştururken filtreleme için üç seçeneğiniz vardır:

Olay tipleri
Konu ... ile başlar veya ... ile biter
Gelişmiş alanlar ve işleçler

Azure Resource Manager şablonu

Bu makalede gösterilen örnekler, Azure Resource Manager (ARM) şablonlarında filtre tanımlamaya yönelik JSON kod parçacıklarıdır. Eksiksiz bir ARM şablonu ve ARM şablonu dağıtma örneği için bkz . Hızlı Başlangıç: ARM şablonu kullanarak Blob depolama olaylarını web uç noktasına yönlendirme. Hızlı başlangıçtaki örnekteki filter bölümünün etrafındaki bazı ek bölümler şöyle: ARM şablonu aşağıdaki kaynakları tanımlar.

Azure depolama hesabı
Depolama hesabı için sistem konusu
Sistem konusuna yönelik olay aboneliği. Olay aboneliği bölümündeki filter alt bölüme bakın.

Aşağıdaki örnekte, Microsoft.Storage.BlobCreated ve Microsoft.Storage.BlobDeleted olayları için abonelik filtrelenir.

{
  "resources": [
    {
      "type": "Microsoft.Storage/storageAccounts",
      "apiVersion": "2021-08-01",
      "name": "[parameters('storageAccountName')]",
      "location": "[parameters('location')]",
      "sku": {
        "name": "Standard_LRS"
      },
      "kind": "StorageV2",
      "properties": {
        "accessTier": "Hot"
      }
    },
    {
      "type": "Microsoft.EventGrid/systemTopics",
      "apiVersion": "2021-12-01",
      "name": "[parameters('systemTopicName')]",
      "location": "[parameters('location')]",
      "properties": {
        "source": "[resourceId('Microsoft.Storage/storageAccounts', parameters('storageAccountName'))]",
        "topicType": "Microsoft.Storage.StorageAccounts"
      },
      "dependsOn": [
        "[resourceId('Microsoft.Storage/storageAccounts', parameters('storageAccountName'))]"
      ]
    },
    {
      "type": "Microsoft.EventGrid/systemTopics/eventSubscriptions",
      "apiVersion": "2021-12-01",
      "name": "[format('{0}/{1}', parameters('systemTopicName'), parameters('eventSubName'))]",
      "properties": {
        "destination": {
          "properties": {
            "endpointUrl": "[parameters('endpoint')]"
          },
          "endpointType": "WebHook"
        },
        "filter": {
          "includedEventTypes": [
            "Microsoft.Storage.BlobCreated",
            "Microsoft.Storage.BlobDeleted"
          ]
        }
      },
      "dependsOn": [
        "[resourceId('Microsoft.EventGrid/systemTopics', parameters('systemTopicName'))]"
      ]
    }
  ]
}

Olay türü filtreleme

Varsayılan olarak, olay kaynağı için tüm olay türleri uç noktaya gönderilir. Uç noktanıza yalnızca belirli olay türlerini göndermeye karar vekleyebilirsiniz. Örneğin, kaynaklarınızdaki güncelleştirmeler için bildirim alabilir, ancak silme işlemleri gibi diğer işlemler için bildirim alamayabilirsiniz. Bu durumda, olay türüne Microsoft.Resources.ResourceWriteSuccess göre filtreleyin. Olay türlerini içeren bir dizi sağlayın veya olay kaynağı için tüm olay türlerini almak üzere belirtin All .

Olay türüne göre filtrelemeye yönelik JSON söz dizimi şöyledir:

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

Konu filtreleme

Konuya göre basit filtreleme için konu için bir başlangıç veya bitiş değeri belirtin. Örneğin, yalnızca bir metin dosyasının bir depolama hesabına yüklenmesiyle ilgili olayları almak için, konunun .txt ile bittiğini belirtebilirsiniz. Alternatif olarak, /blobServices/default/containers/testcontainer ile başlayan konuları filtreleyebilir ve bu kapsayıcının tüm olaylarını alabilir, ancak depolama hesabındaki diğer kapsayıcılardan gelenleri alamazsınız.

Olayları özel konulara yayımlarken, abonelerin olayla ilgilenip ilgilenmediklerini bilmelerini kolaylaştıran etkinlikleriniz için konular oluşturun. Aboneler olayları filtrelemek ve yönlendirmek için subject özelliğini kullanır. Abonelerin bu yolun segmentlerine göre filtrelemesi için olayın gerçekleştiği yerin yolunu eklemeyi göz önünde bulundurun. Yol, abonelerin olayları dar veya geniş kapsamlı bir şekilde filtrelemesini sağlar. Konuda olduğu gibi /A/B/C üç segment yolu sağlarsanız, aboneler geniş bir olay kümesi elde etmek için ilk segmente /A göre filtreleyebilir. Bu aboneler, /A/B/C veya /A/D/E gibi konularla ilgili olaylar alır. Diğer aboneler, /A/B ölçütüne göre filtreleyerek daha dar bir olay kümesi elde edebilir.

Örnekler (Blob Depolama olayları)

Blob olayları, oluşturulan veya silinen nesnenin olay türüne, kapsayıcı adına veya adına göre filtrelenebilir.

Blob depolama olaylarının konusu şu biçimi kullanır:

/blobServices/default/containers/<containername>/blobs/<blobname>

Depolama hesabının tüm olaylarını eşleştirmek için konu filtrelerini boş bırakabilirsiniz.

Ön eki paylaşan bir kapsayıcı kümesinde oluşturulan bloblardan gelen olayları eşleştirmek için aşağıdaki gibi bir subjectBeginsWith filtre kullanın:

/blobServices/default/containers/containerprefix

Belirli bir kapsayıcıda oluşturulan bloblardan gelen olayları eşleştirmek için aşağıdaki gibi bir subjectBeginsWith filtre kullanın:

/blobServices/default/containers/containername/

Blob adı ön ekini paylaşan belirli bir kapsayıcıda oluşturulan bloblardan gelen olayları eşleştirmek için aşağıdaki gibi bir subjectBeginsWith filtre kullanın:

/blobServices/default/containers/containername/blobs/blobprefix

Kapsayıcının belirli bir alt klasöründe oluşturulan bloblardan gelen olayları eşleştirmek için aşağıdaki gibi bir subjectBeginsWith filtre kullanın:

/blobServices/default/containers/{containername}/blobs/{subfolder}/

Bir blob sonekini paylaşan belirli bir kapsayıcıda oluşturulan bloblardan gelen olayları eşleştirmek için ".log" veya ".jpg" gibi bir subjectEndsWith filtre kullanın.

Gelişmiş filtreleme

Veri alanlarındaki değerlere göre filtrelemek ve karşılaştırma işlecini belirtmek için gelişmiş filtreleme seçeneğini kullanın. Gelişmiş filtrelemede şunları belirtirsiniz:

işleç türü - Karşılaştırma türü.
key - Filtreleme için kullandığınız olay verilerindeki alan. Bir sayı, boolean, dize veya dizi olabilir.
values - Anahtarla karşılaştırılacak değer veya değerler.

Anahtar

Anahtar, filtreleme için kullandığınız olay verilerindeki alandır. Aşağıdaki türlerden biri olabilir:

Sayı
Boolean
String

Dizi. Bu özelliği kullanmak için özelliğini true olarak ayarlamanız enableAdvancedFilteringOnArrays gerekir.

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

Bulut Olayları şemasındaki olaylar için anahtar için aşağıdaki değerleri kullanın: eventid, source, eventtype, veya eventtypeversionolay verileri (gibidata.key1).

Event Grid temel katmanını kullanıyorsanız, Event Grid şemasındaki olaylar için anahtar için şu değerleri kullanın: , ID, Topic, Subject, , EventTypeveya olay verileri (gibiDataVersion).data.key1 Özel giriş şeması için olay verisi alanlarını (gibi data.key1) kullanın. Veri bölümündeki alanlara erişmek için (nokta) gösterimini . kullanın. Örneğin, aşağıdaki örnek olay için siteName'e erişmek amacıyla data.siteName, data.appEventTypeDetail.action veya action kullanılabilir.

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

Not

Event Grid, bir nesne dizisinde filtrelemeyi desteklemez. Yalnızca aynı türlerdeki Dize, Boole, Sayılar ve Dizi'ye (tamsayı dizisi veya dize dizisi gibi) izin verir.

Değerler

Değerler şunlar olabilir: sayı, dize, boole veya dizi

İşleçler

Sayılar için kullanılabilir işleçler şunlardır:

NumberIn

Anahtar değeri belirtilen filtre değerlerinden biriyse NumberIn işleci true olarak değerlendirilir. Aşağıdaki örnekte, bölümündeki özniteliğin counter değerinin data 5 mi yoksa 1 mi olduğunu denetler.

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

Anahtar bir diziyse, dizideki tüm değerler filtre değerleri dizisine göre denetlenir. Anahtarı ve filtresini içeren sahte kod şu şekildedir: [v1, v2, v3][a, b, c]. Filtrenin veri türüyle eşleşmeyen veri türlerine sahip tüm anahtar değerler yoksayılır.

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

NumberNotIn

Anahtar değeri belirtilen filtre değerlerinden biri değilse NumberNotIn değeri true olarak değerlendirilir. Aşağıdaki örnekte, data bölümündeki counter özniteliğinin değerinin 41 ve 0 olmadığını kontrol eder.

"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

Anahtar değeri belirtilen filtre değerinden küçükse NumberLessThan işleci true olarak değerlendirilir. Aşağıdaki örnekte, data bölümündeki counter özniteliğinin değerinin 100'den küçük olup olmadığını kontrol eder.

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

Anahtar bir diziyse, dizideki tüm değerler filtre değerine göre denetlenir. Anahtarı ile sahte kod aşağıdadır: [v1, v2, v3]. Filtrenin veri türüyle eşleşmeyen veri türlerine sahip tüm anahtar değerler yoksayılır.

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

NumberGreaterThan

Anahtar değeri belirtilen filtre değerinden büyükse NumberGreaterThan işleci true olarak değerlendirilir. Aşağıdaki örnekte, data bölümündeki counter özniteliğinin değerinin 20'den büyük olup olmadığını denetler.

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

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

SayiKucukVeyaEsit

Anahtar değeri belirtilen filtre değerinden küçük veya buna eşitse NumberLessThanOrEquals işleci true olarak değerlendirilir. Aşağıdaki örnekte, data bölümündeki counter özniteliğinin değerinin 100'e eşit veya küçük olup olmadığını kontrol eder.

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

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

SayıBüyüktürVeyaEşittir

Anahtar değeri belirtilen filtre değerinden büyük veya buna eşitse NumberGreaterThanOrEquals işleci true olarak değerlendirilir. Aşağıdaki örnekte, data bölümündeki counter özniteliğinin değerinin 30'a büyük ya da eşit mi diye kontrol eder.

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

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

NumberInRange

Anahtar değeri belirtilen filtre aralıklarından birindeyse NumberInRange işleci true olarak değerlendirilir. Aşağıdaki örnekte, bölümdeki key1 özniteliğin değerinin data iki aralık arasında olup olmadığını denetler: 3.14159 - 999.95, 3000 - 4000.

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

values özelliği bir aralık dizisidir. Önceki örnekte, iki aralıklı bir dizidir. Denetlenecek tek aralıklı bir dizi örneği aşağıda verilmiştir.

Tek aralıklı dizi:

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

Anahtar bir diziyse, dizideki tüm değerler filtre değerleri dizisine göre denetlenir. Anahtara sahip sahte kod ve [v1, v2, v3] filtre: bir aralık dizisi. Bu sahte kodda a ve b dizideki her aralığın düşük ve yüksek değerleridir. Filtrenin veri türüyle eşleşmeyen veri türlerine sahip tüm anahtar değerler yoksayılır.

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

SayıAralığınDışında

Anahtar değeri belirtilen filtre aralıklarından birinde değilse NumberNotInRange işleci true olarak değerlendirilir. Aşağıdaki örnekte, bölümdeki key1 özniteliğin değerinin data iki aralık arasında olup olmadığını denetler: 3.14159 - 999.95, 3000 - 4000. Eğer öyleyse, operatör false döndürür.

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

values özelliği bir aralık dizisidir. Önceki örnekte, iki aralıklı bir dizidir. Denetlenecek tek aralıklı bir dizi örneği aşağıda verilmiştir.

Tek aralıklı dizi:

{
    "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

Boole'lar için kullanılabilir işleç şu şekildedir:

BoolEquals

Anahtar değeri belirtilen boole filtresi ise BoolEquals işleci true olarak değerlendirilir. Aşağıdaki örnekte, bölümündeki isEnabledözniteliğin data değerinin true olup olmadığını denetler.

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

Anahtar bir diziyse, dizideki tüm değerler filtre boole değeriyle denetlenir. Anahtarı ile sahte kod aşağıdadır: [v1, v2, v3]. Filtrenin veri türüyle eşleşmeyen veri türlerine sahip tüm anahtar değerler yoksayılır.

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

Dizeler için kullanılabilir işleçler şunlardır:

Dizeİçerir

StringContains içinde belirtilen filtre değerlerinden herhangi bir anahtardeğer içeriyorsa true olarak değerlendirilir (alt dizeler olarak). Aşağıdaki örnekte, bölümündeki özniteliğin key1 değerinin data belirtilen alt dizelerden birini içerip içermediğini denetler: microsoft veya azure. Örneğin, azure data factory içinde azure var.

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