Topology - Get Eventstream Topology

Служба:: Eventstream

Версия API:: v1

Возвращает топологию указанного потока событий.

Разрешения

Вызывающий объект должен иметь разрешения на чтение для потока событий.

Обязательные делегированные области

Eventstream.Read.All или Eventstream.ReadWrite.All или Item.Read.All или Item.ReadWrite.All

поддерживаемые удостоверения Microsoft Entra

Этот API поддерживает Майкрософт identities, перечисленных в этом разделе.

Идентичность	Поддержка
Пользователь	Да
Представитель службы и управляемые удостоверения	Да

Интерфейс

GET https://api.fabric.microsoft.com/v1/workspaces/{workspaceId}/eventstreams/{eventstreamId}/topology

Параметры URI

Имя	В	Обязательно	Тип	Описание
eventstreamId	path	True	string (uuid)	Идентификатор потока событий.
workspaceId	path	True	string (uuid)	Идентификатор рабочей области.

Ответы

Имя Тип Описание

200 OK

Имя	Тип	Описание
200 OK	EventstreamTopologyResponse	Запрос успешно завершен.
429 Too Many Requests	ErrorResponse	Превышено ограничение скорости обслуживания. Сервер возвращает заголовок, указывающий `Retry-After` в секундах, сколько времени клиент должен ждать перед отправкой дополнительных запросов. Заголовки Retry-After: integer
Other Status Codes	ErrorResponse	Распространенные коды ошибок: ItemNotFound — запрошенный элемент не найден.

EventstreamTopologyResponse

Запрос успешно завершен.

429 Too Many Requests

ErrorResponse

Превышено ограничение скорости обслуживания. Сервер возвращает заголовок, указывающий Retry-After в секундах, сколько времени клиент должен ждать перед отправкой дополнительных запросов.

Заголовки

Retry-After: integer

Other Status Codes

ErrorResponse

Распространенные коды ошибок:

ItemNotFound — запрошенный элемент не найден.

Примеры

Get an eventstream topology example

Образец запроса

HTTP

GET https://api.fabric.microsoft.com/v1/workspaces/cfafbeb1-8037-4d0c-896e-a46fb27ff229/eventstreams/8c500070-073f-4a88-b478-8fabe1941c52/topology

Пример ответа

Код состояния:: 200

