Özel alanları Event Grid şemasına eşleme

  • Makale
  • Okumak için 3 dakika

Olay verileriniz beklenen Event Grid şemasıylaeşleşmiyorsa, etkinliği abonelere yönlendirmek için Event Grid kullanmaya devam edebilirsiniz. Bu makalede, şemanızın Event Grid şemasına nasıl eşleneceğini açıklanmaktadır.

Özgün olay şeması

Aşağıdaki biçimde olayları gönderen bir uygulamanız olduğunu varsayalım:

[
  {
    "myEventTypeField":"Created",
    "resource":"Users/example/Messages/1000",
    "resourceData":{"someDataField1":"SomeDataFieldValue"}
  }
]

Bu biçim gerekli şemayla eşleşmez, ancak Event Grid alanları şemayla eşlemenizi sağlar. Ya da özgün şemadaki değerleri alabilirsiniz.

Eşlenmiş alanlarla özel konu oluşturma

Özel bir konu oluştururken, özgün olayınızdan bulunan alanları Event Grid şemasına nasıl eşleneceğini belirtin. Eşlemeyi özelleştirmek için kullandığınız üç değer vardır:

  • Giriş şeması değeri şemanın türünü belirtir. Kullanılabilir seçenekler CloudEvents şeması, özel olay şeması veya Event Grid şemadır. Varsayılan değer Event Grid şemadır. Şemanız ve olay Kılavuzu şeması arasında özel eşleme oluştururken özel olay şeması kullanın. Olaylar CloudEvents biçiminde olduğunda, CloudEvents şeması ' nı kullanın.

  • Mapping default Values özelliği Event Grid şemasındaki alanlar için varsayılan değerleri belirtir. , Ve için varsayılan değerleri ayarlayabilirsiniz subject eventtype dataversion . Genellikle bu parametreyi, özel şemanız bu üç alandan birine karşılık gelen bir alan içermiyorsa kullanırsınız. Örneğin, veri sürümünün her zaman 1,0 olarak ayarlandığını belirtebilirsiniz.

  • Mapping Fields değeri, şemadaki alanları Event Grid şemasına eşler. Değerleri boşlukla ayrılmış anahtar/değer çiftlerinde belirtirsiniz. Anahtar adı için Event Grid alanının adını kullanın. Değer için, alanın adını kullanın. ,,,, Ve için anahtar adlarını kullanabilirsiniz id topic eventtime subject eventtype dataversion .

Azure CLı ile özel bir konu oluşturmak için şunu kullanın:

az eventgrid topic create \
  -n demotopic \
  -l eastus2 \
  -g myResourceGroup \
  --input-schema customeventschema \
  --input-mapping-fields eventType=myEventTypeField \
  --input-mapping-default-values subject=DefaultSubject dataVersion=1.0

PowerShell için şunu kullanın:

New-AzEventGridTopic `
  -ResourceGroupName myResourceGroup `
  -Name demotopic `
  -Location eastus2 `
  -InputSchema CustomEventSchema `
  -InputMappingField @{eventType="myEventTypeField"} `
  -InputMappingDefaultValue @{subject="DefaultSubject"; dataVersion="1.0" }

Event Grid 'e abone olma konusu

Özel konuya abone olurken, olayları almak için kullanmak istediğiniz şemayı belirtirsiniz. CloudEvents şeması, özel olay şeması veya Event Grid şemasını belirtirsiniz. Varsayılan değer Event Grid şemadır.

Aşağıdaki örnek bir Event Grid konusuna abone olur ve Event Grid şemasını kullanır. Azure CLI için şunu kullanın:

topicid=$(az eventgrid topic show --name demoTopic -g myResourceGroup --query id --output tsv)

az eventgrid event-subscription create \
  --source-resource-id $topicid \
  --name eventsub1 \
  --event-delivery-schema eventgridschema \
  --endpoint <endpoint_URL>

