Event Grid kaynağı olarak Azure Event Hubs
Bu makalede event hubs olaylarının özellikleri ve şeması sağlanır. Olay şemalarına giriş için bkz . Azure Event Grid olay şeması.
Kullanılabilir olay türleri
Event Hubs, bir yakalama dosyası oluşturulduğunda Microsoft.EventHub.CaptureFileCreated olay türünü yayar.
Örnek olay
Bu örnek olay, yakalama özelliği bir dosyayı depoladığında tetiklenen olay hub'ları olayının şemasını gösterir:
[
{
"source": "/subscriptions/<guid>/resourcegroups/rgDataMigrationSample/providers/Microsoft.EventHub/namespaces/tfdatamigratens",
"subject": "eventhubs/hubdatamigration",
"type": "Microsoft.EventHub.CaptureFileCreated",
"time": "2017-08-31T19:12:46.0498024Z",
"id": "14e87d03-6fbf-4bb2-9a21-92bd1281f247",
"data": {
"fileUrl": "https://tf0831datamigrate.blob.core.windows.net/windturbinecapture/tfdatamigratens/hubdatamigration/1/2017/08/31/19/11/45.avro",
"fileType": "AzureBlockBlob",
"partitionId": "1",
"sizeInBytes": 249168,
"eventCount": 1500,
"firstSequenceNumber": 2400,
"lastSequenceNumber": 3899,
"firstEnqueueTime": "2017-08-31T19:12:14.674Z",
"lastEnqueueTime": "2017-08-31T19:12:44.309Z"
},
"specversion": "1.0"
}
]
Olay özellikleri
Bir olay aşağıdaki üst düzey verilere sahiptir:
Özellik | Türü | Veri Akışı Açıklaması |
---|---|---|
source |
Dize | Olay kaynağının tam kaynak yolu. Bu alan yazılabilir değil. Event Grid bu değeri sağlar. |
subject |
Dize | Olay konusunun yayımcı tarafından tanımlanan yolu. |
type |
Dize | Bu olay kaynağı için kayıtlı olay türlerinden biri. |
time |
Dize | Sağlayıcının UTC saati temelinde olayın oluşturulduğu saat. |
id |
Dize | Olayın benzersiz tanımlayıcısı. |
data |
nesne | Olay hub'ı olay verileri. |
specversion |
Dize | CloudEvents şema belirtimi sürümü. |
Veri nesnesi aşağıdaki özelliklere sahiptir:
Özellik | Türü | Veri Akışı Açıklaması |
---|---|---|
fileUrl |
Dize | Yakalama dosyasının yolu. |
fileType |
Dize | Yakalama dosyasının dosya türü. |
partitionId |
Dize | Parça kimliği. |
sizeInBytes |
integer | Dosya boyutu. |
eventCount |
integer | Dosyadaki olay sayısı. |
firstSequenceNumber |
integer | Kuyruktan en küçük sıra numarası. |
lastSequenceNumber |
integer | Kuyruktan gelen son sıra numarası. |
firstEnqueueTime |
Dize | Kuyruktan ilk kez. |
lastEnqueueTime |
Dize | Kuyruktan son kez. |
Öğreticiler ve nasıl yapılır kılavuzları
Ünvan | Açıklama |
---|---|
Öğretici: Büyük verileri veri ambarı içine akışla aktarma | Event Hubs bir Yakalama dosyası oluşturduğunda, Event Grid bir işlev uygulamasına bir olay gönderir. Uygulama Capture dosyasını alır ve verileri bir veri ambarı'na geçirir. |
Sonraki adımlar
- Azure Event Grid'e giriş için bkz. Event Grid nedir?
- Azure Event Grid aboneliği oluşturma hakkında daha fazla bilgi için bkz . Event Grid abonelik şeması.
- Olay hub'ları olaylarını işleme hakkında bilgi için bkz . Büyük verileri veri ambarına akışla aktarma.