{
  "compatibilityLevel": "1.1",
  "sources": [
    {
      "id": "97554164-1b8f-410b-bb72-750f6e88f1c6",
      "name": "AzureEventGridNamespaceSource",
      "type": "AzureEventGridNamespace",
      "properties": {
        "namespaceResourceId": "/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/resourceGroupName/providers/Microsoft.EventGrid/namespaces/eventGridNamespaceName",
        "topic": "eea0a4ba-733a-4519-a20c-3c95f3840efa"
      },
      "status": "Running"
    },
    {
      "id": "514d0e11-cf65-44fb-a292-fc88a2a78618",
      "name": "AzureEventHubSource",
      "type": "AzureEventHub",
      "properties": {
        "dataConnectionId": "9c500070-073f-4a88-b478-8fabe1941c52",
        "consumerGroupName": "$Default",
        "inputSerialization": {
          "type": "Json",
          "properties": {
            "encoding": "UTF8"
          }
        }
      },
      "status": "Running"
    },
    {
      "id": "d1c9f8a2-8f3e-4c7c-b9b9-4e1b7b3a5f3f",
      "name": "AzureEventHubExtendedSource",
      "type": "AzureEventHubExtended",
      "properties": {
        "dataConnectionId": "7b0d2f83-1b3f-4f3b-a0f9-1d6b2f7b6c21",
        "consumerGroupName": "$Default",
        "startPosition": "Earliest"
      },
      "status": "Running"
    },
    {
      "id": "e2886002-d696-4c05-969c-51361365cc24",
      "name": "AzureIoTHubSource",
      "type": "AzureIoTHub",
      "properties": {
        "dataConnectionId": "8c500070-073f-4a88-b478-8fabe1941c52",
        "consumerGroupName": "$Default",
        "inputSerialization": {
          "type": "Json",
          "properties": {
            "encoding": "UTF8"
          }
        }
      },
      "status": "Running"
    },
    {
      "id": "7ff51116-df2c-4e47-bf4f-1b59f5f0ed17",
      "name": "AzureDataExplorerSource",
      "type": "AzureDataExplorer",
      "properties": {
        "dataConnectionId": "980bd823-8389-471b-a7cd-f5ac33b53061",
        "databaseName": "databaseName",
        "tableNames": "tableName1,tableName2"
      },
      "status": "Running"
    },
    {
      "id": "9fff8320-3e09-41b1-b417-d0d3879dd6f6",
      "name": "AzureServiceBusSource",
      "type": "AzureServiceBus",
      "properties": {
        "dataConnectionId": "765fd5a4-602c-4477-b0d5-918b416f94b4",
        "serviceBusType": "Topic",
        "topicOrQueueName": "topicName",
        "subscriptionName": "subscriptionExample"
      },
      "status": "Running"
    },
    {
      "id": "0d9bf4db-bc7f-4854-8579-6fdf244ed503",
      "name": "CustomEndpointSource",
      "type": "CustomEndpoint",
      "properties": {},
      "status": "Running"
    },
    {
      "id": "8b6b1b8e-9b7f-4a7d-8f6b-6f2a8b7c4b15",
      "name": "AzureBlobStorageEventsSource",
      "type": "AzureBlobStorageEvents",
      "properties": {
        "azureBlobStorageEvents": [
          {
            "id": "c1a7f10c-3b4a-4d1a-9f6f-1d2b3c4d5e6f",
            "azureResourceId": "/subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/resourceGroupName/providers/Microsoft.Storage/storageAccounts/storageAccountName",
            "includedEventTypes": [
              "Microsoft.Storage.BlobCreated",
              "Microsoft.Storage.BlobDeleted"
            ]
          }
        ],
        "streamEvents": true
      },
      "status": "Running"
    },
    {
      "id": "2e7b7f0f-6f1a-4d38-8b12-67d0e2d3e0b9",
      "name": "FabricCapacityOverviewEventsSource",
      "type": "FabricCapacityOverviewEvents",
      "properties": {
        "eventScope": "Capacity",
        "capacityId": "0b6d8e27-0b7b-4e18-9e5b-2e6b9d9d7e3a",
        "includedEventTypes": [
          "Microsoft.Fabric.Capacity.State",
          "Microsoft.Fabric.Capacity.Summary"
        ],
        "filters": [
          {
            "operatorType": "NumberIn",
            "key": "data.counter",
            "values": [
              5,
              1
            ]
          }
        ]
      },
      "status": "Running"
    },
    {
      "id": "f9c8c1e2-1c5b-4c2a-8f3a-1a2b3c4d5e6f",
      "name": "FabricJobEventsSource",
      "type": "FabricJobEvents",
      "properties": {
        "eventScope": "Workspace",
        "workspaceId": "9625b495-17b3-4d6c-aeea-a81ae76ba369",
        "itemId": "ee579458-85ea-4652-bd77-5c7d7c298b2a",
        "includedEventTypes": [
          "Microsoft.Fabric.Job.Started",
          "Microsoft.Fabric.Job.Completed"
        ],
        "filters": [
          {
            "operatorType": "StringIn",
            "key": "data.jobType",
            "values": [
              "Pipeline",
              "Notebook"
            ]
          }
        ]
      },
      "status": "Running"
    },
    {
      "id": "b7a6f5e4-3d2c-4b1a-9f8e-7d6c5b4a3f2e",
      "name": "FabricOneLakeEventsSource",
      "type": "FabricOneLakeEvents",
      "properties": {
        "tenantId": "cfafbeb1-8037-4d0c-896e-a46fb27ff229",
        "workspaceId": "9625b495-17b3-4d6c-aeea-a81ae76ba369",
        "itemId": "ee579458-85ea-4652-bd77-5c7d7c298b2a",
        "oneLakePaths": [
          "/Files/Events/",
          "/Tables/Telemetry/"
        ],
        "includedEventTypes": [
          "Microsoft.Fabric.OneLake.FileCreated",
          "Microsoft.Fabric.OneLake.FileDeleted"
        ],
        "filters": [
          {
            "operatorType": "StringEndsWith",
            "key": "data.path",
            "values": [
              ".json",
              ".csv"
            ]
          }
        ]
      },
      "status": "Running"
    },
    {
      "id": "e6d5c4b3-a2b1-4c5d-9e8f-7a6b5c4d3e2f",
      "name": "FabricWorkspaceItemEventsSource",
      "type": "FabricWorkspaceItemEvents",
      "properties": {
        "eventScope": "Item",
        "workspaceId": "9625b495-17b3-4d6c-aeea-a81ae76ba369",
        "itemId": "4c8c3353-9652-4567-b8f3-eb585ef01ba9",
        "includedEventTypes": [
          "Microsoft.Fabric.Item.Created",
          "Microsoft.Fabric.Item.Deleted"
        ],
        "filters": [
          {
            "operatorType": "StringIn",
            "key": "data.itemType",
            "values": [
              "Lakehouse",
              "Notebook"
            ]
          }
        ]
      },
      "status": "Running"
    },
    {
      "id": "19258e62-4de9-4c52-b45e-71502dc2ddea",
      "name": "SampleDataSource",
      "type": "SampleData",
      "properties": {
        "type": "Bicycles"
      },
      "status": "Running"
    },
    {
      "id": "7afaa265-1d67-416f-8183-e6e1b1ebb4ea",
      "name": "AmazonKinesisSource",
      "type": "AmazonKinesis",
      "properties": {
        "dataConnectionId": "2e4c91e7-0c4a-4cc4-abe3-cc7ba4310a37",
        "region": "us-east-1",
        "startPosition": "AtTimestamp",
        "startTimestamp": "2024-01-15T10:30:00Z"
      },
      "status": "Running"
    },
    {
      "id": "d020dd19-e84c-42e1-b4be-87e58145e1b5",
      "name": "AmazonMSKKafkaSource",
      "type": "AmazonMSKKafka",
      "properties": {
        "dataConnectionId": "2e4c91e7-0c4a-4cc4-abe3-cc7ba4310a37",
        "topic": "topic",
        "consumerGroupName": "consumerGroupName",
        "autoOffsetReset": "Earliest",
        "saslMechanism": "PLAIN",
        "securityProtocol": "SASL_PLAINTEXT"
      },
      "status": "Running"
    },
    {
      "id": "03a6dd4a-4627-422f-a287-2ccd7daf903d",
      "name": "ApacheKafkaSource",
      "type": "ApacheKafka",
      "properties": {
        "dataConnectionId": "2e4c91e7-0c4a-4cc4-abe3-cc7ba4310a37",
        "topic": "topic",
        "consumerGroupName": "consumerGroupName",
        "autoOffsetReset": "Latest",
        "saslMechanism": "SCRAM-SHA-512",
        "securityProtocol": "SASL_SSL"
      },
      "status": "Running"
    },
    {
      "id": "6f493321-6c12-40c6-9980-c2aa38804829",
      "name": "ConfluentCloudSource",
      "type": "ConfluentCloud",
      "properties": {
        "dataConnectionId": "2e4c91e7-0c4a-4cc4-abe3-cc7ba4310a37",
        "topic": "topic",
        "consumerGroupName": "consumerGroupName",
        "autoOffsetReset": "Earliest"
      },
      "status": "Running"
    },
    {
      "id": "e7f88779-0349-47e3-bead-85afc9d3c9a4",
      "name": "AzureCosmosDBCDCSource",
      "type": "AzureCosmosDBCDC",
      "properties": {
        "dataConnectionId": "2e4c91e7-0c4a-4cc4-abe3-cc7ba4310a37",
        "containerName": "containerName",
        "databaseName": "databaseName",
        "offsetPolicy": "Earliest"
      },
      "status": "Running"
    },
    {
      "id": "da5ed80d-c672-4809-a7ac-6224aa2ab2c7",
      "name": "AzureSQLDBCDCSource",
      "type": "AzureSQLDBCDC",
      "properties": {
        "dataConnectionId": "2e4c91e7-0c4a-4cc4-abe3-cc7ba4310a37",
        "tableName": "tableName",
        "decimalHandlingMode": "Precise"
      },
      "status": "Running"
    },
    {
      "id": "745e401f-aac6-463f-b107-c336a2440abe",
      "name": "AzureSQLMIDBCDCSource",
      "type": "AzureSQLMIDBCDC",
      "properties": {
        "dataConnectionId": "2e4c91e7-0c4a-4cc4-abe3-cc7ba4310a37",
        "tableName": "tableName",
        "decimalHandlingMode": "Double"
      },
      "status": "Running"
    },
    {
      "id": "759842ab-a968-498d-9f37-f46297da8b07",
      "name": "SQLServerOnVMDBCDCSource",
      "type": "SQLServerOnVMDBCDC",
      "properties": {
        "dataConnectionId": "2e4c91e7-0c4a-4cc4-abe3-cc7ba4310a37",
        "tableName": "tableName",
        "decimalHandlingMode": "String"
      },
      "status": "Running"
    },
    {
      "id": "9791cd2a-19fb-4991-b878-2b061420a460",
      "name": "MySQLCDCSource",
      "type": "MySQLCDC",
      "properties": {
        "dataConnectionId": "2e4c91e7-0c4a-4cc4-abe3-cc7ba4310a37",
        "tableName": "tableName",
        "serverId": 9,
        "port": 3306,
        "snapshotLockingMode": "Minimal"
      },
      "status": "Running"
    },
    {
      "id": "57b3394b-bcf3-479a-952b-22a815e1d684",
      "name": "PostgreSQLCDCSource",
      "type": "PostgreSQLCDC",
      "properties": {
        "dataConnectionId": "2e4c91e7-0c4a-4cc4-abe3-cc7ba4310a37",
        "tableName": "tableName",
        "slotName": "slotName",
        "port": 5432,
        "publicationName": "my_publication",
        "publicationAutoCreateMode": "Filtered"
      },
      "status": "Running"
    },
    {
      "id": "a3c1d2e4-5f67-4890-abcd-ef1234567890",
      "name": "MongoDBCDCSource",
      "type": "MongoDBCDC",
      "properties": {
        "dataConnectionId": "2e4c91e7-0c4a-4cc4-abe3-cc7ba4310a37",
        "includedDatabases": "db1,db2",
        "includedCollections": "collection1,collection2",
        "snapshotMode": "Initial"
      },
      "status": "Running"
    },
    {
      "id": "d5f702ca-8b2b-4ac5-88e7-50697cb1b207",
      "name": "GooglePubSubSource",
      "type": "GooglePubSub",
      "properties": {
        "dataConnectionId": "2e4c91e7-0c4a-4cc4-abe3-cc7ba4310a37"
      },
      "status": "Running"
    },
    {
      "id": "0d61c91a-6b1d-4f4f-8e9a-1a7ef0f4d4f1",
      "name": "HttpSource",
      "type": "Http",
      "properties": {
        "dataConnectionId": "9dfcf6c1-0b38-4d53-9a2f-7b7f7d3f1a4b",
        "method": "GET",
        "requestHeaders": [
          {
            "key": "Accept",
            "value": "application/json"
          }
        ],
        "requestParameters": [
          {
            "key": "country",
            "value": "US"
          }
        ],
        "requestBody": "{\"query\":\"sample\"}",
        "pollIntervalMs": 60000,
        "maxRetries": 3,
        "retryBackoffMs": 2000,
        "retriableHttpStatusCodes": "408,423,429"
      },
      "status": "Running"
    },
    {
      "id": "77640306-3525-45cb-978c-f2ce6f1d2605",
      "name": "MqttSource",
      "type": "Mqtt",
      "properties": {
        "dataConnectionId": "6950656c-9f6d-48e8-b7d1-6cf9eb7cca28",
        "serverVersion": "V5",
        "topic": "mqttTopicName"
      },
      "status": "Running"
    },
    {
      "id": "bf273a56-dcb7-4cb1-8be4-5620f769fe1f",
      "name": "RealTimeWeatherSource",
      "type": "RealTimeWeather",
      "properties": {
        "latitude": -22.690611,
        "longitude": -45.7846301
      },
      "status": "Running"
    },
    {
      "id": "a612baf7-4d64-4522-8850-44847c99016c",
      "name": "SolacePubSubSource",
      "type": "SolacePubSub",
      "properties": {
        "dataConnectionId": "684e1958-5999-4f3f-bfe5-e19dd55f9cbf",
        "pubSubType": "Topics",
        "messageVpnName": "messageVpnName",
        "topics": [
          "topicName1",
          "topicName2"
        ],
        "mapUserProperties": false,
        "mapSolaceProperties": false
      },
      "status": "Running"
    }
  ],
  "destinations": [
    {
      "id": "4642073b-c216-4675-a17c-ed2e75756330",
      "name": "CustomEndpointDestination",
      "type": "CustomEndpoint",
      "properties": {},
      "inputNodes": [
        {
          "name": "DerivedStreamName"
        }
      ],
      "status": "Running"
    },
    {
      "id": "e1e2d0cc-87e5-46d9-977d-2a8eede7bef0",
      "name": "LakehouseDestination",
      "type": "Lakehouse",
      "properties": {
        "workspaceId": "9625b495-17b3-4d6c-aeea-a81ae76ba369",
        "itemId": "ee579458-85ea-4652-bd77-5c7d7c298b2a",
        "schema": "dbo",
        "deltaTable": "deltaTable",
        "minimumRows": 100000,
        "maximumDurationInSeconds": 120,
        "inputSerialization": {
          "type": "Json",
          "properties": {
            "encoding": "UTF8"
          }
        }
      },
      "inputNodes": [
        {
          "name": "DerivedStreamName"
        }
      ],
      "status": "Running"
    },
    {
      "id": "49b5d6ec-f8af-4ae9-a4d6-5e94645efe1f",
      "name": "EventhouseProcessedIngestionModeDestination",
      "type": "Eventhouse",
      "properties": {
        "dataIngestionMode": "ProcessedIngestion",
        "workspaceId": "9625b495-17b3-4d6c-aeea-a81ae76ba369",
        "itemId": "4c8c3353-9652-4567-b8f3-eb585ef01ba9",
        "databaseName": "databaseName",
        "tableName": "tableName",
        "inputSerialization": {
          "type": "Json",
          "properties": {
            "encoding": "UTF8"
          }
        }
      },
      "inputNodes": [
        {
          "name": "EventStreamName-stream"
        }
      ],
      "status": "Running"
    },
    {
      "id": "c0ca1c2a-b8c5-482c-98da-40088f988e9c",
      "name": "EventhouseDirectIngestionModeDestination",
      "type": "Eventhouse",
      "properties": {
        "dataIngestionMode": "DirectIngestion",
        "workspaceId": "9625b495-17b3-4d6c-aeea-a81ae76ba369",
        "itemId": "4c8c3353-9652-4567-b8f3-eb585ef01ba9",
        "connectionName": "connectionName",
        "mappingRuleName": "mappingRuleName"
      },
      "inputNodes": [
        {
          "name": "EventStreamName-stream"
        }
      ],
      "status": "External"
    }
  ],
  "streams": [
    {
      "id": "8eff3cbe-f452-4d7f-bc2d-f35b4359c917",
      "name": "Eventstream-stream",
      "type": "DefaultStream",
      "properties": {},
      "inputNodes": [
        {
          "name": "AzureEventHubSource"
        }
      ]
    },
    {
      "id": "0f6f0dd8-9de2-48e2-92e7-e15b755b22a6",
      "name": "DerivedStreamName",
      "type": "DerivedStream",
      "properties": {
        "inputSerialization": {
          "type": "Json",
          "properties": {
            "encoding": "UTF8"
          }
        }
      },
      "inputNodes": [
        {
          "name": "FilterName"
        }
      ]
    }
  ],
  "operators": [
    {
      "name": "FilterName",
      "type": "Filter",
      "inputNodes": [
        {
          "name": "EventStreamName-stream"
        }
      ],
      "properties": {
        "conditions": [
          {
            "column": {
              "node": "nodeName",
              "columnName": "columnName",
              "columnPathSegments": [
                "path",
                "to",
                "column"
              ]
            },
            "operatorType": "Equals",
            "value": {
              "dataType": "Nvarchar(max)",
              "value": "stringValue"
            }
          }
        ]
      },
      "inputSchemas": [
        {
          "name": "EventStreamName-stream",
          "schema": {
            "columns": [
              {
                "name": "BikepointID",
                "type": "Nvarchar(max)",
                "fields": null,
                "items": null
              },
              {
                "name": "Street",
                "type": "Nvarchar(max)",
                "fields": null,
                "items": null
              },
              {
                "name": "Neighbourhood",
                "type": "Nvarchar(max)",
                "fields": null,
                "items": null
              },
              {
                "name": "Latitude",
                "type": "Float",
                "fields": null,
                "items": null
              },
              {
                "name": "Longitude",
                "type": "Float",
                "fields": null,
                "items": null
              },
              {
                "name": "No_Bikes",
                "type": "BigInt",
                "fields": null,
                "items": null
              },
              {
                "name": "No_Empty_Docks",
                "type": "BigInt",
                "fields": null,
                "items": null
              },
              {
                "name": "Record_Example",
                "type": "Record",
                "fields": [
                  {
                    "name": "column1",
                    "type": "BigInt"
                  },
                  {
                    "name": "column2",
                    "type": "Nvarchar(max)"
                  }
                ]
              },
              {
                "name": "Array_Example",
                "type": "Array",
                "items": {
                  "type": "BigInt"
                }
              }
            ]
          }
        }
      ]
    },
    {
      "name": "JoinerName",
      "type": "Join",
      "inputNodes": [
        {
          "name": "FilterName"
        },
        {
          "name": "DerivedStreamName"
        }
      ],
      "properties": {
        "joinType": "Inner",
        "joinOn": [
          {
            "left": {
              "node": "leftNodeName",
              "columnName": "leftColumnName"
            },
            "right": {
              "node": "rightNodeName",
              "columnName": "rightColumnName"
            }
          }
        ],
        "duration": {
          "value": 1,
          "unit": "Minute"
        }
      }
    },
    {
      "name": "FieldsManagerName",
      "type": "ManageFields",
      "inputNodes": [
        {
          "name": "DerivedStreamName"
        }
      ],
      "properties": {
        "columns": [
          {
            "type": "Rename",
            "properties": {
              "column": {
                "node": "renameNode",
                "columnName": "renameColumn"
              }
            },
            "alias": "renameAlias"
          },
          {
            "type": "Cast",
            "properties": {
              "targetDataType": "BigInt",
              "column": {
                "node": "castNode",
                "columnName": "castColumn"
              }
            },
            "alias": "castAlias"
          },
          {
            "type": "FunctionCall",
            "properties": {
              "functionName": "CharIndex",
              "arguments": [
                "a",
                {
                  "node": "functionCallNode",
                  "columnName": "functionCallColumn"
                },
                1
              ]
            },
            "alias": "indexOf"
          }
        ]
      },
      "inputSchemas": [
        {
          "name": "DerivedStreamName",
          "schema": {
            "columns": [
              {
                "name": "BikepointID",
                "type": "Nvarchar(max)",
                "fields": null,
                "items": null
              },
              {
                "name": "Street",
                "type": "Nvarchar(max)",
                "fields": null,
                "items": null
              },
              {
                "name": "Neighbourhood",
                "type": "Nvarchar(max)",
                "fields": null,
                "items": null
              },
              {
                "name": "Latitude",
                "type": "Float",
                "fields": null,
                "items": null
              },
              {
                "name": "Longitude",
                "type": "Float",
                "fields": null,
                "items": null
              },
              {
                "name": "No_Bikes",
                "type": "BigInt",
                "fields": null,
                "items": null
              },
              {
                "name": "No_Empty_Docks",
                "type": "BigInt",
                "fields": null,
                "items": null
              }
            ]
          }
        }
      ]
    },
    {
      "name": "AggregatorName",
      "type": "Aggregate",
      "inputNodes": [
        {
          "name": "DerivedStreamName"
        }
      ],
      "properties": {
        "aggregations": [
          {
            "aggregationFunction": "Average",
            "column": {
              "node": "aggregationNode",
              "columnName": "aggregationColumn"
            },
            "alias": "aggregatedAlias",
            "partitionBy": [
              {
                "node": "partitionByNode",
                "columnName": "partitionByColumn"
              }
            ],
            "duration": {
              "value": 1,
              "unit": "Minute"
            }
          }
        ]
      }
    },
    {
      "name": "GroupByName",
      "type": "GroupBy",
      "inputNodes": [
        {
          "name": "DerivedStreamName"
        }
      ],
      "properties": {
        "aggregations": [
          {
            "aggregationFunction": "Average",
            "column": {
              "node": "groupByAggregationNode",
              "columnName": "groupByAggregationColumn"
            },
            "alias": "groupByAggregationAlias"
          }
        ],
        "groupBy": [
          {
            "node": "groupByNode",
            "columnName": "groupByColumn"
          }
        ],
        "window": {
          "type": "Tumbling",
          "properties": {
            "duration": {
              "value": 5,
              "unit": "Minute"
            },
            "offset": {
              "value": 1,
              "unit": "Minute"
            }
          }
        }
      }
    },
    {
      "name": "UnionName",
      "type": "Union",
      "inputNodes": [
        {
          "name": "FilterName"
        },
        {
          "name": "GroupByName"
        }
      ],
      "properties": {}
    },
    {
      "name": "ExpansionName",
      "type": "Expand",
      "inputNodes": [
        {
          "name": "MyNode"
        }
      ],
      "properties": {
        "column": [
          {
            "node": "expansionNode",
            "columnName": "expansionColumn"
          }
        ],
        "ignoreMissingOrEmpty": true
      }
    },
    {
      "name": "SQLName",
      "type": "SQL",
      "inputNodes": [
        {
          "name": "MyNode"
        }
      ],
      "properties": {
        "query": "SELECT * INTO [MyStream] FROM [MyNode]",
        "advancedSettings": {
          "eventsOutOfOrderPolicy": "Adjust",
          "eventsOutOfOrderMaxDelayInSeconds": 5,
          "eventsLateArrivalMaxDelayInSeconds": 300
        }
      }
    }
  ]
}