Sonraki örnek, olayın giriş şemasını kullanır:

az eventgrid event-subscription create \
  --source-resource-id $topicid \
  --name eventsub2 \
  --event-delivery-schema custominputschema \
  --endpoint <endpoint_URL>

Aşağıdaki örnek bir Event Grid konusuna abone olur ve Event Grid şemasını kullanır. PowerShell için şunu kullanın:

$topicid = (Get-AzEventGridTopic -ResourceGroupName myResourceGroup -Name demoTopic).Id

New-AzEventGridSubscription `
  -ResourceId $topicid `
  -EventSubscriptionName eventsub1 `
  -EndpointType webhook `
  -Endpoint <endpoint-url> `
  -DeliverySchema EventGridSchema

Sonraki örnek, olayın giriş şemasını kullanır:

New-AzEventGridSubscription `
  -ResourceId $topicid `
  -EventSubscriptionName eventsub2 `
  -EndpointType webhook `
  -Endpoint <endpoint-url> `
  -DeliverySchema CustomInputSchema

Etkinliği konuya Yayımla

Artık özel konuya bir olay göndermeye hazır olursunuz ve eşlemenin sonucunu görebilirsiniz. Örnek şemasındabir olay göndermek için aşağıdaki komut dosyası:

Azure CLI için şunu kullanın:

endpoint=$(az eventgrid topic show --name demotopic -g myResourceGroup --query "endpoint" --output tsv)
key=$(az eventgrid topic key list --name demotopic -g myResourceGroup --query "key1" --output tsv)

event='[ { "myEventTypeField":"Created", "resource":"Users/example/Messages/1000", "resourceData":{"someDataField1":"SomeDataFieldValue"} } ]'

curl -X POST -H "aeg-sas-key: $key" -d "$event" $endpoint

PowerShell için şunu kullanın:

$endpoint = (Get-AzEventGridTopic -ResourceGroupName myResourceGroup -Name demotopic).Endpoint
$keys = Get-AzEventGridTopicKey -ResourceGroupName myResourceGroup -Name demotopic

$htbody = @{
    myEventTypeField="Created"
    resource="Users/example/Messages/1000"
    resourceData= @{
        someDataField1="SomeDataFieldValue"
    }
}

$body = "["+(ConvertTo-Json $htbody)+"]"
Invoke-WebRequest -Uri $endpoint -Method POST -Body $body -Headers @{"aeg-sas-key" = $keys.Key1}

Şimdi Web kancası uç noktanıza bakın. İki abonelik, farklı şemalarda olay teslim edildi.

İlk kullanılan abonelik olay Kılavuzu şeması. Teslim edilen olayın biçimi:

{
  "id": "aa5b8e2a-1235-4032-be8f-5223395b9eae",
  "eventTime": "2018-11-07T23:59:14.7997564Z",
  "eventType": "Created",
  "dataVersion": "1.0",
  "metadataVersion": "1",
  "topic": "/subscriptions/<subscription-id>/resourceGroups/myResourceGroup/providers/Microsoft.EventGrid/topics/demotopic",
  "subject": "DefaultSubject",
  "data": {
    "myEventTypeField": "Created",
    "resource": "Users/example/Messages/1000",
    "resourceData": {
      "someDataField1": "SomeDataFieldValue"
    }
  }
}

Bu alanlar özel konudan eşlemeleri içerir. Myeventtypefield , EventType ile eşlendi. Dataversion ve Subject için varsayılan değerler kullanılır. Veri nesnesi, özgün olay şeması alanlarını içerir.

İkinci abonelik, giriş olay şemasını kullandı. Teslim edilen olayın biçimi:

{
  "myEventTypeField": "Created",
  "resource": "Users/example/Messages/1000",
  "resourceData": {
    "someDataField1": "SomeDataFieldValue"
  }
}

Özgün alanların teslim edildiğini unutmayın.

Sonraki adımlar