Aracılığıyla paylaş

Olay akışı tanımı

Bu makalede Eventstream öğeleri için tanım yapısının dökümü sağlanır.

Tanım bölümleri

Bu tabloda Eventstream tanım bölümleri listelenir.

Tanım bölümü yolu tür Gerekli Açıklama
eventstream.json Eventstream (JSON) ✅ Eventstream öğesinin topolojisini açıklama
eventstreamProperties.json EventstreamProperties (JSON) ❌ Olay Akışı meta verilerini açıklama
.platform PlatformDetails (JSON) ❌ Öğenin meta verilerini açıklar

Eventstream öğesinin her tanım bölümü aşağıdaki gibi oluşturulur:

Olay Akışı

Eventstream öğesinin topolojisini açıklama.

İsim Türü Gerekli Açıklama
sources Dizi doğru İşleme için Eventstream'e alınabilecek veri kaynaklarını açıklar.
destinations Dizi doğru Lakehouse, Eventhouse, Reflex ve diğerleri gibi işlenen verilerin yönlendirilebildiği Fabric içindeki uç noktaları açıklar.
operators Dizi doğru Filter, Aggregate, Group By ve Join gibi gerçek zamanlı veri akışlarını işleyen olay işlemcilerini tanımlayın.
streams Dizi doğru Gerçek Zamanlı Hub'da abonelik ve analiz için kullanılabilen veri akışlarını açıklar. İki tür akış vardır: varsayılan akışlar ve türetilmiş akışlar.

eventstream.json örnek

Eventstream öğesini açıklayan bir JSON dosyasının nasıl oluşturulacağını görmek için bkz. Eventstream REST API.

{
    "sources": [
        {
            "name": "myEventHub",
            "type": "AzureEventHub",
            "properties": {
                "dataConnectionId": "cc8271ee-8f72-473d-969c-6828f5fd0d45",
                "consumerGroupName": "$Default",
                "inputSerialization": {
                    "type": "Json",
                    "properties": {
                        "encoding": "UTF8"
                    }
                }
            }
        }
    ],
    "destinations": [
        {
            "name": "myLakehouse",
            "type": "Lakehouse",
            "properties": {
                "workspaceId": "fdf52f3a-b687-41b8-8ff8-aeeca4d1edd8",
                "itemId": "737d6a97-e88c-45e1-9c39-adf1c9c4e817",
                "schema": "",
                "deltaTable": "newTable",
                "minimumRows": 100000,
                "maximumDurationInSeconds": 120,
                "inputSerialization": {
                    "type": "Json",
                    "properties": {
                        "encoding": "UTF8"
                    }
                }
            },
            "inputNodes": [
                {
                    "name": "derivedStream"
                }
            ]
        }
    ],
    "streams": [
        {
            "name": "myEventstream-stream",
            "type": "DefaultStream",
            "properties": {},
            "inputNodes": [
                {
                    "name": "myEventHub"
                }
            ]
        },
        {
            "name": "derivedStream",
            "type": "DerivedStream",
            "properties": {
                "inputSerialization": {
                    "type": "Json",
                    "properties": {
                        "encoding": "UTF8"
                    }
                }
            },
            "inputNodes": [
                {
                    "name": "GroupBy"
                }
            ]
        }
    ],
    "operators": [
        {
            "name": "GroupBy",
            "type": "GroupBy",
            "inputNodes": [
                {
                    "name": "myEventstream-stream"
                }
            ],
            "properties": {
                "aggregations": [
                    {
                        "aggregateFunction": "Average",
                        "column": {
                            "expressionType": "ColumnReference",
                            "node": null,
                            "columnName": "payload",
                            "columnPathSegments": [
                                {
                                    "field": "ts_ms"
                                }
                            ]
                        },
                        "alias": "AVG_ts_ms"
                    }
                ],
                "groupBy": [],
                "window": {
                    "type": "Tumbling",
                    "properties": {
                        "duration": {
                            "value": 5,
                            "unit": "Minute"
                        },
                        "offset": {
                            "value": 1,
                            "unit": "Minute"
                        }
                    }
                }
            }
        }
    ],
    "compatibilityLevel": "1.0"
}

API yüküne yönelik bir Eventstream öğesi oluşturmak için GitHub şablonunu kullanarak bir Eventstream öğesi tanımlayabilirsiniz.

EventstreamProperties

Olay akışı meta verilerini açıklama.

İsim Türü Gerekli Açıklama
retentionTimeInDays Tam sayı ❌ Eventstream öğesinin bekletme günlerini açıklar. Varsayılan değer 1'dir. İzin verilen değer aralığı 1 ile 90 arasındadır.
eventThroughputLevel Sabit Listesi ❌ Eventstream öğesinin olay aktarım hızı düzeyini açıklar. Varsayılan değer Düşük'dür. İzin verilen değerler , Low, MediumHigh.

eventstreamProperties.json örnek

{
  "retentionTimeInDays": 1,
  "eventThroughputLevel": "Low"
}

Platform bölümü

Platform yükü isteğe bağlıdır. Platform bölümü, Eventstream meta veri bilgilerini içeren bir dosyadır.

  • Tanımı olan Öğe Oluşturma, sağlanırsa platform dosyasına göre belirlenir.
  • Öğe Al tanımı her zaman platform dosyasını döndürür.
  • Yeni bir URL parametresi updateMetadata=trueayarlarsanız, Öğe Güncelleştirme tanımı sağlanırsa platform dosyasını kabul eder.

Tanım örneği

Aşağıda Base64 kodlanmış olay akışı tanımı örneği verilmiştir. Burada Base64'ten kodlanmış yük içeriği örneğindeki içerik Base64'te kodlanır ve yolu olarak ayarlanmış eventstream.json alana yerleştirilirpayload:


{
  "displayName": "myEventstream",
  "type": "Eventstream",
  "description": "Create Eventstream item with definition",
  "definition": {
    "parts": [
      {
        "path": "eventstream.json",
        "payload": "<base64 encoded string>",
        "payloadType": "InlineBase64"
      },
      {
        "path": "eventstreamProperties.json",
        "payload": "<base64 encoded string>",
        "payloadType": "InlineBase64"
      },
      {
        "path": ".platform",
        "payload": "ZG90UGxhdGZvcm1CYXNlNjRTdHJpbmc=",
        "payloadType": "InlineBase64"
      }
    ]
  }
}
  • Last updated on