Определения

Имя	Описание
ActivatorDestinationProperties	Свойства назначения активатора.
ActivatorDestinationResponse	Ответ назначения активатора.
AdvancedSettings	Дополнительные параметры для оператора SQL.
AggregateOperator	Оператор агрегата.
AggregateOperatorProperties	Свойства агрегатного оператора.
Aggregation	Представляет агрегирование в столбце.
AggregationFunction	Функция агрегирования.
AmazonKinesisSourceProperties	Свойства источника Amazon Kinesis.
AmazonKinesisSourceResponse	Ответ исходных свойств Amazon Kinesis.
AmazonMSKKafkaSourceProperties	Свойства источника Amazon MSK Kafka.
AmazonMSKKafkaSourceResponse	Ответ источника Amazon MSK Kafka.
ApacheKafkaSourceProperties	Свойства источника Apache Kafka.
ApacheKafkaSourceResponse	Ответ источника Apache Kafka.
AutoOffsetReset	Свойство автоматического сброса смещения. Значение по умолчанию — None.
AvroSerializationInfo	Сведения о сериализации Avro.
AvroSerializationProperties	Свойства сериализации Avro.
AzureBlobStorageEvents	Хранилище BLOB-объектов Azure источник событий.
AzureBlobStorageEventsSourceProperties	Хранилище BLOB-объектов Azure свойства источника событий.
AzureBlobStorageEventsSourceResponse	Хранилище BLOB-объектов Azure ответ источника событий.
AzureCosmosDBCDCSourceProperties	Azure Cosmos DB свойства источника CDC.
AzureCosmosDBCDCSourceResponse	Azure Cosmos DB ответ источника CDC.
AzureDataExplorerSourceProperties	Azure Data Explorer свойства источника.
AzureDataExplorerSourceResponse	Azure Data Explorer исходный ответ.
AzureEventGridNamespaceSourceProperties	Сетка событий Azure свойства источника пространства имен.
AzureEventGridNamespaceSourceResponse	ответ источника пространства имен Сетка событий Azure.
AzureEventHubExtendedSourceProperties	Azure свойства расширенного источника концентратора событий.
AzureEventHubExtendedSourceResponse	Azure ответ расширенного источника концентратора событий.
AzureEventHubSourceProperties	Azure свойства источника Концентратора событий.
AzureEventHubSourceResponse	Azure ответ источника Концентратора событий.
AzureIoTHubSourceProperties	Центр Интернета вещей Azure свойства источника.
AzureIoTHubSourceResponse	Центр Интернета вещей Azure ответ источника.
AzureServiceBusSourceProperties	Служебная шина Azure свойства источника.
AzureServiceBusSourceResponse	Служебная шина Azure исходный ответ.
AzureSQLDBCDCSourceResponse	Azure SQL ответ источника CDC базы данных.
AzureSQLMIDBCDCSourceResponse	Azure SQL ответ источника MI DB CDC.
BaseKafkaSourceProperties	Базовые свойства источника Kafka.
BaseSQLCDCSourceProperties	Базовые свойства источника SQL CDC.
CastProperties	Свойства операции приведения.
ColumnReferenceExpression	Представляет ссылку на столбец.
ColumnSchema	Представляет схему столбца.
CompatibilityLevel	Представляет уровень совместимости топологии Eventstream. С течением времени могут добавляться дополнительные уровни совместимости.
ConfluentCloudSourceResponse	Ответ источника Confluent Cloud.
CsvSerializationInfo	Сведения о сериализации CSV.
CsvSerializationProperties	Свойства сериализации CSV.
CustomEndpointDestinationProperties	Свойства назначения событий пользовательской конечной точки.
CustomEndpointDestinationResponse	Ответ назначения событий пользовательской конечной точки.
CustomEndpointSourceProperties	Свойства источника событий пользовательской конечной точки.
CustomEndpointSourceResponse	Ответ источника событий пользовательской конечной точки.
DataType	Представляет тип данных. С течением времени могут добавляться дополнительные типы данных.
DecimalHandlingMode	Указывает, как десятичные значения представлены соединителем (точные десятичные, двойные или строки).
DefaultStreamProperties	Свойства потока по умолчанию.
DefaultStreamResponse	Ответ потока по умолчанию.
DerivedStreamProperties	Производные свойства потока.
DerivedStreamResponse	Производный ответ потока.
DestinationType	Представляет тип назначения. С течением времени могут добавляться дополнительные типы назначения.
Encoding	Тип кодирования.
ErrorInfo	Представляет сведения об ошибке.
ErrorRelatedResource	Объект сведений об ошибках, связанных с ресурсом.
ErrorResponse	Ответ на ошибку.
ErrorResponseDetails	Сведения об ответе на ошибку.
EventhouseDestinationResponse	Ответ назначения eventhouse.
EventhouseDirectIngestionModeDestinationProperties	Свойства назначения режима directIngestion eventhouse.
EventhouseProcessedIngestionModeDestinationProperties	Свойства назначения режима обработки eventhouse ProcessedIngestion.
EventScope
EventsOutOfOrderPolicy	Политика обработки событий, поступающих из порядка. С течением времени могут добавляться дополнительные политики.
EventstreamTopologyResponse	Представляет ответ топологии Eventstream.
ExpandOperator	Оператор развертывания.
ExpandOperatorProperties	Разверните свойства оператора.
FabricCapacityOverviewEventsSourceProperties	Fabric свойства источника событий обзора емкости.
FabricCapacityOverviewEventsSourceResponse	Fabric ответ источника событий обзора емкости.
FabricJobEventsSourceProperties	Fabric свойства источника событий задания.
FabricJobEventsSourceResponse	Fabric ответ источника событий задания.
FabricOneLakeEventsSourceProperties	Fabric свойства источника OneLake Events.
FabricOneLakeEventsSourceResponse	Fabric ответ источника Событий OneLake.
FabricWorkspaceItemEventsSourceProperties	Fabric свойства источника событий элемента рабочей области.
FabricWorkspaceItemEventsSourceResponse	ответ источника событий элементов рабочей области Fabric.
FilterCondition	Представляет условие фильтра.
FilterOperator	Оператор фильтра.
FilterOperatorProperties	Свойства оператора фильтра.
Format	Тип формата.
FunctionCallProperties	Свойства для операции вызова функции.
GooglePubSubSourceProperties	Свойства источника Google Pub/Sub.
GooglePubSubSourceResponse	Ответ источника Google Pub/Sub.
GroupByOperator	Оператор GroupBy.
GroupByOperatorProperties	Свойства оператора GroupBy.
HoppingWindow
HoppingWindowProperties	Свойства для окна прыжка.
HttpMethod	Метод HTTP. С течением времени могут добавляться дополнительные методы.
HttpSourceProperties	Свойства источника HTTP.
HttpSourceResponse	Ответ источника HTTP.
IncludedEventTypes	Включенные типы событий. С течением времени могут добавляться дополнительные типы событий.
InColumnAggregation	Представляет агрегирование в столбце.
InputSchema	Представляет входную схему источника, назначения или оператора.
JoinOn	Представляет условие соединения.
JoinOperator	Оператор соединения.
JoinOperatorProperties	Свойства оператора Join.
JoinType	Тип соединения.
JsonSerializationInfo	Сведения о сериализации JSON.
JsonSerializationProperties	Свойства сериализации JSON.
KeyStringValuePair
LakehouseDestinationProperties	Свойства назначения Lakehouse.
LakehouseDestinationResponse	Ответ назначения Lakehouse.
LiteralExpression	Представляет литеральное выражение.
ManageFieldsCastOperation	Представляет операцию приведения полей управления.
ManageFieldsFunctionCallOperation	Представляет операцию вызова функции управления полями.
ManageFieldsOperator	Оператор ManageFields.
ManageFieldsOperatorProperties	Свойства оператора ManageFields.
ManageFieldsRenameOperation	Представляет операцию переименования полей управления.
MongoDBCDCSourceProperties	Свойства источника MongoDB CDC.
MongoDBCDCSourceResponse	Ответ источника MongoDB CDC.
MqttSourceProperties	Свойства источника MQTT.
MqttSourceResponse	Ответ источника MQTT.
MySQLCDCSourceProperties	Свойства источника MySQL CDC.
MySQLCDCSourceResponse	Ответ источника MySQL CDC.
NodeReference	Представляет ссылку на узел с помощью уникального имени.
NodeStatus	Состояние узла. С течением времени может быть добавлено дополнительное состояние узла.
OffsetPolicy	Политика смещения.
OperatorCommonDuration	Представляет длительность.
OperatorType	Тип оператора.
PostgreSQLCDCSourceProperties	Свойства источника POSTgreSQL CDC.
PostgreSQLCDCSourceResponse	Ответ источника CDC PostgreSQL.
PublicationAutoCreateMode	Режим автоматического создания публикации.
RealTimeWeatherSourceProperties	Свойства источника погоды в режиме реального времени.
RealTimeWeatherSourceResponse	Ответ источника погоды в режиме реального времени.
Region	Имя региона Amazon Kinesis. С течением времени могут добавляться дополнительные регионы.
RenameProperties	Свойства для операции переименования.
SampleDataSourceProperties	Примеры свойств источника данных.
SampleDataSourceResponse	Пример ответа источника событий данных.
SaslMechanism	Механизм SASL. С течением времени могут добавляться дополнительные механизмы SASL.
Schema	Представляет схему данных.
SecurityProtocol	Протокол безопасности.
SerializationType	Тип сериализации. С течением времени могут добавляться дополнительные типы сериализации.
ServerVersion	Версия сервера MQTT.
SessionWindow
SessionWindowProperties	Свойства для окна сеанса.
SlidingWindow
SlidingWindowProperties	Свойства скользящего окна.
SnapshotLockingMode	Указывает стратегию блокировки, используемую при принятии начального моментального снимка (например, минимальные блокировки и расширенная блокировка для более строгой согласованности).
SnapshotMode	Режим моментального снимка.
SnapshotWindow
SnapshotWindowProperties	Свойства окна моментального снимка.
SolacePubSubQueueSourceProperties	Свойства источника очереди Solace PubSub.
SolacePubSubSourceResponse	Ответ источника Solace PubSub.
SolacePubSubTopicsSourceProperties	Исходные свойства разделов Solace PubSub.
SourceType	Представляет тип источника. С течением времени могут добавляться дополнительные типы источников.
SqlOperator	Оператор SQL.
SqlOperatorProperties	Свойства оператора SQL.
SQLServerOnVMDBCDCSourceResponse	Azure SQL Server в ответе источника CDC базы данных виртуальной машины.
StartPosition	Начальная позиция в потоке концентратора событий Azure.
StreamType	Представляет тип потока. С течением времени могут добавляться дополнительные типы потоков.
TumblingWindow
TumblingWindowProperties	Свойства для переворачивающегося окна.
Type	Пример типа данных. С течением времени могут добавляться дополнительные примеры типов данных.
UnionOperator	Оператор union.
UnionOperatorProperties	Свойства оператора union.
Unit	Единица длительности.

ActivatorDestinationProperties

Объект

Свойства назначения активатора.

Имя	Тип	Описание
inputSerialization	SerializationInfo: AvroSerializationInfo CsvSerializationInfo JsonSerializationInfo	Сведения о сериализации.
itemId	string (uuid)	Идентификатор элемента активатора.
workspaceId	string (uuid)	Идентификатор рабочей области Активатора.

ActivatorDestinationResponse

Объект

Ответ назначения активатора.

Имя	Тип	Описание
error	ErrorInfo	Сведения об ошибке.
id	string (uuid)	Уникальный идентификатор назначения.
inputNodes	NodeReference[]	Список ссылок на входные узлы назначения.
inputSchemas	InputSchema[]	Входные схемы назначения.
name	string	Уникальное имя назначения.
properties	ActivatorDestinationProperties	Свойства назначения Активатора.
status	NodeStatus	Состояние узла. С течением времени может быть добавлено дополнительное состояние узла.
type	string: Activator	Тип назначения.

AdvancedSettings

Объект

Дополнительные параметры для оператора SQL.

Имя	Тип	Описание
eventsLateArrivalMaxDelayInSeconds	integer (int32) minimum: 0 maximum: 1814400	Максимальная задержка в секундах для событий позднего прибытия. Значение должно быть от 0 до 1814400.
eventsOutOfOrderMaxDelayInSeconds	integer (int32) minimum: 0 maximum: 3600	Максимальная задержка в секундах для событий вне порядка. Значение должно быть от 0 до 3600.
eventsOutOfOrderPolicy	EventsOutOfOrderPolicy	Политика обработки событий, поступающих из порядка. С течением времени могут добавляться дополнительные политики.

AggregateOperator

