Muokkaa

Jaa

Eventstream definition

  • Artikkeli

This article provides a breakdown of the definition structure for Eventstream items.

Supported formats

Eventstream items support the JSON format.

Definition parts

Eventstream has different parts that make up its definition:

Example of payload content decoded from Base64

{
  "sources": [
    {
      "id": "1c2f8876-0616-4936-b44a-c96f153c5a09",
      "name": "AzureEventHub",
      "type": "AzureEventHub",
      "properties": {
        "dataConnectionId": "7b8187ad-4d58-4dc9-a953-4f6ac3636bef",
        "consumerGroupName": "$Default",
        "inputSerialization": {
          "type": "Json",
          "properties": {
            "encoding": "UTF8"
          }
        }
      }
    }
  ],
  "destinations": [
    {
      "id": "d843812d-c7b4-4bec-ae8c-74a553d07c66",
      "name": "kql",
      "type": "Eventhouse",
      "properties": {
        "dataIngestionMode": "ProcessedIngestion",
        "workspaceId": "0a47cd64-0aaf-488b-8038-4816153bd14b",
        "itemId": "5726a793-ccf2-4dd9-ac84-ec8f74aa22a2",
        "databaseName": "alex-eh2",
        "tableName": "table1016",
        "inputSerialization": {
          "type": "Json",
          "properties": {
            "encoding": "UTF8"
          }
        }
      },
      "inputNodes": []
    }
  ],
  "streams": [],
  "operators": [],
  "compatibilityLevel": "1.0"
}

Definition example


{
 "definition": {
  "parts": [
   {
    "path": "eventstream.json",
    "payload": "ew0KICAic291cmNlcyI6IFsNCiAgICB7DQogICAgICAiaWQiOiAiMWMyZjg4NzYtMDYxNi00OTM2LWI0NGEtYzk2ZjE1M2M1YTA5IiwNCiAgICAgICJuYW1lIjogIkF6dXJlRXZlbnRIdWIiLA0KICAgICAgInR5cGUiOiAiQXp1cmVFdmVudEh1YiIsDQogICAgICAicHJvcGVydGllcyI6IHsNCiAgICAgICAgImRhdGFDb25uZWN0aW9uSWQiOiAiN2I4MTg3YWQtNGQ1OC00ZGM5LWE5NTMtNGY2YWMzNjM2YmVmIiwNCiAgICAgICAgImNvbnN1bWVyR3JvdXBOYW1lIjogIiREZWZhdWx0IiwNCiAgICAgICAgImlucHV0U2VyaWFsaXphdGlvbiI6IHsNCiAgICAgICAgICAidHlwZSI6ICJKc29uIiwNCiAgICAgICAgICAicHJvcGVydGllcyI6IHsNCiAgICAgICAgICAgICJlbmNvZGluZyI6ICJVVEY4Ig0KICAgICAgICAgIH0NCiAgICAgICAgfQ0KICAgICAgfQ0KICAgIH0NCiAgXSwNCiAgImRlc3RpbmF0aW9ucyI6IFsNCiAgICB7DQogICAgICAiaWQiOiAiZDg0MzgxMmQtYzdiNC00YmVjLWFlOGMtNzRhNTUzZDA3YzY2IiwNCiAgICAgICJuYW1lIjogImtxbCIsDQogICAgICAidHlwZSI6ICJFdmVudGhvdXNlIiwNCiAgICAgICJwcm9wZXJ0aWVzIjogew0KICAgICAgICAiZGF0YUluZ2VzdGlvbk1vZGUiOiAiUHJvY2Vzc2VkSW5nZXN0aW9uIiwNCiAgICAgICAgIndvcmtzcGFjZUlkIjogIjBhNDdjZDY0LTBhYWYtNDg4Yi04MDM4LTQ4MTYxNTNiZDE0YiIsDQogICAgICAgICJpdGVtSWQiOiAiNTcyNmE3OTMtY2NmMi00ZGQ5LWFjODQtZWM4Zjc0YWEyMmEyIiwNCiAgICAgICAgImRhdGFiYXNlTmFtZSI6ICJhbGV4LWVoMiIsDQogICAgICAgICJ0YWJsZU5hbWUiOiAidGFibGUxMDE2IiwNCiAgICAgICAgImlucHV0U2VyaWFsaXphdGlvbiI6IHsNCiAgICAgICAgICAidHlwZSI6ICJKc29uIiwNCiAgICAgICAgICAicHJvcGVydGllcyI6IHsNCiAgICAgICAgICAgICJlbmNvZGluZyI6ICJVVEY4Ig0KICAgICAgICAgIH0NCiAgICAgICAgfQ0KICAgICAgfSwNCiAgICAgICJpbnB1dE5vZGVzIjogW10NCiAgICB9DQogIF0sDQogICJzdHJlYW1zIjogW10sDQogICJvcGVyYXRvcnMiOiBbXSwNCiAgImNvbXBhdGliaWxpdHlMZXZlbCI6ICIxLjAiDQp9",
    "payloadType": "InlineBase64"
   },
   {
    "path": ".platform",
    "payload": "ewogICIkc2NoZW1hIjogImh0dHBzOi8vZGV2ZWxvcGVyLm1pY3Jvc29mdC5jb20vanNvbi1zY2hlbWFzL2ZhYnJpYy9naXRJbnRlZ3JhdGlvbi9wbGF0Zm9ybVByb3BlcnRpZXMvMi4wLjAvc2NoZW1hLmpzb24iLAogICJtZXRhZGF0YSI6IHsKICAgICJ0eXBlIjogIkV2ZW50c3RyZWFtIiwKICAgICJkaXNwbGF5TmFtZSI6ICJhbGV4LWVzMSIKICB9LAogICJjb25maWciOiB7CiAgICAidmVyc2lvbiI6ICIyLjAiLAogICAgImxvZ2ljYWxJZCI6ICIwMDAwMDAwMC0wMDAwLTAwMDAtMDAwMC0wMDAwMDAwMDAwMDAiCiAgfQp9",
    "payloadType": "InlineBase64"
   }
  ]
 }
}