Jaa

Eventstream – GitHub-integrointi

Seuraavassa artikkelissa kerrotaan Eventstreamin tiedostorakenteesta, kun ne on synkronoitu GitHub- tai Azure Devops -säilöön.

Kansiorakenne

Kun työtila on synkronoitu säilöön, näet työtilan ylimmän tason kansion ja alikansion kullekin synkronoidulle kohteelle. Jokainen alikansio on muotoiltu kohteen nimellä. Kohteen tyyppi

Näet seuraavat tiedostot eventstream-kansion sisällä:

  • Ympäristö: Määrittää kangasympäristön arvot, kuten Näyttönimi ja Kuvaus.
  • Ominaisuudet: Määrittää kohdekohtaiset arvot.

Tässä on esimerkki siitä, miltä kansiorakenne näyttää:

Repo

  • Työtila A
    • Item_A.Eventstream
      • .lava
      • EventstreamProperties.json
  • Työtila B
    • Item_C.Eventstream
      • .lava
      • EventstreamProperties.json

Eventstream-tiedostot

Seuraavat tiedostot sisältyvät eventstream-kansioon:

  • .lava

    Tiedosto käyttää seuraavaa rakennetta tapahtumavirran määrittämiseen:

    {
  "$schema": "https://developer.microsoft.com/json-schemas/fabric/gitIntegration/platformProperties/2.0.0/schema.json",
  "metadata": {
    "type": "Eventstream",
    "displayName": "",
    "description": ""
  },
  "config": {
    "version": "2.0",
    "logicalId": ""
  }
}

  • EventstreamProperties.json

    Tiedoston avulla voit määrittää ympäristötason asetukset eventstream-kohteelle. Tässä on mallitiedosto:

    {
    "sources": [
        {
            "name": "AzureEventHubSource",
            "type": "AzureEventHub",
            "properties": {
                "dataConnectionId": "aaaaaaaa-0000-1111-2222-bbbbbbbbbbbb",
                "consumerGroupName": "$Default",
                "inputSerialization": {
                    "type": "Json",
                    "properties": {
                        "encoding": "UTF8"
                    }
                }
            }
        },
        {
            "name": "AzureIoTHubSource",
            "type": "AzureIoTHub",
            "properties": {
                "dataConnectionId": "aaaaaaaa-0000-1111-2222-bbbbbbbbbbbb",
                "consumerGroupName": "$Default",
                "inputSerialization": {
                    "type": "Json",
                    "properties": {
                        "encoding": "UTF8"
                    }
                }
            }
        }
    ],
    "destinations": [
        {
            "name": "CustomEndpointDestination",
            "type": "CustomEndpoint",
            "properties": {},
            "inputNodes": [
                {
                    "name": "myEventstream-stream"
                }
            ]
        },
        {
            "name": "LakehouseDestination",
            "type": "Lakehouse",
            "properties": {
                "workspaceId": "00000000-0000-0000-0000-000000000000",
                "itemId": "aaaaaaaa-0000-1111-2222-bbbbbbbbbbbb",
                "schema": "dbo",
                "deltaTable": "deltaTable",
                "minimumRows": 100000,
                "maximumDurationInSeconds": 120,
                "inputSerialization": {
                    "type": "Json",
                    "properties": {
                        "encoding": "UTF8"
                    }
                }
            },
            "inputNodes": [
                {
                    "name": "myEventstream-stream"
                }
            ]
        }
    ],
    "streams": [
        {
            "name": "myEventstream-stream",
            "type": "DefaultStream",
            "properties": {},
            "inputNodes": [
                {
                    "name": "sourceName"
                }
            ]
        },
        {
            "name": "DerivedStreamName",
            "type": "DerivedStream",
            "properties": {
                "inputSerialization": {
                    "type": "Json",
                    "properties": {
                        "encoding": "UTF8"
                    }
                }
            },
            "inputNodes": [
                {
                    "name": "FilterName"
                }
            ]
        }
    ],
    "operators": [
        {
            "name": "FilterName",
            "type": "Filter",
            "inputNodes": [
                {
                    "name": "myEventstream-stream"
                }
            ],
            "properties": {
                "conditions": [
                    {
                        "column": {
                            "node": null,
                            "columnName": "BikepointID",
                            "columnPath": null,
                            "expressionType": "ColumnReference"
                        },
                        "operatorType": "NotEquals",
                        "value": {
                            "dataType": "Nvarchar(max)",
                            "value": "0",
                            "expressionType": "Literal"
                        }
                    }
                ]
            }
        }
    ],
    "compatibilityLevel": "1.0"
}

Täydellinen malli, joka sisältää kaikki lähde-, kohde- ja operaattorityypit, on kohdassa eventstream-definition.json.

Aiheeseen liittyvä sisältö

  • Last updated on