Объект

Оператор агрегата.

Имя	Тип	Описание
inputNodes	NodeReference[]	Список ссылок на входные узлы оператора.
inputSchemas	InputSchema[]	Входные схемы оператора.
name	string	Имя оператора.
properties	AggregateOperatorProperties	Свойства агрегатного оператора.
type	string: Aggregate	Тип оператора. С течением времени могут добавляться дополнительные типы операторов.

AggregateOperatorProperties

Объект

Свойства агрегатного оператора.

Имя	Тип	Описание
aggregations	InColumnAggregation[]	Список агрегатов.

Aggregation

Объект

Представляет агрегирование в столбце.

Имя	Тип	Описание
aggregationFunction	AggregationFunction	Функция агрегирования.
alias	string	Псевдоним агрегата.
arguments	object[]	Список аргументов для агрегирования.
column	ColumnReferenceExpression	Представляет ссылку на столбец.

AggregationFunction

Перечисление

Функция агрегирования.

Значение	Описание
Average	Средняя агрегатная функция.
Count	Функция агрегирования счетчиков.
Maximum	Максимальная функция агрегирования.
Minimum	Минимальная функция агрегирования.
PercentileContinuous	Функция агрегирования percentileContinuous.
PercentileDiscrete	Функция агрегирования percentileDiscrete.
StandardDeviation	Функция агрегирования StandardDeviation.
StandardDeviationPopulation	Функция агрегирования StandardDeviationPopulation.
Sum	Функция агрегирования сумм.
Variance	Функция агрегирования дисперсии.
VariancePopulation	Функция агрегирования variancePopulation.

AmazonKinesisSourceProperties

Объект

Свойства источника Amazon Kinesis.

Имя	Тип	Описание
dataConnectionId	string (uuid)	Идентификатор подключения к данным Amazon Kinesis.
region	Region	Имя региона Amazon Kinesis. С течением времени могут добавляться дополнительные регионы.
startPosition	StartPosition	Начальная позиция в потоке.
startTimestamp	string	Метка времени начала в формате ISO 8601 (например, '2024-01-15T10:30:00Z'). Обязательный, если `startPosition` имеет значение `AtTimestamp`.

AmazonKinesisSourceResponse

Объект

Ответ исходных свойств Amazon Kinesis.

Имя	Тип	Описание
error	ErrorInfo	Сведения об ошибке.
id	string (uuid)	Уникальный идентификатор источника.
inputSchemas	InputSchema[]	Входные схемы источника.
name	string	Уникальное имя источника.
properties	AmazonKinesisSourceProperties	Свойства источника Amazon Kinesis.
status	NodeStatus	Состояние узла. С течением времени может быть добавлено дополнительное состояние узла.
type	string: AmazonKinesis	Тип источника.

AmazonMSKKafkaSourceProperties

Объект

Свойства источника Amazon MSK Kafka.

Имя	Тип	Default value	Описание
autoOffsetReset	AutoOffsetReset	None	Свойство автоматического сброса смещения. Значение по умолчанию — None.
consumerGroupName	string		Имя группы потребителей.
dataConnectionId	string (uuid)		Идентификатор подключения к данным Kafka.
saslMechanism	SaslMechanism		Механизм SASL. С течением времени могут добавляться дополнительные механизмы SASL.
securityProtocol	SecurityProtocol		Протокол безопасности.
topic	string		Раздел Kafka.

AmazonMSKKafkaSourceResponse

Объект

Ответ источника Amazon MSK Kafka.

Имя	Тип	Описание
error	ErrorInfo	Сведения об ошибке.
id	string (uuid)	Уникальный идентификатор источника.
inputSchemas	InputSchema[]	Входные схемы источника.
name	string	Уникальное имя источника.
properties	AmazonMSKKafkaSourceProperties	Свойства источника Amazon MSK Kafka.
status	NodeStatus	Состояние узла. С течением времени может быть добавлено дополнительное состояние узла.
type	string: AmazonMSKKafka	Тип источника.

ApacheKafkaSourceProperties

Объект

Свойства источника Apache Kafka.

Имя	Тип	Default value	Описание
autoOffsetReset	AutoOffsetReset	None	Свойство автоматического сброса смещения. Значение по умолчанию — None.
consumerGroupName	string		Имя группы потребителей.
dataConnectionId	string (uuid)		Идентификатор подключения к данным Kafka.
saslMechanism	SaslMechanism		Механизм SASL. С течением времени могут добавляться дополнительные механизмы SASL.
securityProtocol	SecurityProtocol		Протокол безопасности.
topic	string		Раздел Kafka.

ApacheKafkaSourceResponse

Объект

Ответ источника Apache Kafka.

Имя	Тип	Описание
error	ErrorInfo	Сведения об ошибке.
id	string (uuid)	Уникальный идентификатор источника.
inputSchemas	InputSchema[]	Входные схемы источника.
name	string	Уникальное имя источника.
properties	ApacheKafkaSourceProperties	Свойства источника Apache Kafka.
status	NodeStatus	Состояние узла. С течением времени может быть добавлено дополнительное состояние узла.
type	string: ApacheKafka	Тип источника.

AutoOffsetReset

Перечисление

Свойство автоматического сброса смещения. Значение по умолчанию — None.

Значение	Описание
None	Автоматический сброс смещения — None.
Earliest	Автоматический сброс смещения является самым ранним.
Latest	Автоматический сброс смещения имеет значение Latest.

AvroSerializationInfo

Объект

Сведения о сериализации Avro.

Имя	Тип	Описание
properties	AvroSerializationProperties	Свойства сериализации Avro.
type	string: Avro	Тип сериализации.

AvroSerializationProperties

Объект

Свойства сериализации Avro.

AzureBlobStorageEvents

Объект

Хранилище BLOB-объектов Azure источник событий.

Имя	Тип	Описание
azureResourceId	string	Идентификатор ресурса Azure хранилища BLOB-объектов.
id	string (uuid)	Уникальный идентификатор источника.
includedEventTypes	IncludedEventTypes[]	Включенные типы событий. С течением времени могут добавляться дополнительные типы событий.

AzureBlobStorageEventsSourceProperties

Объект

Хранилище BLOB-объектов Azure свойства источника событий.

Имя	Тип	Описание
azureBlobStorageEvents	AzureBlobStorageEvents[]	События Хранилище BLOB-объектов Azure.
streamEvents	boolean	Указывает, следует ли передавать события.

AzureBlobStorageEventsSourceResponse

Объект

Хранилище BLOB-объектов Azure ответ источника событий.

Имя	Тип	Описание
error	ErrorInfo	Сведения об ошибке.
id	string (uuid)	Уникальный идентификатор источника.
inputSchemas	InputSchema[]	Входные схемы источника.
name	string	Уникальное имя источника.
properties	AzureBlobStorageEventsSourceProperties	Свойства источника событий Хранилище BLOB-объектов Azure.
status	NodeStatus	Состояние узла. С течением времени может быть добавлено дополнительное состояние узла.
type	string: AzureBlobStorageEvents	Тип источника.

AzureCosmosDBCDCSourceProperties

Объект

Azure Cosmos DB свойства источника CDC.

Имя	Тип	Описание
containerName	string	Имя контейнера.
dataConnectionId	string (uuid)	Идентификатор подключения к данным CDC Azure Cosmos DB.
databaseName	string	Имя базы данных.
offsetPolicy	OffsetPolicy	Политика смещения.

AzureCosmosDBCDCSourceResponse

Объект

Azure Cosmos DB ответ источника CDC.

Имя	Тип	Описание
error	ErrorInfo	Сведения об ошибке.
id	string (uuid)	Уникальный идентификатор источника.
inputSchemas	InputSchema[]	Входные схемы источника.
name	string	Уникальное имя источника.
properties	AzureCosmosDBCDCSourceProperties	Свойства источника CDC Azure Cosmos DB.
status	NodeStatus	Состояние узла. С течением времени может быть добавлено дополнительное состояние узла.
type	string: AzureCosmosDBCDC	Тип источника.

AzureDataExplorerSourceProperties

Объект

Azure Data Explorer свойства источника.

Имя	Тип	Описание
dataConnectionId	string (uuid)	Идентификатор подключения к данным Azure Data Explorer.
databaseName	string	Имя базы данных.
tableNames	string	Список имен таблиц, разделенных запятыми.

AzureDataExplorerSourceResponse

Объект

Azure Data Explorer исходный ответ.

Имя	Тип	Описание
error	ErrorInfo	Сведения об ошибке.
id	string (uuid)	Уникальный идентификатор источника.
inputSchemas	InputSchema[]	Входные схемы источника.
name	string	Уникальное имя источника.
properties	AzureDataExplorerSourceProperties	Свойства источника Azure Data Explorer.
status	NodeStatus	Состояние узла. С течением времени может быть добавлено дополнительное состояние узла.
type	string: AzureDataExplorer	Тип источника.

AzureEventGridNamespaceSourceProperties

Объект

Сетка событий Azure свойства источника пространства имен.

Имя	Тип	Описание
namespaceResourceId	string	Идентификатор ресурса пространства имен Сетка событий Azure.
topic	string	Имя раздела.

AzureEventGridNamespaceSourceResponse

Объект

ответ источника пространства имен Сетка событий Azure.

Имя	Тип	Описание
error	ErrorInfo	Сведения об ошибке.
id	string (uuid)	Уникальный идентификатор источника.
inputSchemas	InputSchema[]	Входные схемы источника.
name	string	Уникальное имя источника.
properties	AzureEventGridNamespaceSourceProperties	Свойства источника пространства имен Сетка событий Azure.
status	NodeStatus	Состояние узла. С течением времени может быть добавлено дополнительное состояние узла.
type	string: AzureEventGridNamespace	Тип источника.

AzureEventHubExtendedSourceProperties

Объект

Azure свойства расширенного источника концентратора событий.

Имя	Тип	Описание
consumerGroupName	string	Имя группы потребителей.
dataConnectionId	string (uuid)	Идентификатор подключения к данным концентратора событий Azure.
startPosition	StartPosition	Начальная позиция в потоке концентратора событий Azure.

AzureEventHubExtendedSourceResponse

Объект

Azure ответ расширенного источника концентратора событий.

Имя	Тип	Описание
error	ErrorInfo	Сведения об ошибке.
id	string (uuid)	Уникальный идентификатор источника.
inputSchemas	InputSchema[]	Входные схемы источника.
name	string	Уникальное имя источника.
properties	AzureEventHubExtendedSourceProperties	Свойства расширенного источника концентратора событий Azure.
status	NodeStatus	Состояние узла. С течением времени может быть добавлено дополнительное состояние узла.
type	string: AzureEventHubExtended	Тип источника.

AzureEventHubSourceProperties

Объект

Azure свойства источника Концентратора событий.

Имя	Тип	Описание
consumerGroupName	string	Имя группы потребителей.
dataConnectionId	string (uuid)	Идентификатор подключения к данным концентратора событий Azure.
inputSerialization	SerializationInfo: AvroSerializationInfo CsvSerializationInfo JsonSerializationInfo	Сведения о сериализации.

AzureEventHubSourceResponse

Объект

Azure ответ источника Концентратора событий.

Имя	Тип	Описание
error	ErrorInfo	Сведения об ошибке.
id	string (uuid)	Уникальный идентификатор источника.
inputSchemas	InputSchema[]	Входные схемы источника.
name	string	Уникальное имя источника.
properties	AzureEventHubSourceProperties	Свойства источника концентратора событий Azure.
status	NodeStatus	Состояние узла. С течением времени может быть добавлено дополнительное состояние узла.
type	string: AzureEventHub	Тип источника.

AzureIoTHubSourceProperties

Объект

Центр Интернета вещей Azure свойства источника.

Имя	Тип	Описание
consumerGroupName	string	Имя группы потребителей.
dataConnectionId	string (uuid)	Идентификатор подключения к данным Центр Интернета вещей Azure.
inputSerialization	SerializationInfo: AvroSerializationInfo CsvSerializationInfo JsonSerializationInfo	Сведения о сериализации.

AzureIoTHubSourceResponse

Объект

Центр Интернета вещей Azure ответ источника.

Имя	Тип	Описание
error	ErrorInfo	Сведения об ошибке.
id	string (uuid)	Уникальный идентификатор источника.
inputSchemas	InputSchema[]	Входные схемы источника.
name	string	Уникальное имя источника.
properties	AzureIoTHubSourceProperties	Свойства источника Центр Интернета вещей Azure.
status	NodeStatus	Состояние узла. С течением времени может быть добавлено дополнительное состояние узла.
type	string: AzureIoTHub	Тип источника.

AzureServiceBusSourceProperties

Объект

Служебная шина Azure свойства источника.

Имя	Тип	Описание
dataConnectionId	string (uuid)	Идентификатор подключения к данным Служебная шина Azure.
serviceBusType	enum: Queue Topic	Тип источника Служебная шина Azure.
subscriptionName	string	Имя подписки Служебная шина Azure. Это свойство требуется при использовании `Topic`типа сущности.
topicOrQueueName	string	Имя раздела или очереди Служебная шина Azure.

AzureServiceBusSourceResponse

Объект

Служебная шина Azure исходный ответ.

Имя	Тип	Описание
error	ErrorInfo	Сведения об ошибке.
id	string (uuid)	Уникальный идентификатор источника.
inputSchemas	InputSchema[]	Входные схемы источника.
name	string	Уникальное имя источника.
properties	AzureServiceBusSourceProperties	Свойства источника Служебная шина Azure.
status	NodeStatus	Состояние узла. С течением времени может быть добавлено дополнительное состояние узла.
type	string: AzureServiceBus	Тип источника.

AzureSQLDBCDCSourceResponse

Объект

Azure SQL ответ источника CDC базы данных.

Имя	Тип	Описание
error	ErrorInfo	Сведения об ошибке.
id	string (uuid)	Уникальный идентификатор источника.
inputSchemas	InputSchema[]	Входные схемы источника.
name	string	Уникальное имя источника.
properties	BaseSQLCDCSourceProperties	Базовые свойства источника SQL CDC.
status	NodeStatus	Состояние узла. С течением времени может быть добавлено дополнительное состояние узла.
type	string: AzureSQLDBCDC	Тип источника.

AzureSQLMIDBCDCSourceResponse

Объект

Azure SQL ответ источника MI DB CDC.

Имя	Тип	Описание
error	ErrorInfo	Сведения об ошибке.
id	string (uuid)	Уникальный идентификатор источника.
inputSchemas	InputSchema[]	Входные схемы источника.
name	string	Уникальное имя источника.
properties	BaseSQLCDCSourceProperties	Базовые свойства источника SQL CDC.
status	NodeStatus	Состояние узла. С течением времени может быть добавлено дополнительное состояние узла.
type	string: AzureSQLMIDBCDC	Тип источника.

BaseKafkaSourceProperties

Объект

Базовые свойства источника Kafka.

Имя	Тип	Default value	Описание
autoOffsetReset	AutoOffsetReset	None	Свойство автоматического сброса смещения. Значение по умолчанию — None.
consumerGroupName	string		Имя группы потребителей.
dataConnectionId	string (uuid)		Идентификатор подключения к данным Kafka.
topic	string		Раздел Kafka.

BaseSQLCDCSourceProperties

Объект

Базовые свойства источника SQL CDC.

Имя	Тип	Описание
dataConnectionId	string (uuid)	Идентификатор подключения к данным SQL CDC.
decimalHandlingMode	DecimalHandlingMode	Указывает, как десятичные значения представлены соединителем (точные десятичные, двойные или строки).
tableName	string	Имя таблицы.

CastProperties

Объект

Свойства операции приведения.

Имя	Тип	Описание
column	ColumnReferenceExpression	Представляет ссылку на столбец.
targetDataType	DataType	Представляет тип данных. С течением времени могут добавляться дополнительные типы данных.

ColumnReferenceExpression

Объект

Представляет ссылку на столбец.

Имя	Тип	Описание
columnName	string	Имя столбца.
columnPathSegments	string[]	Путь сегментирует ссылку на столбец для вложенных столбцов.
node	string	Имя эталонного узла.

ColumnSchema

Объект

Представляет схему столбца.

Имя	Тип	Описание
fields	ColumnSchema[]	Список полей для типа данных записи или массива.
items	ColumnSchema	Схема элементов массива.
name	string	Имя столбца.
type	DataType	Тип данных столбца служб .

CompatibilityLevel

Перечисление

Представляет уровень совместимости топологии Eventstream. С течением времени могут добавляться дополнительные уровни совместимости.

Значение	Описание
1.0	Уровень совместимости топологии Eventstream — 1.0.

ConfluentCloudSourceResponse

Объект

Ответ источника Confluent Cloud.

Имя	Тип	Описание
error	ErrorInfo	Сведения об ошибке.
id	string (uuid)	Уникальный идентификатор источника.
inputSchemas	InputSchema[]	Входные схемы источника.
name	string	Уникальное имя источника.
properties	BaseKafkaSourceProperties	Базовые свойства источника Kafka.
status	NodeStatus	Состояние узла. С течением времени может быть добавлено дополнительное состояние узла.
type	string: ConfluentCloud	Тип источника.

CsvSerializationInfo

Объект

Сведения о сериализации CSV.

Имя	Тип	Описание
properties	CsvSerializationProperties	Свойства сериализации CSV.
type	string: Csv	Тип сериализации.

CsvSerializationProperties

Объект

Свойства сериализации CSV.

Имя	Тип	Описание
encoding	Encoding	Тип кодирования.
fieldDelimiter	string	Разделитель полей.
format	Format	Тип формата.

CustomEndpointDestinationProperties

Объект

Свойства назначения событий пользовательской конечной точки.

CustomEndpointDestinationResponse

Объект

Ответ назначения событий пользовательской конечной точки.

Имя	Тип	Описание
error	ErrorInfo	Сведения об ошибке.
id	string (uuid)	Уникальный идентификатор назначения.
inputNodes	NodeReference[]	Список ссылок на входные узлы назначения.
inputSchemas	InputSchema[]	Входные схемы назначения.
name	string	Уникальное имя назначения.
properties	CustomEndpointDestinationProperties	Свойства назначения пользовательской конечной точки.
status	NodeStatus	Состояние узла. С течением времени может быть добавлено дополнительное состояние узла.
type	string: CustomEndpoint	Тип назначения.

CustomEndpointSourceProperties

Объект

Свойства источника событий пользовательской конечной точки.

CustomEndpointSourceResponse

Объект

Ответ источника событий пользовательской конечной точки.

Имя	Тип	Описание
error	ErrorInfo	Сведения об ошибке.
id	string (uuid)	Уникальный идентификатор источника.
inputSchemas	InputSchema[]	Входные схемы источника.
name	string	Уникальное имя источника.
properties	CustomEndpointSourceProperties	Свойства источника событий пользовательской конечной точки.
status	NodeStatus	Состояние узла. С течением времени может быть добавлено дополнительное состояние узла.
type	string: CustomEndpoint	Тип источника.

DataType

Перечисление

Представляет тип данных. С течением времени могут добавляться дополнительные типы данных.

Значение	Описание
BigInt	Тип данных BigInt.
Float	Тип данных float.
Nvarchar(max)	Тип данных Nvarchar(max).
DateTime	Тип данных DateTime.
Bit	Тип битового данных.
Record	Запись типа данных.
Array	Тип данных — массив.
Any	Неизвестный тип данных.

DecimalHandlingMode

Перечисление

Указывает, как десятичные значения представлены соединителем (точные десятичные, двойные или строки).

Значение	Описание
Precise	Десятичный режим обработки является точным.
Double	Режим обработки десятичных знаков — Double.
String	Десятичный режим обработки — String.

DefaultStreamProperties

Объект

Свойства потока по умолчанию.

DefaultStreamResponse

Объект

Ответ потока по умолчанию.

Имя	Тип	Описание
id	string (uuid)	Уникальный идентификатор потока.
inputNodes	NodeReference[]	Список ссылок на входные узлы потока.
name	string	Уникальное имя потока.
properties	DefaultStreamProperties	Свойства потока по умолчанию.
type	string: DefaultStream	Тип потока.

DerivedStreamProperties

Объект

Производные свойства потока.

Имя	Тип	Описание
inputSerialization	SerializationInfo: AvroSerializationInfo CsvSerializationInfo JsonSerializationInfo	Сведения о сериализации.

DerivedStreamResponse

Объект

Производный ответ потока.

Имя	Тип	Описание
id	string (uuid)	Уникальный идентификатор потока.
inputNodes	NodeReference[]	Список ссылок на входные узлы потока.
name	string	Уникальное имя потока.
properties	DerivedStreamProperties	Свойства производного потока.
type	string: DerivedStream	Тип потока.

DestinationType

Перечисление

Представляет тип назначения. С течением времени могут добавляться дополнительные типы назначения.

Значение	Описание
Activator	Тип назначения Активатора.
CustomEndpoint	Тип назначения CustomEndpoint.
Eventhouse	Тип назначения Eventhouse.
Lakehouse	Тип назначения Lakehouse.

Encoding

Перечисление

Тип кодирования.

Значение	Описание
UTF8	Тип кодирования — UTF8.

ErrorInfo

Объект

Представляет сведения об ошибке.

Имя	Тип	Описание
errorCode	string	Код ошибки.
errorDetails	string[]	Сведения об ошибке.
errorMessage	string	Сообщение об ошибке.

ErrorRelatedResource

Объект

Объект сведений об ошибках, связанных с ресурсом.

Имя	Тип	Описание
resourceId	string	Идентификатор ресурса, участвующий в ошибке.
resourceType	string	Тип ресурса, который участвует в ошибке.

ErrorResponse

Объект

Ответ на ошибку.

Имя	Тип	Описание
errorCode	string	Определенный идентификатор, предоставляющий сведения об условии ошибки, что позволяет стандартизировать обмен данными между службой и ее пользователями.
message	string	Удобочитаемое представление ошибки.
moreDetails	ErrorResponseDetails[]	Список дополнительных сведений об ошибке.
relatedResource	ErrorRelatedResource	Сведения об ошибках, связанных с ресурсом.
requestId	string (uuid)	Идентификатор запроса, связанного с ошибкой.

ErrorResponseDetails

Объект

Сведения об ответе на ошибку.

Имя	Тип	Описание
errorCode	string	Определенный идентификатор, предоставляющий сведения об условии ошибки, что позволяет стандартизировать обмен данными между службой и ее пользователями.
message	string	Удобочитаемое представление ошибки.
relatedResource	ErrorRelatedResource	Сведения об ошибках, связанных с ресурсом.

EventhouseDestinationResponse

Объект

Ответ назначения eventhouse.

Имя	Тип	Описание
error	ErrorInfo	Сведения об ошибке.
id	string (uuid)	Уникальный идентификатор назначения.
inputNodes	NodeReference[]	Список ссылок на входные узлы назначения.
inputSchemas	InputSchema[]	Входные схемы назначения.
name	string	Уникальное имя назначения.
properties	EventhouseDestinationProperties: EventhouseDirectIngestionModeDestinationProperties EventhouseProcessedIngestionModeDestinationProperties	Свойства назначения Eventhouse.
status	NodeStatus	Состояние узла. С течением времени может быть добавлено дополнительное состояние узла.
type	string: Eventhouse	Тип назначения.

EventhouseDirectIngestionModeDestinationProperties

Объект

Свойства назначения режима directIngestion eventhouse.

Имя	Тип	Описание
connectionName	string	Имя подключения.
dataIngestionMode	string: DirectIngestion	Режим приема данных.
itemId	string (uuid)	Идентификатор элемента Eventhouse.
mappingRuleName	string	Имя правила сопоставления.
tableName	string	Имя таблицы KQL.
workspaceId	string (uuid)	Идентификатор рабочей области Eventhouse.

EventhouseProcessedIngestionModeDestinationProperties

Объект

Свойства назначения режима обработки eventhouse ProcessedIngestion.

Имя	Тип	Описание
dataIngestionMode	string: ProcessedIngestion	Режим приема данных.
databaseName	string	Имя базы данных KQL.
inputSerialization	SerializationInfo: AvroSerializationInfo CsvSerializationInfo JsonSerializationInfo	Сведения о сериализации.
itemId	string (uuid)	Идентификатор элемента Eventhouse.
tableName	string	Имя таблицы KQL.
workspaceId	string (uuid)	Идентификатор рабочей области Eventhouse.

EventScope

Перечисление

Значение	Описание
Tenant	Область событий — клиент.
Capacity	Область событий — Емкость.
Workspace	Область событий — Рабочая область.
Item	Область события — Item.
SubItem	Область событий — SubItem.

EventsOutOfOrderPolicy

Перечисление

Политика обработки событий, поступающих из порядка. С течением времени могут добавляться дополнительные политики.

Значение	Описание
Adjust	Настройте метку времени событий вне порядка.
Drop	Удаление событий вне порядка.

EventstreamTopologyResponse

Объект

Представляет ответ топологии Eventstream.

Имя	Тип	Описание
compatibilityLevel	CompatibilityLevel	Представляет уровень совместимости топологии Eventstream. С течением времени могут добавляться дополнительные уровни совместимости.
destinations	DestinationResponse[]: ActivatorDestinationResponse[] CustomEndpointDestinationResponse[] EventhouseDestinationResponse[] LakehouseDestinationResponse[]	Список назначений Eventstream.
operators	Operator[]: AggregateOperator[] ExpandOperator[] FilterOperator[] GroupByOperator[] JoinOperator[] ManageFieldsOperator[] SqlOperator[] UnionOperator[]	Список операторов Eventstream.
sources	SourceResponse[]: AmazonKinesisSourceResponse[] AmazonMSKKafkaSourceResponse[] ApacheKafkaSourceResponse[] AzureBlobStorageEventsSourceResponse[] AzureCosmosDBCDCSourceResponse[] AzureDataExplorerSourceResponse[] AzureEventGridNamespaceSourceResponse[] AzureEventHubExtendedSourceResponse[] AzureEventHubSourceResponse[] AzureIoTHubSourceResponse[] AzureSQLDBCDCSourceResponse[] AzureSQLMIDBCDCSourceResponse[] AzureServiceBusSourceResponse[] ConfluentCloudSourceResponse[] CustomEndpointSourceResponse[] FabricCapacityOverviewEventsSourceResponse[] FabricJobEventsSourceResponse[] FabricOneLakeEventsSourceResponse[] FabricWorkspaceItemEventsSourceResponse[] GooglePubSubSourceResponse[] HttpSourceResponse[] MongoDBCDCSourceResponse[] MqttSourceResponse[] MySQLCDCSourceResponse[] PostgreSQLCDCSourceResponse[] RealTimeWeatherSourceResponse[] SQLServerOnVMDBCDCSourceResponse[] SampleDataSourceResponse[] SolacePubSubSourceResponse[]	Список источников eventstream.
streams	StreamResponse[]: DefaultStreamResponse[] DerivedStreamResponse[]	Список потоков событий по умолчанию и производных потоков.

ExpandOperator

Объект

Оператор развертывания.

Имя	Тип	Описание
inputNodes	NodeReference[]	Список ссылок на входные узлы оператора.
inputSchemas	InputSchema[]	Входные схемы оператора.
name	string	Имя оператора.
properties	ExpandOperatorProperties	Разверните свойства оператора.
type	string: Expand	Тип оператора. С течением времени могут добавляться дополнительные типы операторов.

ExpandOperatorProperties

Объект

Разверните свойства оператора.

Имя	Тип	Описание
column	ColumnReferenceExpression[]	Список столбцов, которые нужно развернуть.
ignoreMissingOrEmpty	boolean	Параметр отсутствующих или пустых столбцов. True — игнорировать столбцы, false — не игнорировать столбцы.

FabricCapacityOverviewEventsSourceProperties

Объект

Fabric свойства источника событий обзора емкости.

Имя	Тип	Описание
capacityId	string (uuid)	Идентификатор емкости.
eventScope	EventScope
filters	object[]	Применяемые Сетка событий Azure расширенные фильтры. Каждая запись — это расширенный объект фильтра, определенный Сетка событий Azure. Дополнительные сведения см. в https://learn.microsoft.com/azure/event-grid/event-filtering#advanced-filtering.
includedEventTypes	string[]	Список типов событий для включения. Поддерживаемые значения: Майкрософт.Fabric. Capacity.State, Майкрософт.Fabric. Capacity.Summary. С течением времени могут добавляться дополнительные типы событий.

FabricCapacityOverviewEventsSourceResponse

Объект

Fabric ответ источника событий обзора емкости.

Имя	Тип	Описание
error	ErrorInfo	Сведения об ошибке.
id	string (uuid)	Уникальный идентификатор источника.
inputSchemas	InputSchema[]	Входные схемы источника.
name	string	Уникальное имя источника.
properties	FabricCapacityOverviewEventsSourceProperties	Свойства источника событий обзора емкости Fabric.
status	NodeStatus	Состояние узла. С течением времени может быть добавлено дополнительное состояние узла.
type	string: FabricCapacityOverviewEvents	Тип источника.

FabricJobEventsSourceProperties

Объект

Fabric свойства источника событий задания.

Имя	Тип	Описание
eventScope	EventScope
filters	object	Расширенные фильтры, определенные в https://learn.microsoft.com/en-us/azure/event-grid/event-filtering#advanced-filtering.
includedEventTypes	string[]	Список типов событий для включения. Поддерживаемые значения: Майкрософт.Fabric. JobEvents.ItemJobCreated, Майкрософт.Fabric. JobEvents.ItemJobStatusChanged, Майкрософт.Fabric. JobEvents.ItemJobSucceeded, Майкрософт.Fabric. JobEvents.ItemJobFailed. С течением времени могут добавляться дополнительные типы событий.
itemId	string (uuid)	Идентификатор элемента.
workspaceId	string (uuid)	Идентификатор рабочей области.

FabricJobEventsSourceResponse

Объект

Fabric ответ источника событий задания.

Имя	Тип	Описание
error	ErrorInfo	Сведения об ошибке.
id	string (uuid)	Уникальный идентификатор источника.
inputSchemas	InputSchema[]	Входные схемы источника.
name	string	Уникальное имя источника.
properties	FabricJobEventsSourceProperties	Свойства источника событий задания Fabric.
status	NodeStatus	Состояние узла. С течением времени может быть добавлено дополнительное состояние узла.
type	string: FabricJobEvents	Тип источника.

FabricOneLakeEventsSourceProperties

Объект

Fabric свойства источника OneLake Events.

Имя	Тип	Описание
filters	object	Расширенные фильтры, определенные в https://learn.microsoft.com/en-us/azure/event-grid/event-filtering#advanced-filtering.
includedEventTypes	string[]	Список типов событий для включения. Поддерживаемые значения: Майкрософт.Fabric. OneLake.FileCreated, Майкрософт.Fabric. OneLake.FileDeleted, Майкрософт.Fabric. OneLake.FileRenamed, Майкрософт.Fabric. OneLake.FolderCreated, Майкрософт.Fabric. OneLake.FolderDeleted, Майкрософт.Fabric. OneLake.FolderRenamed. С течением времени могут добавляться дополнительные типы событий.
itemId	string (uuid)	Идентификатор элемента.
oneLakePaths	string[]	Пути OneLake.
tenantId	string (uuid)	Идентификатор клиента.
workspaceId	string (uuid)	Идентификатор рабочей области.

FabricOneLakeEventsSourceResponse

Объект

Fabric ответ источника Событий OneLake.

Имя	Тип	Описание
error	ErrorInfo	Сведения об ошибке.
id	string (uuid)	Уникальный идентификатор источника.
inputSchemas	InputSchema[]	Входные схемы источника.
name	string	Уникальное имя источника.
properties	FabricOneLakeEventsSourceProperties	Свойства источника событий OneLake Fabric.
status	NodeStatus	Состояние узла. С течением времени может быть добавлено дополнительное состояние узла.
type	string: FabricOneLakeEvents	Тип источника.

FabricWorkspaceItemEventsSourceProperties

Объект

Fabric свойства источника событий элемента рабочей области.

Имя	Тип	Описание
eventScope	EventScope
filters	object	Расширенные фильтры, определенные в https://learn.microsoft.com/en-us/azure/event-grid/event-filtering#advanced-filtering.
includedEventTypes	string[]	Список типов событий для включения. Поддерживаемые значения: Майкрософт.Fabric. ItemCreateSucceeded, Майкрософт.Fabric. ItemCreateFailed, Майкрософт.Fabric. ItemUpdateSucceeded, Майкрософт.Fabric. ItemUpdateFailed, Майкрософт.Fabric. ItemDeleteSucceeded, Майкрософт.Fabric. ItemDeleteFailed. С течением времени могут добавляться дополнительные типы событий.
itemId	string (uuid)	Идентификатор элемента.
workspaceId	string (uuid)	Идентификатор рабочей области.

FabricWorkspaceItemEventsSourceResponse

Объект

ответ источника событий элементов рабочей области Fabric.

Имя	Тип	Описание
error	ErrorInfo	Сведения об ошибке.
id	string (uuid)	Уникальный идентификатор источника.
inputSchemas	InputSchema[]	Входные схемы источника.
name	string	Уникальное имя источника.
properties	FabricWorkspaceItemEventsSourceProperties	Свойства источника событий элементов рабочей области Fabric.
status	NodeStatus	Состояние узла. С течением времени может быть добавлено дополнительное состояние узла.
type	string: FabricWorkspaceItemEvents	Тип источника.

FilterCondition

Объект

Представляет условие фильтра.

Имя	Тип	Описание
column	ColumnReferenceExpression	Представляет ссылку на столбец.
operatorType	OperatorType	Тип оператора.
value	LiteralExpression	Представляет литеральное выражение.

FilterOperator

Объект

Оператор фильтра.

Имя	Тип	Описание
inputNodes	NodeReference[]	Список ссылок на входные узлы оператора.
inputSchemas	InputSchema[]	Входные схемы оператора.
name	string	Имя оператора.
properties	FilterOperatorProperties	Свойства оператора фильтра.
type	string: Filter	Тип оператора. С течением времени могут добавляться дополнительные типы операторов.

FilterOperatorProperties

Объект

Свойства оператора фильтра.

Имя	Тип	Описание
conditions	FilterCondition[]	Список условий фильтра.

Format

Перечисление

Тип формата.

Значение	Описание
WithHeaders	Формат содержит заголовки.
WithoutHeaders	Формат не включает заголовки.

FunctionCallProperties

Объект

Свойства для операции вызова функции.

Имя	Тип	Описание
arguments	object[]	Список аргументов для функции.
functionName	string	Имя функции.

GooglePubSubSourceProperties

Объект

Свойства источника Google Pub/Sub.

Имя	Тип	Описание
dataConnectionId	string (uuid)	Идентификатор подключения к данным Google Pub/Sub.

GooglePubSubSourceResponse

Объект

Ответ источника Google Pub/Sub.

Имя	Тип	Описание
error	ErrorInfo	Сведения об ошибке.
id	string (uuid)	Уникальный идентификатор источника.
inputSchemas	InputSchema[]	Входные схемы источника.
name	string	Уникальное имя источника.
properties	GooglePubSubSourceProperties	Свойства источника Google Pub/Sub.
status	NodeStatus	Состояние узла. С течением времени может быть добавлено дополнительное состояние узла.
type	string: GooglePubSub	Тип источника.

GroupByOperator

Объект

Оператор GroupBy.

Имя	Тип	Описание
inputNodes	NodeReference[]	Список ссылок на входные узлы оператора.
inputSchemas	InputSchema[]	Входные схемы оператора.
name	string	Имя оператора.
properties	GroupByOperatorProperties	Свойства оператора GroupBy.
type	string: GroupBy	Тип оператора. С течением времени могут добавляться дополнительные типы операторов.

GroupByOperatorProperties

Объект

Свойства оператора GroupBy.

Имя	Тип	Описание
aggregations	Aggregation[]	Список агрегатов.
groupBy	ColumnReferenceExpression[]	Список столбцов для группировки по.
window	GroupByWindow: HoppingWindow SessionWindow SlidingWindow SnapshotWindow TumblingWindow	Представляет окно для группы по оператору.

HoppingWindow

Объект

Имя	Тип	Описание
properties	HoppingWindowProperties	Свойства для прыжкового окна.
type	string: Hopping	Тип окна.

HoppingWindowProperties

Объект

Свойства для окна прыжка.

Имя	Тип	Описание
duration	OperatorCommonDuration	Представляет длительность.
hopSize	OperatorCommonDuration	Представляет длительность.
offset	OperatorCommonDuration	Представляет длительность.

HttpMethod

Перечисление

Метод HTTP. С течением времени могут добавляться дополнительные методы.

Значение	Описание
GET	Метод HTTP GET.
POST	Метод HTTP POST.

HttpSourceProperties

Объект

Свойства источника HTTP.

Имя	Тип	Описание
dataConnectionId	string (uuid)	Идентификатор подключения к данным HTTP.
maxRetries	integer	Максимальное количество повторных попыток для неудачных запросов.
method	HttpMethod	Метод HTTP. С течением времени могут добавляться дополнительные методы.
pollIntervalMs	integer	Интервал опроса в миллисекундах.
requestBody	string	Текст HTTP-запроса.
requestHeaders	KeyStringValuePair[]	Заголовки HTTP-запроса.
requestParameters	KeyStringValuePair[]	Параметры HTTP-запроса.
retriableHttpStatusCodes	string	Коды состояния HTTP в виде строки, разделенной запятыми.
retryBackoffMs	integer	Время повтора в миллисекундах.

HttpSourceResponse

Объект

Ответ источника HTTP.

Имя	Тип	Описание
error	ErrorInfo	Сведения об ошибке.
id	string (uuid)	Уникальный идентификатор источника.
inputSchemas	InputSchema[]	Входные схемы источника.
name	string	Уникальное имя источника.
properties	HttpSourceProperties	Свойства источника HTTP.
status	NodeStatus	Состояние узла. С течением времени может быть добавлено дополнительное состояние узла.
type	string: Http	Тип источника.

IncludedEventTypes

Перечисление

Включенные типы событий. С течением времени могут добавляться дополнительные типы событий.

Значение	Описание
Microsoft.Storage.BlobCreated	Событие создания БОЛЬШОго двоичного объекта.
Microsoft.Storage.BlobDeleted	Событие удаления БОЛЬШОго двоичного объекта.
Microsoft.Storage.BlobRenamed	Событие, переименованное blob-объектом.
Microsoft.Storage.BlobTierChanged	Событие изменения уровня BLOB-объектов.
Microsoft.Storage.DirectoryCreated	Событие создания каталога.
Microsoft.Storage.DirectoryDeleted	Событие удаления каталога.
Microsoft.Storage.DirectoryRenamed	Переименованное в каталог событие.
Microsoft.Storage.BlobInventoryPolicyCompleted	Завершено событие политики инвентаризации BLOB-объектов.
Microsoft.Storage.AsyncOperationInitiated	Событие, инициированное асинхронной операцией.
Microsoft.Storage.LifecyclePolicyCompleted	Завершенное событие политики жизненного цикла.

InColumnAggregation

Объект

Представляет агрегирование в столбце.

Имя	Тип	Описание
aggregationFunction	AggregationFunction	Функция агрегирования.
alias	string	Псевдоним агрегата.
arguments	object[]	Список аргументов для агрегирования.
column	ColumnReferenceExpression	Представляет ссылку на столбец.
duration	OperatorCommonDuration	Представляет длительность.
partitionBy	ColumnReferenceExpression[]	Список столбцов для секционирования по.

InputSchema

Объект

Представляет входную схему источника, назначения или оператора.

Имя	Тип	Описание
name	string	Имя входной схемы.
schema	Schema	Представляет схему данных.

JoinOn

Объект

Представляет условие соединения.

Имя	Тип	Описание
left	ColumnReferenceExpression	Представляет ссылку на столбец.
right	ColumnReferenceExpression	Представляет ссылку на столбец.

JoinOperator

Объект

Оператор соединения.

Имя	Тип	Описание
inputNodes	NodeReference[]	Список ссылок на входные узлы оператора.
inputSchemas	InputSchema[]	Входные схемы оператора.
name	string	Имя оператора.
properties	JoinOperatorProperties	Свойства оператора Join.
type	string: Join	Тип оператора. С течением времени могут добавляться дополнительные типы операторов.

JoinOperatorProperties

Объект

Свойства оператора Join.

Имя	Тип	Описание
duration	OperatorCommonDuration	Представляет длительность.
joinOn	JoinOn[]	Список условий соединения.
joinType	JoinType	Тип соединения.

JoinType

Перечисление

Тип соединения.

Значение	Описание
Inner	Внутреннее соединение.
LeftOuter	Левое внешнее соединение.

JsonSerializationInfo

Объект

Сведения о сериализации JSON.

Имя	Тип	Описание
properties	JsonSerializationProperties	Свойства сериализации JSON.
type	string: Json	Тип сериализации.

JsonSerializationProperties

Объект

Свойства сериализации JSON.

Имя	Тип	Описание
encoding	Encoding	Тип кодирования.

KeyStringValuePair

Объект

Имя	Тип	Описание
key	string	Ключ.
value	string	Значение типа .

LakehouseDestinationProperties

Объект

Свойства назначения Lakehouse.

Имя	Тип	Default value	Описание
deltaTable	string		Имя разностной таблицы.
inputSerialization	SerializationInfo: AvroSerializationInfo CsvSerializationInfo JsonSerializationInfo		Сведения о сериализации.
itemId	string (uuid)		Идентификатор элемента Lakehouse.
maximumDurationInSeconds	integer	120	Максимальная длительность в секундах для выходного пакета. Значение по умолчанию — 120.
minimumRows	integer	100000	Минимальное количество строк для выходного пакета. Значение по умолчанию — 100000.
schema	string		Имя схемы.
workspaceId	string (uuid)		Идентификатор рабочей области Lakehouse.

LakehouseDestinationResponse

Объект

Ответ назначения Lakehouse.

Имя	Тип	Описание
error	ErrorInfo	Сведения об ошибке.
id	string (uuid)	Уникальный идентификатор назначения.
inputNodes	NodeReference[]	Список ссылок на входные узлы назначения.
inputSchemas	InputSchema[]	Входные схемы назначения.
name	string	Уникальное имя назначения.
properties	LakehouseDestinationProperties	Свойства назначения Lakehouse.
status	NodeStatus	Состояние узла. С течением времени может быть добавлено дополнительное состояние узла.
type	string: Lakehouse	Тип назначения.

LiteralExpression

Объект

Представляет литеральное выражение.

Имя	Тип	Описание
dataType	DataType	Тип данных литерального выражения.
value	string	Значение литерального выражения.

ManageFieldsCastOperation

Объект

Представляет операцию приведения полей управления.

Имя	Тип	Описание
alias	string	Псевдоним операции.
properties	CastProperties	Свойства операции приведения полей управления.
type	string: Cast	Тип операции.

ManageFieldsFunctionCallOperation

Объект

Представляет операцию вызова функции управления полями.

Имя	Тип	Описание
alias	string	Псевдоним операции.
properties	FunctionCallProperties	Свойства для операции вызова функции управления полями.
type	string: FunctionCall	Тип операции.

ManageFieldsOperator

Объект

Оператор ManageFields.

Имя	Тип	Описание
inputNodes	NodeReference[]	Список ссылок на входные узлы оператора.
inputSchemas	InputSchema[]	Входные схемы оператора.
name	string	Имя оператора.
properties	ManageFieldsOperatorProperties	Свойства оператора ManageFields.
type	string: ManageFields	Тип оператора. С течением времени могут добавляться дополнительные типы операторов.

ManageFieldsOperatorProperties

Объект

Свойства оператора ManageFields.

Имя	Тип	Описание
columns	ManageFieldsOperation[]: ManageFieldsCastOperation[] ManageFieldsFunctionCallOperation[] ManageFieldsRenameOperation[]	Список столбцов для управления.

ManageFieldsRenameOperation

Объект

Представляет операцию переименования полей управления.

Имя	Тип	Описание
alias	string	Псевдоним операции.
properties	RenameProperties	Свойства для операции переименования полей управления.
type	string: Rename	Тип операции.

MongoDBCDCSourceProperties

Объект

Свойства источника MongoDB CDC.

Имя	Тип	Описание
dataConnectionId	string (uuid)	Идентификатор подключения к данным MongoDB CDC.
includedCollections	string	Список регулярных выражений, соответствующих именам коллекций, разделенным запятыми.
includedDatabases	string	Список регулярных выражений, соответствующих именам баз данных, разделенным запятыми.
snapshotMode	SnapshotMode	Режим моментального снимка.

MongoDBCDCSourceResponse

Объект

Ответ источника MongoDB CDC.

Имя	Тип	Описание
error	ErrorInfo	Сведения об ошибке.
id	string (uuid)	Уникальный идентификатор источника.
inputSchemas	InputSchema[]	Входные схемы источника.
name	string	Уникальное имя источника.
properties	MongoDBCDCSourceProperties	Свойства источника CDC MongoDB.
status	NodeStatus	Состояние узла. С течением времени может быть добавлено дополнительное состояние узла.
type	string: MongoDBCDC	Тип источника.

MqttSourceProperties

Объект

Свойства источника MQTT.

Имя	Тип	Описание
dataConnectionId	string (uuid)	Идентификатор подключения к данным MQTT.
serverVersion	ServerVersion	Версия сервера MQTT.
topic	string	Тема MQTT.

MqttSourceResponse

Объект

Ответ источника MQTT.

Имя	Тип	Описание
error	ErrorInfo	Сведения об ошибке.
id	string (uuid)	Уникальный идентификатор источника.
inputSchemas	InputSchema[]	Входные схемы источника.
name	string	Уникальное имя источника.
properties	MqttSourceProperties	Свойства источника MQTT.
status	NodeStatus	Состояние узла. С течением времени может быть добавлено дополнительное состояние узла.
type	string: Mqtt	Тип источника.

MySQLCDCSourceProperties

Объект

Свойства источника MySQL CDC.

Имя	Тип	Default value	Описание
dataConnectionId	string (uuid)		Идентификатор подключения к данным SQL CDC.
decimalHandlingMode	DecimalHandlingMode		Указывает, как десятичные значения представлены соединителем (точные десятичные, двойные или строки).
port	integer	3306	номер порта. Значение по умолчанию — 3306.
serverId	integer		Идентификатор сервера для соединителя CDC.
snapshotLockingMode	SnapshotLockingMode		Указывает стратегию блокировки, используемую при принятии начального моментального снимка (например, минимальные блокировки и расширенная блокировка для более строгой согласованности).
tableName	string		Имя таблицы.

MySQLCDCSourceResponse

Объект

Ответ источника MySQL CDC.

Имя	Тип	Описание
error	ErrorInfo	Сведения об ошибке.
id	string (uuid)	Уникальный идентификатор источника.
inputSchemas	InputSchema[]	Входные схемы источника.
name	string	Уникальное имя источника.
properties	MySQLCDCSourceProperties	Свойства источника MYSQL CDC.
status	NodeStatus	Состояние узла. С течением времени может быть добавлено дополнительное состояние узла.
type	string: MySQLCDC	Тип источника.

NodeReference

Объект

Представляет ссылку на узел с помощью уникального имени.

Имя	Тип	Описание
name	string	Уникальное имя узла.

NodeStatus

Перечисление

Состояние узла. С течением времени может быть добавлено дополнительное состояние узла.

Значение	Описание
Unknown	Состояние узла неизвестно.
Creating	Узел создается.
Created	Узел был создан.
Updating	Узел обновляется.
Running	Узел запущен.
Paused	Узел приостановлен.
Failed	Сбой узла.
Warning	Узел содержит предупреждение.
Deleting	Узел удаляется.
Pausing	Узел приостановлен.
Resuming	Узел возобновляется.
External	Состояние узла зависит от внешней службы.

OffsetPolicy

Перечисление

Политика смещения.

Значение	Описание
Earliest	Политика смещения является самой ранней.
Latest	Политика смещения является последней.

OperatorCommonDuration

Объект

Представляет длительность.

Имя	Тип	Описание
unit	Unit	Единица длительности.
value	integer	Значение длительности.

OperatorType

Перечисление

Тип оператора.

Значение	Описание
Equals	Оператор Equals.
NotEquals	Оператор NotEquals.
GreaterThan	Оператор GreaterThan.
GreaterThanOrEquals	Оператор GreaterThanOrEquals.
LessThan	Оператор LessThan.
LessThanOrEquals	Оператор LessThanOrEquals.
Contains	Содержит оператор.
DoesNotContain	Оператор DoesNotContain.
StartsWith	Оператор StartsWith.
DoesNotStartWith	Оператор DoesNotStartWith.
EndsWith	Оператор EndsWith.
DoesNotEndWith	Оператор DoesNotEndWith.
IsEmpty	Оператор IsEmpty.
IsNull	Оператор IsNull.
IsNotNull	Оператор IsNotNull.
IsNotNullOrEmpty	Оператор IsNotNullOrEmpty.

PostgreSQLCDCSourceProperties

Объект

Свойства источника POSTgreSQL CDC.

Имя	Тип	Default value	Описание
dataConnectionId	string (uuid)		Идентификатор подключения к данным SQL CDC.
decimalHandlingMode	DecimalHandlingMode		Указывает, как десятичные значения представлены соединителем (точные десятичные, двойные или строки).
port	integer	5432	номер порта. Значение по умолчанию — 5432.
publicationAutoCreateMode	PublicationAutoCreateMode		Режим автоматического создания публикации.
publicationName	string		Имя публикации для соединителя CDC.
slotName	string		Имя слота для соединителя CDC.
tableName	string		Имя таблицы.

PostgreSQLCDCSourceResponse

Объект

Ответ источника CDC PostgreSQL.

Имя	Тип	Описание
error	ErrorInfo	Сведения об ошибке.
id	string (uuid)	Уникальный идентификатор источника.
inputSchemas	InputSchema[]	Входные схемы источника.
name	string	Уникальное имя источника.
properties	PostgreSQLCDCSourceProperties	Свойства источника CDC PostgreSQL.
status	NodeStatus	Состояние узла. С течением времени может быть добавлено дополнительное состояние узла.
type	string: PostgreSQLCDC	Тип источника.

PublicationAutoCreateMode

Перечисление

Режим автоматического создания публикации.

Значение	Описание
Filtered	Режим автоматического создания публикации фильтруется.
AllTables	Режим автоматического создания публикации — AllTables.
Disabled	Режим автоматического создания публикации отключен.

RealTimeWeatherSourceProperties

Объект

Свойства источника погоды в режиме реального времени.

Имя	Тип	Описание
latitude	number	Широта для данных о погоде.
longitude	number	Долгота для данных о погоде.

RealTimeWeatherSourceResponse

Объект

Ответ источника погоды в режиме реального времени.

Имя	Тип	Описание
error	ErrorInfo	Сведения об ошибке.
id	string (uuid)	Уникальный идентификатор источника.
inputSchemas	InputSchema[]	Входные схемы источника.
name	string	Уникальное имя источника.
properties	RealTimeWeatherSourceProperties	Свойства источника погоды в режиме реального времени.
status	NodeStatus	Состояние узла. С течением времени может быть добавлено дополнительное состояние узла.
type	string: RealTimeWeather	Тип источника.

Region

Перечисление

Имя региона Amazon Kinesis. С течением времени могут добавляться дополнительные регионы.

Значение	Описание
af-south-1	Африка (Кейптаун) регион.
ap-east-1	Азиатско-Тихоокеанский регион (Гонконг).
ap-northeast-1	Азиатско-Тихоокеанский регион (Токио).
ap-northeast-2	Азиатско-Тихоокеанский регион (Сеул).
ap-northeast-3	Азиатско-Тихоокеанский регион (Осака).
ap-south-1	Азиатско-Тихоокеанский регион (Мумбаи).
ap-south-2	Азиатско-Тихоокеанский регион (Хайдерабад).
ap-southeast-1	Азиатско-Тихоокеанский регион (Сингапур).
ap-southeast-2	Азиатско-Тихоокеанский регион (Сидней).
ap-southeast-3	Азиатско-Тихоокеанский регион (Джакарта).
ap-southeast-4	Азиатско-Тихоокеанский регион (Мельбурн).
ap-southeast-5	Азиатско-Тихоокеанский регион (Малайзия).
ca-central-1	Канада (Центральная) область.
ca-west-1	Западная Канада (Калгари) регион.
eu-central-1	Европа (Франкфурт) регион.
eu-central-2	Европа (Цюрих) регион.
eu-north-1	Европа (Стокгольм) регион.
eu-south-1	Европа (Милан) регион.
eu-south-2	Регион Европы (Испания).
eu-west-1	Регион Европы (Ирландия).
eu-west-2	Регион Европы (Лондон).
eu-west-3	Европа (Париж) регион.
il-central-1	Израиль (Тель-Авив) регион.
me-central-1	Регион Ближнего Востока (ОАЭ).
me-south-1	Регион Ближнего Востока (Бахрейн).
sa-east-1	Южная Америка (Сан-Паулу) регион.
us-east-1	Регион "Восточная часть США" (N. Вирджиния).
us-east-2	Регион "Восточная часть США" (Огайо).
us-gov-east-1	Регион AWS GovCloud (US-East)
us-gov-west-1	Регион AWS GovCloud (US-West)
us-west-1	Регион "Западная часть США" (N. Калифорния).
us-west-2	Западная часть США (Орегон) регион.

RenameProperties

Объект

Свойства для операции переименования.

Имя	Тип	Описание
column	ColumnReferenceExpression	Представляет ссылку на столбец.

SampleDataSourceProperties

Объект

Примеры свойств источника данных.

Имя	Тип	Описание
type	Type	Пример типа данных. С течением времени могут добавляться дополнительные примеры типов данных.

SampleDataSourceResponse

Объект

Пример ответа источника событий данных.

Имя	Тип	Описание
error	ErrorInfo	Сведения об ошибке.
id	string (uuid)	Уникальный идентификатор источника.
inputSchemas	InputSchema[]	Входные схемы источника.
name	string	Уникальное имя источника.
properties	SampleDataSourceProperties	Свойства источника событий данных образца.
status	NodeStatus	Состояние узла. С течением времени может быть добавлено дополнительное состояние узла.
type	string: SampleData	Тип источника.

SaslMechanism

Перечисление

Механизм SASL. С течением времени могут добавляться дополнительные механизмы SASL.

Значение	Описание
PLAIN	Механизм SASL — PLAIN.
SCRAM-SHA-256	Механизм SASL — SCRAM-SHA-256.
SCRAM-SHA-512	Механизм SASL — SCRAM-SHA-512.

Schema

Объект

Представляет схему данных.

Имя	Тип	Описание
columns	ColumnSchema[]	Список столбцов в схеме.

SecurityProtocol

Перечисление

Протокол безопасности.

Значение	Описание
SASL_PLAINTEXT	Протокол безопасности SASL_PLAINTEXT.
PLAINTEXT	Протокол безопасности — PLAINTEXT.
SASL_SSL	Протокол безопасности SASL_SSL.
SSL	Протокол безопасности — SSL.

SerializationType

Перечисление

Тип сериализации. С течением времени могут добавляться дополнительные типы сериализации.

Значение	Описание
Avro	Тип сериализации — Avro.
Json	Тип сериализации — JSON.
Csv	Тип сериализации — CSV.

ServerVersion

Перечисление

Версия сервера MQTT.

Значение	Описание
V3	Версия сервера MQTT — V3.
V5	Версия сервера MQTT — V5.

SessionWindow

Объект

Имя	Тип	Описание
properties	SessionWindowProperties	Свойства окна сеанса.
type	string: Session	Тип окна.

SessionWindowProperties

Объект

Свойства для окна сеанса.

Имя	Тип	Описание
maxDuration	OperatorCommonDuration	Представляет длительность.
partitionBy	ColumnReferenceExpression	Представляет ссылку на столбец.
timeout	OperatorCommonDuration	Представляет длительность.

SlidingWindow

Объект

Имя	Тип	Описание
properties	SlidingWindowProperties	Свойства скользящего окна.
type	string: Sliding	Тип окна.

SlidingWindowProperties

Объект

Свойства скользящего окна.

Имя	Тип	Описание
duration	OperatorCommonDuration	Представляет длительность.

SnapshotLockingMode

Перечисление

Указывает стратегию блокировки, используемую при принятии начального моментального снимка (например, минимальные блокировки и расширенная блокировка для более строгой согласованности).

Значение	Описание
Minimal	Режим блокировки моментальных снимков — минимальный.
Extended	Режим блокировки моментальных снимков расширен.

SnapshotMode

Перечисление

Режим моментального снимка.

Значение	Описание
Initial	Режим моментального снимка — Initial.
InitialOnly	Режим моментального снимка — InitialOnly.
NoData	Режим моментального снимка — NoData.

SnapshotWindow

Объект

Имя	Тип	Описание
properties	SnapshotWindowProperties	Свойства окна моментального снимка.
type	string: Snapshot	Тип окна.

SnapshotWindowProperties

Объект

Свойства окна моментального снимка.

SolacePubSubQueueSourceProperties

Объект

Свойства источника очереди Solace PubSub.

Имя	Тип	Описание
dataConnectionId	string (uuid)	Идентификатор подключения к данным Solace PubSub.
mapSolaceProperties	boolean	Указывает, следует ли сопоставлять свойства стандартного сообщения Solace с заголовками записей Kafka.
mapUserProperties	boolean	Указывает, сопоставлять ли свойства пользователя из сообщения Solace с заголовками записей Kafka.
messageVpnName	string	Имя VPN сообщения Solace PubSub.
pubSubType	string: Queue	Тип Solace PubSub.
queue	string	Имя очереди Solace PubSub.

SolacePubSubSourceResponse

Объект

Ответ источника Solace PubSub.

Имя	Тип	Описание
error	ErrorInfo	Сведения об ошибке.
id	string (uuid)	Уникальный идентификатор источника.
inputSchemas	InputSchema[]	Входные схемы источника.
name	string	Уникальное имя источника.
properties	SolacePubSubSourceProperties: SolacePubSubQueueSourceProperties SolacePubSubTopicsSourceProperties	Свойства источника Solace PubSub.
status	NodeStatus	Состояние узла. С течением времени может быть добавлено дополнительное состояние узла.
type	string: SolacePubSub	Тип источника.

SolacePubSubTopicsSourceProperties

Объект

Исходные свойства разделов Solace PubSub.

Имя	Тип	Описание
dataConnectionId	string (uuid)	Идентификатор подключения к данным Solace PubSub.
mapSolaceProperties	boolean	Указывает, следует ли сопоставлять свойства стандартного сообщения Solace с заголовками записей Kafka.
mapUserProperties	boolean	Указывает, сопоставлять ли свойства пользователя из сообщения Solace с заголовками записей Kafka.
messageVpnName	string	Имя VPN сообщения Solace PubSub.
pubSubType	string: Topics	Тип Solace PubSub.
topics	string[]	Темы Solace PubSub.

SourceType

Перечисление

Представляет тип источника. С течением времени могут добавляться дополнительные типы источников.

Значение	Описание
AmazonKinesis	Тип источника Amazon Kinesis.
AmazonMSKKafka	Тип источника Amazon MSK Kafka.
ApacheKafka	Тип источника Apache Kafka.
AzureBlobStorageEvents	Тип источника событий Хранилище BLOB-объектов Azure.
AzureCosmosDBCDC	Тип источника CDC Azure Cosmos DB.
AzureDataExplorer	Тип источника Azure Data Explorer.
AzureEventGridNamespace	Тип источника пространства имен Сетка событий Azure.
AzureEventHub	Тип источника концентратора событий Azure.
AzureEventHubExtended	Тип расширенного источника концентратора событий Azure.
AzureIoTHub	Тип источника Центр Интернета вещей Azure.
AzureSQLDBCDC	Тип источника AZURE SQL DB CDC.
AzureSQLMIDBCDC	Тип источника AZURE SQL MI DB CDC.
AzureServiceBus	Тип источника Служебная шина Azure.
ConfluentCloud	Тип источника Confluent Cloud.
CustomEndpoint	Тип источника пользовательской конечной точки.
FabricCapacityOverviewEvents	Тип источника событий обзора емкости Fabric.
FabricJobEvents	Тип источника событий задания Fabric.
FabricOneLakeEvents	Тип источника Fabric OneLake Events.
FabricWorkspaceItemEvents	Тип источника событий элемента рабочей области Fabric.
GooglePubSub	Исходный тип Google PubSub.
Http	Тип источника HTTP.
MongoDBCDC	Тип источника CDC MongoDB.
Mqtt	Тип источника MQTT.
MySQLCDC	Тип источника MySQL CDC.
PostgreSQLCDC	Тип источника CDC PostgreSQL.
RealTimeWeather	Тип источника погоды в режиме реального времени.
SQLServerOnVMDBCDC	SQL Server в типе источника CDC базы данных виртуальной машины.
SampleData	Тип источника данных образца.
SolacePubSub	Тип источника Solace PubSub.

SqlOperator

Объект

Оператор SQL.

Имя	Тип	Описание
inputNodes	NodeReference[]	Список ссылок на входные узлы оператора.
inputSchemas	InputSchema[]	Входные схемы оператора.
name	string	Имя оператора.
properties	SqlOperatorProperties	Свойства оператора SQL.
type	string: SQL	Тип оператора. С течением времени могут добавляться дополнительные типы операторов.

SqlOperatorProperties

Объект

Свойства оператора SQL.

Имя	Тип	Описание
advancedSettings	AdvancedSettings	Дополнительные параметры для оператора SQL.
query	string	Выполняемый запрос Azure Stream Analytics и eventstream. Справочная документация по языку доступна здесь.

SQLServerOnVMDBCDCSourceResponse

Объект

Azure SQL Server в ответе источника CDC базы данных виртуальной машины.

Имя	Тип	Описание
error	ErrorInfo	Сведения об ошибке.
id	string (uuid)	Уникальный идентификатор источника.
inputSchemas	InputSchema[]	Входные схемы источника.
name	string	Уникальное имя источника.
properties	BaseSQLCDCSourceProperties	Базовые свойства источника SQL CDC.
status	NodeStatus	Состояние узла. С течением времени может быть добавлено дополнительное состояние узла.
type	string: SQLServerOnVMDBCDC	Тип источника.

StartPosition

Перечисление

Начальная позиция в потоке концентратора событий Azure.

Значение	Описание
Earliest	Начните с самого раннего события.
Latest	Начните с последнего события.

StreamType

Перечисление

Представляет тип потока. С течением времени могут добавляться дополнительные типы потоков.

Значение	Описание
DefaultStream	Поток является потоком по умолчанию.
DerivedStream	Поток является производным от другого потока.

TumblingWindow

Объект

Имя	Тип	Описание
properties	TumblingWindowProperties	Свойства для переворачивающегося окна.
type	string: Tumbling	Тип окна.

TumblingWindowProperties

Объект

Свойства для переворачивающегося окна.

Имя	Тип	Описание
duration	OperatorCommonDuration	Представляет длительность.
offset	OperatorCommonDuration	Представляет длительность.

Type

Перечисление

Пример типа данных. С течением времени могут добавляться дополнительные примеры типов данных.

Значение	Описание
YellowTaxi	Примеры данных желтого такси.
StockMarket	Примеры данных фондового рынка.
Bicycles	Примеры данных велосипедов.
Buses	Примеры данных автобусов.
SP500Stocks	Примеры данных акций S&P 500.
SemanticModelLogs	Примеры данных журналов семантической модели.

UnionOperator

Объект

Оператор union.

Имя	Тип	Описание
inputNodes	NodeReference[]	Список ссылок на входные узлы оператора.
inputSchemas	InputSchema[]	Входные схемы оператора.
name	string	Имя оператора.
properties	UnionOperatorProperties	Свойства оператора union.
type	string: Union	Тип оператора. С течением времени могут добавляться дополнительные типы операторов.

UnionOperatorProperties

Объект

Свойства оператора union.

Unit

Перечисление

Единица длительности.

Значение	Описание
Microsecond	Единица микросекунда.
Millisecond	Единица миллисекунда.
Second	Второй урок.
Minute	Единица минуты.
Hour	Единица часа.
Day	Единица дня.
Weekday	Единица еженедельного дня.
Week	Единица недели.
DayOfYear	Единица DayOfYear.
Month	Единица месяца.
Quarter	Четверть единицы.
Year	Единица года.