通过

Topology - Get Eventstream Topology

  • 参考
服务:
Eventstream
API 版本:
v1

返回指定事件流的拓扑。

权限

调用方必须具有 查看器 或更高版本的工作区角色。

所需的委派范围

Eventstream.Read.All 或 Eventstream.ReadWrite.All 或 Item.Read.All 或 Item.ReadWrite.All

Microsoft Entra 支持的标识

此 API 支持本节中列出的Microsoft 标识。

身份 支持
用户 是的
服务主体 和 托管标识 是的

接口

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

URI 参数

名称 在 必需 类型 说明
eventstreamId
 path True

string (uuid)

事件流标识符。
workspaceId
 path True

string (uuid)

工作区 ID。

响应

名称 类型 说明
200 OK

EventstreamTopologyResponse

请求成功完成。
Other Status Codes

ErrorResponse

常见错误代码：

  • ItemNotFound - 找不到请求的项目。

示例

Get an eventstream topology example

示例请求

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

示例响应

状态代码:
200

定义

名称 说明
ActivatorDestinationProperties

激活器目标属性。
ActivatorDestinationResponse

激活器目标响应。
AggregateOperator

聚合运算符。
AggregateOperatorProperties

聚合运算符属性。
Aggregation

表示列的聚合。
AmazonKinesisSourceProperties

Amazon Kinesis 源属性。
AmazonKinesisSourceResponse

Amazon Kinesis 源属性响应。
AmazonMSKKafkaSourceProperties

Amazon MSK Kafka 源属性。
AmazonMSKKafkaSourceResponse

Amazon MSK Kafka 源响应。
ApacheKafkaSourceProperties

Apache Kafka 源属性。
ApacheKafkaSourceResponse

Apache Kafka 源响应。
AvroSerializationInfo

Avro 序列化信息。
AvroSerializationProperties

Avro 序列化属性。
AzureBlobStorageEvents

Azure Blob 存储事件源。
AzureBlobStorageEventsSourceProperties

Azure Blob 存储事件源属性。
AzureBlobStorageEventsSourceResponse

Azure Blob 存储事件源响应。
AzureCosmosDBCDCSourceProperties

Azure Cosmos DB CDC 源属性。
AzureCosmosDBCDCSourceResponse

Azure Cosmos DB CDC 源响应。
AzureEventHubSourceProperties

Azure 事件中心源属性。
AzureEventHubSourceResponse

Azure 事件中心源响应。
AzureIoTHubSourceProperties

Azure IoT 中心源属性。
AzureIoTHubSourceResponse

Azure IoT 中心源响应。
AzureSQLDBCDCSourceResponse

Azure SQL DB CDC 源响应。
AzureSQLMIDBCDCSourceResponse

Azure SQL MI DB CDC 源响应。
BaseKafkaSourceProperties

基本 Kafka 源属性。
BaseSQLCDCSourceProperties

基本 SQL CDC 源属性。
CastProperties

强制转换作的属性。
ColumnReferenceExpression

表示对列的引用。
ColumnSchema

表示列的架构。
CompatibilityLevel

表示 Eventstream 拓扑的兼容性级别。 随着时间的推移，可能会添加其他兼容性级别。
ConfluentCloudSourceResponse

Confluent 云源响应。
CsvSerializationInfo

CSV 序列化信息。
CsvSerializationProperties

CSV 序列化属性。
CustomEndpointDestinationProperties

自定义终结点事件目标属性。
CustomEndpointDestinationResponse

自定义终结点事件目标响应。
CustomEndpointSourceProperties

自定义终结点事件源属性。
CustomEndpointSourceResponse

自定义终结点事件源响应。
DataType

表示数据类型。 可能会随着时间的推移添加其他数据类型。
DefaultStreamProperties

默认流属性。
DefaultStreamResponse

默认流响应。
DerivedStreamProperties

派生的流属性。
DerivedStreamResponse

派生的流响应。
DestinationType

表示目标的类型。 可能会随着时间的推移添加其他目标类型。
ErrorInfo

表示错误信息。
ErrorRelatedResource

与错误相关的资源详细信息对象。
ErrorResponse

错误响应。
ErrorResponseDetails

错误响应详细信息。
EventhouseDestinationResponse

Eventhouse 目标响应。
EventhouseDirectIngestionModeDestinationProperties

Eventhouse DirectIngestion 模式目标属性。
EventhouseProcessedIngestionModeDestinationProperties

Eventhouse ProcessedIngestion 模式目标属性。
EventstreamTopologyResponse

表示 Eventstream 拓扑响应。
ExpandOperator

Expand 运算符。
ExpandOperatorProperties

展开运算符属性。
FabricCapacityUtilizationEventsSourceProperties

构造容量利用率事件源属性。
FabricCapacityUtilizationEventsSourceResponse

构造容量利用率事件源响应。
FabricJobEventsSourceProperties

Fabric 作业事件源属性。
FabricJobEventsSourceResponse

Fabric 作业事件源响应。
FabricOneLakeEventsSourceProperties

Fabric OneLake 事件源属性。
FabricOneLakeEventsSourceResponse

Fabric OneLake 事件源响应。
FabricWorkspaceItemEventsSourceProperties

Fabric 工作区项事件源属性。
FabricWorkspaceItemEventsSourceResponse

Fabric 工作区项事件源响应。
FilterCondition

表示筛选器条件。
FilterOperator

筛选器运算符。
FilterOperatorProperties

筛选器运算符属性。
FunctionCallProperties

函数调用作的属性。
GooglePubSubSourceProperties

Google Pub/Sub 源属性。
GooglePubSubSourceResponse

Google Pub/Sub 源响应。
GroupByOperator

GroupBy 运算符。
GroupByOperatorProperties

GroupBy 运算符属性。
HoppingWindow
HoppingWindowProperties

跳跃窗口的属性。
IncludedEventTypes

包含的事件类型。
InColumnAggregation

表示列的聚合。
InputSchema

表示源、目标或运算符的输入架构。
JoinOn

表示联接条件。
JoinOperator

Join 运算符。
JoinOperatorProperties

联接运算符属性。
JsonSerializationInfo

JSON 序列化信息。
JsonSerializationProperties

JSON 序列化属性。
LakehouseDestinationProperties

Lakehouse 目标属性。
LakehouseDestinationResponse

Lakehouse 目标响应。
LiteralExpression

表示文本表达式。
ManageFieldsCastOperation

表示管理字段强制转换作。
ManageFieldsFunctionCallOperation

表示管理字段函数调用作。
ManageFieldsOperator

ManageFields 运算符。
ManageFieldsOperatorProperties

ManageFields 运算符属性。
ManageFieldsRenameOperation

表示管理字段重命名作。
MySQLCDCSourceResponse

MySQL CDC 源响应。
NodeReference

表示使用其唯一名称对节点的引用。
NodeStatus

节点的状态。 可能会随着时间的推移添加其他节点状态。
OperatorCommonDuration

表示持续时间。
PostgreSQLCDCSourceProperties

PostgreSQL CDC 源属性。
PostgreSQLCDCSourceResponse

PostgreSQL CDC 源响应。
RenameProperties

重命名作的属性。
SampleDataSourceProperties

示例数据源属性。
SampleDataSourceResponse

示例数据事件源响应。
Schema

表示数据的架构。
SerializationType

序列化类型。
SessionWindow
SessionWindowProperties

会话窗口的属性。
SlidingWindow
SlidingWindowProperties

滑动窗口的属性。
SnapshotWindow
SnapshotWindowProperties

快照窗口的属性。
SourceType

表示源的类型。 可能会随着时间的推移添加其他源类型。
SQLServerOnVMDBCDCSourceResponse

VM DB CDC 源响应上的 Azure SQL Server。
StreamType

表示流的类型。 可能会随着时间的推移添加其他流类型。
TumblingWindow
TumblingWindowProperties

翻转窗口的属性。
UnionOperator

Union 运算符。
UnionOperatorProperties

Union 运算符属性。

ActivatorDestinationProperties

Object

激活器目标属性。

名称 类型 说明
inputSerialization SerializationInfo:

序列化信息。
itemId

string (uuid)

激活器项标识符。
workspaceId

string (uuid)

激活器工作区标识符。

ActivatorDestinationResponse

Object

激活器目标响应。

名称 类型 说明
error

ErrorInfo

错误信息。
id

string (uuid)

目标的唯一标识符。
inputNodes

NodeReference[]

对目标的输入节点的引用列表。
inputSchemas

InputSchema[]

目标的输入架构。
name

string

目标的唯一名称。
properties

ActivatorDestinationProperties

激活器目标的属性。
status

NodeStatus

节点的状态。 可能会随着时间的推移添加其他节点状态。
type string:

Activator

目标的类型。

AggregateOperator

Object

聚合运算符。

名称 类型 说明
inputNodes

NodeReference[]

对运算符输入节点的引用的列表。
inputSchemas

InputSchema[]

运算符的输入架构。
name

string

运算符的名称。
properties

AggregateOperatorProperties

聚合运算符属性。
type string:

Aggregate

运算符的类型。 可能会随着时间的推移添加其他运算符类型。

AggregateOperatorProperties

Object

聚合运算符属性。

名称 类型 说明
aggregations

InColumnAggregation[]

聚合的列表。

Aggregation

Object

表示列的聚合。

名称 类型 说明
aggregationFunction enum:
  • Average
  • Count
  • Maximum
  • Minimum
  • PercentileContinuous
  • PercentileDiscrete
  • StandardDeviation
  • StandardDeviationPopulation
  • Sum
  • Variance
  • VariancePopulation

聚合函数。
alias

string

聚合的别名。
arguments

object[]

聚合的参数列表。
column

ColumnReferenceExpression

表示对列的引用。

AmazonKinesisSourceProperties

Object

Amazon Kinesis 源属性。

名称 类型 说明
dataConnectionId

string (uuid)

Amazon Kinesis 数据连接标识符。
region enum:
  • 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
  • us-east-2
  • us-gov-east-1
  • us-gov-west-1
  • us-west-1
  • us-west-2

Amazon Kinesis 区域名称。

AmazonKinesisSourceResponse

Object

Amazon Kinesis 源属性响应。

名称 类型 说明
error

ErrorInfo

错误信息。
id

string (uuid)

源的唯一标识符。
inputSchemas

InputSchema[]

源的输入架构。
name

string

源的唯一名称。
properties

AmazonKinesisSourceProperties

Amazon Kinesis 源的属性。
status

NodeStatus

节点的状态。 可能会随着时间的推移添加其他节点状态。
type string:

AmazonKinesis

源的类型。

AmazonMSKKafkaSourceProperties

Object

Amazon MSK Kafka 源属性。

名称 类型 默认值 说明
autoOffsetReset enum:
  • Earliest
  • Latest
  • None
None

自动偏移重置属性。 默认值为 None。
consumerGroupName

string

使用者组名称。
dataConnectionId

string (uuid)

Kafka 数据连接标识符。
saslMechanism enum:
  • PLAIN
  • SCRAM-SHA-256
  • SCRAM-SHA-512

SASL 机制。
securityProtocol enum:
  • PLAINTEXT
  • SASL_PLAINTEXT
  • SASL_SSL
  • SSL

安全协议。
topic

string

Kafka 主题。

AmazonMSKKafkaSourceResponse

Object

Amazon MSK Kafka 源响应。

名称 类型 说明
error

ErrorInfo

错误信息。
id

string (uuid)

源的唯一标识符。
inputSchemas

InputSchema[]

源的输入架构。
name

string

源的唯一名称。
properties

AmazonMSKKafkaSourceProperties

Amazon MSK Kafka 源的属性。
status

NodeStatus

节点的状态。 可能会随着时间的推移添加其他节点状态。
type string:

AmazonMSKKafka

源的类型。

ApacheKafkaSourceProperties

Object

Apache Kafka 源属性。

名称 类型 默认值 说明
autoOffsetReset enum:
  • Earliest
  • Latest
  • None
None

自动偏移重置属性。 默认值为 None。
consumerGroupName

string

使用者组名称。
dataConnectionId

string (uuid)

Kafka 数据连接标识符。
saslMechanism enum:
  • PLAIN
  • SCRAM-SHA-256
  • SCRAM-SHA-512

SASL 机制。
securityProtocol enum:
  • PLAINTEXT
  • SASL_PLAINTEXT
  • SASL_SSL
  • SSL

安全协议。
topic

string

Kafka 主题。

ApacheKafkaSourceResponse

Object

Apache Kafka 源响应。

名称 类型 说明
error

ErrorInfo

错误信息。
id

string (uuid)

源的唯一标识符。
inputSchemas

InputSchema[]

源的输入架构。
name

string

源的唯一名称。
properties

ApacheKafkaSourceProperties

Apache Kafka 源的属性。
status

NodeStatus

节点的状态。 可能会随着时间的推移添加其他节点状态。
type string:

ApacheKafka

源的类型。

AvroSerializationInfo

Object

Avro 序列化信息。

名称 类型 说明
properties

AvroSerializationProperties

Avro 序列化属性。
type string:

Avro

序列化类型。

AvroSerializationProperties

Object

Avro 序列化属性。

AzureBlobStorageEvents

Object

Azure Blob 存储事件源。

名称 类型 说明
azureResourceId

string

Blob 存储的 Azure 资源标识符。
id

string (uuid)

源的唯一标识符。
includedEventTypes

IncludedEventTypes[]

包含的事件类型。

AzureBlobStorageEventsSourceProperties

Object

Azure Blob 存储事件源属性。

名称 类型 说明
azureBlobStorageEvents

AzureBlobStorageEvents[]

Azure Blob 存储事件。
streamEvents

boolean

指示是否流式传输事件。

AzureBlobStorageEventsSourceResponse

Object

Azure Blob 存储事件源响应。

名称 类型 说明
error

ErrorInfo

错误信息。
id

string (uuid)

源的唯一标识符。
inputSchemas

InputSchema[]

源的输入架构。
name

string

源的唯一名称。
properties

AzureBlobStorageEventsSourceProperties

Azure Blob 存储事件源的属性。
status

NodeStatus

节点的状态。 可能会随着时间的推移添加其他节点状态。
type string:

AzureBlobStorageEvents

源的类型。

AzureCosmosDBCDCSourceProperties

Object

Azure Cosmos DB CDC 源属性。

名称 类型 说明
containerName

string

容器名称。
dataConnectionId

string (uuid)

Azure Cosmos DB CDC 数据连接标识符。
databaseName

string

数据库名称。
offsetPolicy enum:
  • Earliest
  • Latest

偏移策略。

AzureCosmosDBCDCSourceResponse

Object

Azure Cosmos DB CDC 源响应。

名称 类型 说明
error

ErrorInfo

错误信息。
id

string (uuid)

源的唯一标识符。
inputSchemas

InputSchema[]

源的输入架构。
name

string

源的唯一名称。
properties

AzureCosmosDBCDCSourceProperties

Azure Cosmos DB CDC 源的属性。
status

NodeStatus

节点的状态。 可能会随着时间的推移添加其他节点状态。
type string:

AzureCosmosDBCDC

源的类型。

AzureEventHubSourceProperties

Object

Azure 事件中心源属性。

名称 类型 说明
consumerGroupName

string

使用者组名称。
dataConnectionId

string (uuid)

Azure 事件中心数据连接标识符。
inputSerialization SerializationInfo:

序列化信息。

AzureEventHubSourceResponse

Object

Azure 事件中心源响应。

名称 类型 说明
error

ErrorInfo

错误信息。
id

string (uuid)

源的唯一标识符。
inputSchemas

InputSchema[]

源的输入架构。
name

string

源的唯一名称。
properties

AzureEventHubSourceProperties

Azure 事件中心源的属性。
status

NodeStatus

节点的状态。 可能会随着时间的推移添加其他节点状态。
type string:

AzureEventHub

源的类型。

AzureIoTHubSourceProperties

Object

Azure IoT 中心源属性。

名称 类型 说明
consumerGroupName

string

使用者组名称。
dataConnectionId

string (uuid)

Azure IoT 中心数据连接标识符。
inputSerialization SerializationInfo:

序列化信息。

AzureIoTHubSourceResponse

Object

Azure IoT 中心源响应。

名称 类型 说明
error

ErrorInfo

错误信息。
id

string (uuid)

源的唯一标识符。
inputSchemas

InputSchema[]

源的输入架构。
name

string

源的唯一名称。
properties

AzureIoTHubSourceProperties

Azure IoT 中心源的属性。
status

NodeStatus

节点的状态。 可能会随着时间的推移添加其他节点状态。
type string:

AzureIoTHub

源的类型。

AzureSQLDBCDCSourceResponse

Object

Azure SQL DB CDC 源响应。

名称 类型 说明
error

ErrorInfo

错误信息。
id

string (uuid)

源的唯一标识符。
inputSchemas

InputSchema[]

源的输入架构。
name

string

源的唯一名称。
properties

BaseSQLCDCSourceProperties

基本 SQL CDC 源属性。
status

NodeStatus

节点的状态。 可能会随着时间的推移添加其他节点状态。
type string:

AzureSQLDBCDC

源的类型。

AzureSQLMIDBCDCSourceResponse

Object

Azure SQL MI DB CDC 源响应。

名称 类型 说明
error

ErrorInfo

错误信息。
id

string (uuid)

源的唯一标识符。
inputSchemas

InputSchema[]

源的输入架构。
name

string

源的唯一名称。
properties

BaseSQLCDCSourceProperties

基本 SQL CDC 源属性。
status

NodeStatus

节点的状态。 可能会随着时间的推移添加其他节点状态。
type string:

AzureSQLMIDBCDC

源的类型。

BaseKafkaSourceProperties

Object

基本 Kafka 源属性。

名称 类型 默认值 说明
autoOffsetReset enum:
  • Earliest
  • Latest
  • None
None

自动偏移重置属性。 默认值为 None。
consumerGroupName

string

使用者组名称。
dataConnectionId

string (uuid)

Kafka 数据连接标识符。
topic

string

Kafka 主题。

BaseSQLCDCSourceProperties

Object

基本 SQL CDC 源属性。

名称 类型 说明
dataConnectionId

string (uuid)

SQL CDC 数据连接标识符。
tableName

string

表名称。

CastProperties

Object

强制转换作的属性。

名称 类型 说明
column

ColumnReferenceExpression

表示对列的引用。
targetDataType

DataType

表示数据类型。 可能会随着时间的推移添加其他数据类型。

ColumnReferenceExpression

Object

表示对列的引用。

名称 类型 说明
columnName

string

列的名称。
columnPathSegments

string[]

嵌套列的列引用的路径段。
node

string

引用节点的名称。

ColumnSchema

Object

表示列的架构。

名称 类型 说明
fields

ColumnSchema[]

记录或数组数据类型的字段列表。
items

ColumnSchema

数组项的架构。
name

string

列的名称。
type

DataType

列的数据类型。

CompatibilityLevel

枚举

表示 Eventstream 拓扑的兼容性级别。 随着时间的推移，可能会添加其他兼容性级别。

值 说明
1.0

Eventstream 拓扑的兼容性级别为 1.0。

ConfluentCloudSourceResponse

Object

Confluent 云源响应。

名称 类型 说明
error

ErrorInfo

错误信息。
id

string (uuid)

源的唯一标识符。
inputSchemas

InputSchema[]

源的输入架构。
name

string

源的唯一名称。
properties

BaseKafkaSourceProperties

基本 Kafka 源属性。
status

NodeStatus

节点的状态。 可能会随着时间的推移添加其他节点状态。
type string:

ConfluentCloud

源的类型。

CsvSerializationInfo

Object

CSV 序列化信息。

名称 类型 说明
properties

CsvSerializationProperties

CSV 序列化属性。
type string:

Csv

序列化类型。

CsvSerializationProperties

Object

CSV 序列化属性。

名称 类型 说明
encoding enum:

UTF8

编码类型。
fieldDelimiter

string

字段分隔符。
format enum:
  • WithHeaders
  • WithoutHeaders

格式类型。

CustomEndpointDestinationProperties

Object

自定义终结点事件目标属性。

CustomEndpointDestinationResponse

Object

自定义终结点事件目标响应。

名称 类型 说明
error

ErrorInfo

错误信息。
id

string (uuid)

目标的唯一标识符。
inputNodes

NodeReference[]

对目标的输入节点的引用列表。
inputSchemas

InputSchema[]

目标的输入架构。
name

string

目标的唯一名称。
properties

CustomEndpointDestinationProperties

自定义终结点目标的属性。
status

NodeStatus

节点的状态。 可能会随着时间的推移添加其他节点状态。
type string:

CustomEndpoint

目标的类型。

CustomEndpointSourceProperties

Object

自定义终结点事件源属性。

CustomEndpointSourceResponse

Object

自定义终结点事件源响应。

名称 类型 说明
error

ErrorInfo

错误信息。
id

string (uuid)

源的唯一标识符。
inputSchemas

InputSchema[]

源的输入架构。
name

string

源的唯一名称。
properties

CustomEndpointSourceProperties

自定义终结点事件源的属性。
status

NodeStatus

节点的状态。 可能会随着时间的推移添加其他节点状态。
type string:

CustomEndpoint

源的类型。

DataType

枚举

表示数据类型。 可能会随着时间的推移添加其他数据类型。

值 说明
Any

未知数据类型。
Array

数组数据类型。
BigInt

BigInt 数据类型。
Bit

位数据类型。
DateTime

DateTime 数据类型。
Float

Float 数据类型。
Nvarchar(max)

Nvarchar（max） 数据类型。
Record

记录数据类型。

DefaultStreamProperties

Object

默认流属性。

DefaultStreamResponse

Object

默认流响应。

名称 类型 说明
id

string (uuid)

流的唯一标识符。
inputNodes

NodeReference[]

对流的输入节点的引用的列表。
name

string

流的唯一名称。
properties

DefaultStreamProperties

默认流的属性。
type string:

DefaultStream

流的类型。

DerivedStreamProperties

Object

派生的流属性。

名称 类型 说明
inputSerialization SerializationInfo:

序列化信息。

DerivedStreamResponse

Object

派生的流响应。

名称 类型 说明
id

string (uuid)

流的唯一标识符。
inputNodes

NodeReference[]

对流的输入节点的引用的列表。
name

string

流的唯一名称。
properties

DerivedStreamProperties

派生流的属性。
type string:

DerivedStream

流的类型。

DestinationType

枚举

表示目标的类型。 可能会随着时间的推移添加其他目标类型。

值 说明
Activator

激活器目标类型。
CustomEndpoint

CustomEndpoint 目标类型。
Eventhouse

Eventhouse 目标类型。
Lakehouse

Lakehouse 目标类型。

ErrorInfo

Object

表示错误信息。

名称 类型 说明
errorCode

string

错误代码。
errorDetails

string[]

错误详细信息。
errorMessage

string

错误消息。

ErrorRelatedResource

Object

与错误相关的资源详细信息对象。

名称 类型 说明
resourceId

string

错误中涉及的资源 ID。
resourceType

string

错误中涉及的资源的类型。

ErrorResponse

Object

错误响应。

名称 类型 说明
errorCode

string

提供有关错误条件的信息的特定标识符，允许服务与其用户之间的标准化通信。
message

string

错误的人工可读表示形式。
moreDetails

ErrorResponseDetails[]

其他错误详细信息的列表。
relatedResource

ErrorRelatedResource

与错误相关的资源详细信息。
requestId

string

与错误关联的请求的 ID。

ErrorResponseDetails

Object

错误响应详细信息。

名称 类型 说明
errorCode

string

提供有关错误条件的信息的特定标识符，允许服务与其用户之间的标准化通信。
message

string

错误的人工可读表示形式。
relatedResource

ErrorRelatedResource

与错误相关的资源详细信息。

EventhouseDestinationResponse

Object

Eventhouse 目标响应。

名称 类型 说明
error

ErrorInfo

错误信息。
id

string (uuid)

目标的唯一标识符。
inputNodes

NodeReference[]

对目标的输入节点的引用列表。
inputSchemas

InputSchema[]

目标的输入架构。
name

string

目标的唯一名称。
properties EventhouseDestinationProperties:

Eventhouse 目标属性。
status

NodeStatus

节点的状态。 可能会随着时间的推移添加其他节点状态。
type string:

Eventhouse

目标的类型。

EventhouseDirectIngestionModeDestinationProperties

Object

Eventhouse DirectIngestion 模式目标属性。

名称 类型 说明
connectionName

string

连接名称。
dataIngestionMode string:

DirectIngestion

数据引入模式。
itemId

string (uuid)

Eventhouse 项标识符。
mappingRuleName

string

映射规则名称。
tableName

string

KQL 表名称。
workspaceId

string (uuid)

Eventhouse 工作区标识符。

EventhouseProcessedIngestionModeDestinationProperties

Object

Eventhouse ProcessedIngestion 模式目标属性。

名称 类型 说明
dataIngestionMode string:

ProcessedIngestion

数据引入模式。
databaseName

string

KQL 数据库名称。
inputSerialization SerializationInfo:

序列化信息。
itemId

string (uuid)

Eventhouse 项标识符。
tableName

string

KQL 表名称。
workspaceId

string (uuid)

Eventhouse 工作区标识符。

EventstreamTopologyResponse

Object

表示 Eventstream 拓扑响应。

名称 类型 说明
compatibilityLevel

CompatibilityLevel

表示 Eventstream 拓扑的兼容性级别。 随着时间的推移，可能会添加其他兼容性级别。
destinations DestinationResponse[]:

Eventstream 目标列表。
operators Operator[]:

Eventstream 运算符的列表。
sources SourceResponse[]:

事件流源的列表。
streams StreamResponse[]:

事件流默认值和派生流的列表。

ExpandOperator

Object

Expand 运算符。

名称 类型 说明
inputNodes

NodeReference[]

对运算符输入节点的引用的列表。
inputSchemas

InputSchema[]

运算符的输入架构。
name

string

运算符的名称。
properties

ExpandOperatorProperties

展开运算符属性。
type string:

Expand

运算符的类型。 可能会随着时间的推移添加其他运算符类型。

ExpandOperatorProperties

Object

展开运算符属性。

名称 类型 说明
column

ColumnReferenceExpression[]

要展开的列的列表。
ignoreMissingOrEmpty

boolean

缺少或空列设置。 True - 忽略列，False - 不要忽略列。

FabricCapacityUtilizationEventsSourceProperties

Object

构造容量利用率事件源属性。

名称 类型 说明
capacityId

string (uuid)

容量标识符。
eventScope enum:
  • Capacity
  • Item
  • SubItem
  • Tenant
  • Workspace
filters

object

中 https://learn.microsoft.com/en-us/azure/event-grid/event-filtering#advanced-filtering定义的高级筛选器。
includedEventTypes

string[]

包含的事件类型。

FabricCapacityUtilizationEventsSourceResponse

Object

构造容量利用率事件源响应。

名称 类型 说明
error

ErrorInfo

错误信息。
id

string (uuid)

源的唯一标识符。
inputSchemas

InputSchema[]

源的输入架构。
name

string

源的唯一名称。
properties

FabricCapacityUtilizationEventsSourceProperties

构造容量利用率事件源的属性。
status

NodeStatus

节点的状态。 可能会随着时间的推移添加其他节点状态。
type string:

FabricCapacityUtilizationEvents

源的类型。

FabricJobEventsSourceProperties

Object

Fabric 作业事件源属性。

名称 类型 说明
eventScope enum:
  • Capacity
  • Item
  • SubItem
  • Tenant
  • Workspace
filters

object

中 https://learn.microsoft.com/en-us/azure/event-grid/event-filtering#advanced-filtering定义的高级筛选器。
includedEventTypes

string[]

包含的事件类型。
itemId

string (uuid)

项标识符。
workspaceId

string (uuid)

工作区标识符。

FabricJobEventsSourceResponse

Object

Fabric 作业事件源响应。

名称 类型 说明
error

ErrorInfo

错误信息。
id

string (uuid)

源的唯一标识符。
inputSchemas

InputSchema[]

源的输入架构。
name

string

源的唯一名称。
properties

FabricJobEventsSourceProperties

Fabric 作业事件源的属性。
status

NodeStatus

节点的状态。 可能会随着时间的推移添加其他节点状态。
type string:

FabricJobEvents

源的类型。

FabricOneLakeEventsSourceProperties

Object

Fabric OneLake 事件源属性。

名称 类型 说明
filters

object

中 https://learn.microsoft.com/en-us/azure/event-grid/event-filtering#advanced-filtering定义的高级筛选器。
includedEventTypes

string[]

包含的事件类型。
itemId

string (uuid)

项标识符。
oneLakePaths

string[]

OneLake 路径。
tenantId

string (uuid)

租户标识符。
workspaceId

string (uuid)

工作区标识符。

FabricOneLakeEventsSourceResponse

Object

Fabric OneLake 事件源响应。

名称 类型 说明
error

ErrorInfo

错误信息。
id

string (uuid)

源的唯一标识符。
inputSchemas

InputSchema[]

源的输入架构。
name

string

源的唯一名称。
properties

FabricOneLakeEventsSourceProperties

Fabric OneLake 事件源的属性。
status

NodeStatus

节点的状态。 可能会随着时间的推移添加其他节点状态。
type string:

FabricOneLakeEvents

源的类型。

FabricWorkspaceItemEventsSourceProperties

Object

Fabric 工作区项事件源属性。

名称 类型 说明
eventScope enum:
  • Capacity
  • Item
  • SubItem
  • Tenant
  • Workspace
filters

object

中 https://learn.microsoft.com/en-us/azure/event-grid/event-filtering#advanced-filtering定义的高级筛选器。
includedEventTypes

string[]

包含的事件类型。
itemId

string (uuid)

项标识符。
workspaceId

string (uuid)

工作区标识符。

FabricWorkspaceItemEventsSourceResponse

Object

Fabric 工作区项事件源响应。

名称 类型 说明
error

ErrorInfo

错误信息。
id

string (uuid)

源的唯一标识符。
inputSchemas

InputSchema[]

源的输入架构。
name

string

源的唯一名称。
properties

FabricWorkspaceItemEventsSourceProperties

Fabric 工作区项事件源的属性。
status

NodeStatus

节点的状态。 可能会随着时间的推移添加其他节点状态。
type string:

FabricWorkspaceItemEvents

源的类型。

FilterCondition

Object

表示筛选器条件。

名称 类型 说明
column

ColumnReferenceExpression

表示对列的引用。
operatorType enum:
  • Contains
  • DoesNotContain
  • DoesNotEndWith
  • DoesNotStartWith
  • EndsWith
  • Equals
  • GreaterThan
  • GreaterThanOrEquals
  • IsEmpty
  • IsNotNull
  • IsNotNullOrEmpty
  • IsNull
  • LessThan
  • LessThanOrEquals
  • NotEquals
  • StartsWith

运算符类型。
value

LiteralExpression

表示文本表达式。

FilterOperator

Object

筛选器运算符。

名称 类型 说明
inputNodes

NodeReference[]

对运算符输入节点的引用的列表。
inputSchemas

InputSchema[]

运算符的输入架构。
name

string

运算符的名称。
properties

FilterOperatorProperties

筛选器运算符属性。
type string:

Filter

运算符的类型。 可能会随着时间的推移添加其他运算符类型。

FilterOperatorProperties

Object

筛选器运算符属性。

名称 类型 说明
conditions

FilterCondition[]

筛选条件的列表。

FunctionCallProperties

Object

函数调用作的属性。

名称 类型 说明
arguments

object[]

函数的参数列表。
functionName

string

函数的名称。

GooglePubSubSourceProperties

Object

Google Pub/Sub 源属性。

名称 类型 说明
dataConnectionId

string (uuid)

Google Pub/Sub 数据连接标识符。

GooglePubSubSourceResponse

Object

Google Pub/Sub 源响应。

名称 类型 说明
error

ErrorInfo

错误信息。
id

string (uuid)

源的唯一标识符。
inputSchemas

InputSchema[]

源的输入架构。
name

string

源的唯一名称。
properties

GooglePubSubSourceProperties

Google Pub/Sub 源的属性。
status

NodeStatus

节点的状态。 可能会随着时间的推移添加其他节点状态。
type string:

GooglePubSub

源的类型。

GroupByOperator

Object

GroupBy 运算符。

名称 类型 说明
inputNodes

NodeReference[]

对运算符输入节点的引用的列表。
inputSchemas

InputSchema[]

运算符的输入架构。
name

string

运算符的名称。
properties

GroupByOperatorProperties

GroupBy 运算符属性。
type string:

GroupBy

运算符的类型。 可能会随着时间的推移添加其他运算符类型。

GroupByOperatorProperties

Object

GroupBy 运算符属性。

名称 类型 说明
aggregations

Aggregation[]

聚合的列表。
groupBy

ColumnReferenceExpression[]

要分组依据的列的列表。
window GroupByWindow:

表示按运算符分组的窗口。

HoppingWindow

Object
名称 类型 说明
properties

HoppingWindowProperties

跳跃窗口的属性。
type string:

Hopping

窗口的类型。

HoppingWindowProperties

Object

跳跃窗口的属性。

名称 类型 说明
duration

OperatorCommonDuration

表示持续时间。
hopSize

OperatorCommonDuration

表示持续时间。
offset

OperatorCommonDuration

表示持续时间。

IncludedEventTypes

枚举

包含的事件类型。

值 说明
Microsoft.Storage.AsyncOperationInitiated
Microsoft.Storage.BlobCreated
Microsoft.Storage.BlobDeleted
Microsoft.Storage.BlobInventoryPolicyCompleted
Microsoft.Storage.BlobRenamed
Microsoft.Storage.BlobTierChanged
Microsoft.Storage.DirectoryCreated
Microsoft.Storage.DirectoryDeleted
Microsoft.Storage.DirectoryRenamed
Microsoft.Storage.LifecyclePolicyCompleted

InColumnAggregation

Object

表示列的聚合。

名称 类型 说明
aggregationFunction enum:
  • Average
  • Count
  • Maximum
  • Minimum
  • PercentileContinuous
  • PercentileDiscrete
  • StandardDeviation
  • StandardDeviationPopulation
  • Sum
  • Variance
  • VariancePopulation

聚合函数。
alias

string

聚合的别名。
arguments

object[]

聚合的参数列表。
column

ColumnReferenceExpression

表示对列的引用。
duration

OperatorCommonDuration

表示持续时间。
partitionBy

ColumnReferenceExpression[]

要分区依据的列的列表。

InputSchema

Object

表示源、目标或运算符的输入架构。

名称 类型 说明
name

string

输入架构的名称。
schema

Schema

表示数据的架构。

JoinOn

Object

表示联接条件。

名称 类型 说明
left

ColumnReferenceExpression

表示对列的引用。
right

ColumnReferenceExpression

表示对列的引用。

JoinOperator

Object

Join 运算符。

名称 类型 说明
inputNodes

NodeReference[]

对运算符输入节点的引用的列表。
inputSchemas

InputSchema[]

运算符的输入架构。
name

string

运算符的名称。
properties

JoinOperatorProperties

联接运算符属性。
type string:

Join

运算符的类型。 可能会随着时间的推移添加其他运算符类型。

JoinOperatorProperties

Object

联接运算符属性。

名称 类型 说明
duration

OperatorCommonDuration

表示持续时间。
joinOn

JoinOn[]

联接条件的列表。
joinType enum:
  • Inner
  • LeftOuter

联接的类型。

JsonSerializationInfo

Object

JSON 序列化信息。

名称 类型 说明
properties

JsonSerializationProperties

JSON 序列化属性。
type string:

Json

序列化类型。

JsonSerializationProperties

Object

JSON 序列化属性。

名称 类型 说明
encoding enum:

UTF8

编码类型。

LakehouseDestinationProperties

Object

Lakehouse 目标属性。

名称 类型 默认值 说明
deltaTable

string

增量表名称。
inputSerialization SerializationInfo:

序列化信息。
itemId

string (uuid)

Lakehouse 项标识符。
maximumDurationInSeconds

integer

120

输出批处理的最大持续时间（以秒为单位）。 默认值为 120。
minimumRows

integer

100000

输出批处理的最小行数。 默认值为 100000。
schema

string

架构名称。
workspaceId

string (uuid)

Lakehouse 工作区标识符。

LakehouseDestinationResponse

Object

Lakehouse 目标响应。

名称 类型 说明
error

ErrorInfo

错误信息。
id

string (uuid)

目标的唯一标识符。
inputNodes

NodeReference[]

对目标的输入节点的引用列表。
inputSchemas

InputSchema[]

目标的输入架构。
name

string

目标的唯一名称。
properties

LakehouseDestinationProperties

Lakehouse 目标的属性。
status

NodeStatus

节点的状态。 可能会随着时间的推移添加其他节点状态。
type string:

Lakehouse

目标的类型。

LiteralExpression

Object

表示文本表达式。

名称 类型 说明
dataType

DataType

文本表达式的数据类型。
value

string

文本表达式的值。

ManageFieldsCastOperation

Object

表示管理字段强制转换作。

名称 类型 说明
alias

string

作的别名。
operationType string:

Cast

作类型。
properties

CastProperties

管理字段强制转换作的属性。

ManageFieldsFunctionCallOperation

Object

表示管理字段函数调用作。

名称 类型 说明
alias

string

作的别名。
operationType string:

FunctionCall

作类型。
properties

FunctionCallProperties

管理字段函数调用作的属性。

ManageFieldsOperator

Object

ManageFields 运算符。

名称 类型 说明
inputNodes

NodeReference[]

对运算符输入节点的引用的列表。
inputSchemas

InputSchema[]

运算符的输入架构。
name

string

运算符的名称。
properties

ManageFieldsOperatorProperties

ManageFields 运算符属性。
type string:

ManageFields

运算符的类型。 可能会随着时间的推移添加其他运算符类型。

ManageFieldsOperatorProperties

Object

ManageFields 运算符属性。

名称 类型 说明
columns ManageFieldsOperation[]:

要管理的列的列表。

ManageFieldsRenameOperation

Object

表示管理字段重命名作。

名称 类型 说明
alias

string

作的别名。
operationType string:

Rename

作类型。
properties

RenameProperties

管理字段重命名作的属性。

MySQLCDCSourceResponse

Object

MySQL CDC 源响应。

名称 类型 说明
error

ErrorInfo

错误信息。
id

string (uuid)

源的唯一标识符。
inputSchemas

InputSchema[]

源的输入架构。
name

string

源的唯一名称。
properties
status

NodeStatus

节点的状态。 可能会随着时间的推移添加其他节点状态。
type string:

MySQLCDC

源的类型。

NodeReference

Object

表示使用其唯一名称对节点的引用。

名称 类型 说明
name

string

节点的唯一名称。

NodeStatus

枚举

节点的状态。 可能会随着时间的推移添加其他节点状态。

值 说明
Created

节点已创建。
Creating

正在创建节点。
Deleting

正在删除节点。
External

节点状态取决于外部服务。
Failed

节点已失败。
Paused

节点已暂停。
Pausing

节点正在暂停。
Resuming

正在恢复节点。
Running

节点正在运行。
Unknown

节点的状态未知。
Updating

正在更新节点。
Warning

节点有警告。

OperatorCommonDuration

Object

表示持续时间。

名称 类型 说明
unit enum:
  • Day
  • DayOfYear
  • Hour
  • Microsecond
  • Millisecond
  • Minute
  • Month
  • Quarter
  • Second
  • Week
  • Weekday
  • Year

持续时间的单位。
value

integer

持续时间的值。

PostgreSQLCDCSourceProperties

Object

PostgreSQL CDC 源属性。

名称 类型 默认值 说明
dataConnectionId

string (uuid)

SQL CDC 数据连接标识符。
port

integer

5432

端口号。 默认值为 5432。
slotName

string

CDC 连接器的槽名称。
tableName

string

表名称。

PostgreSQLCDCSourceResponse

Object

PostgreSQL CDC 源响应。

名称 类型 说明
error

ErrorInfo

错误信息。
id

string (uuid)

源的唯一标识符。
inputSchemas

InputSchema[]

源的输入架构。
name

string

源的唯一名称。
properties

PostgreSQLCDCSourceProperties

PostgreSQL CDC 源的属性。
status

NodeStatus

节点的状态。 可能会随着时间的推移添加其他节点状态。
type string:

PostgreSQLCDC

源的类型。

RenameProperties

Object

重命名作的属性。

名称 类型 说明
column

ColumnReferenceExpression

表示对列的引用。

SampleDataSourceProperties

Object

示例数据源属性。

名称 类型 说明
type enum:
  • Bicycles
  • StockMarket
  • YellowTaxi

示例数据类型。

SampleDataSourceResponse

Object

示例数据事件源响应。

名称 类型 说明
error

ErrorInfo

错误信息。
id

string (uuid)

源的唯一标识符。
inputSchemas

InputSchema[]

源的输入架构。
name

string

源的唯一名称。
properties

SampleDataSourceProperties

示例数据事件源的属性。
status

NodeStatus

节点的状态。 可能会随着时间的推移添加其他节点状态。
type string:

SampleData

源的类型。

Schema

Object

表示数据的架构。

名称 类型 说明
columns

ColumnSchema[]

架构中列的列表。

SerializationType

枚举

序列化类型。

值 说明
Avro

序列化类型为 Avro。
Csv

序列化类型为 CSV。
Json

序列化类型为 JSON。

SessionWindow

Object
名称 类型 说明
properties

SessionWindowProperties

会话窗口的属性。
type string:

Session

窗口的类型。

SessionWindowProperties

Object

会话窗口的属性。

名称 类型 说明
maxDuration

OperatorCommonDuration

表示持续时间。
partitionBy

ColumnReferenceExpression

表示对列的引用。
timeout

OperatorCommonDuration

表示持续时间。

SlidingWindow

Object
名称 类型 说明
properties

SlidingWindowProperties

滑动窗口的属性。
type string:

Sliding

窗口的类型。

SlidingWindowProperties

Object

滑动窗口的属性。

名称 类型 说明
duration

OperatorCommonDuration

表示持续时间。

SnapshotWindow

Object
名称 类型 说明
properties

SnapshotWindowProperties

快照窗口的属性。
type string:

Snapshot

窗口的类型。

SnapshotWindowProperties

Object

快照窗口的属性。

SourceType

枚举

表示源的类型。 可能会随着时间的推移添加其他源类型。

值 说明
AmazonKinesis

Amazon Kinesis 源类型。
AmazonMSKKafka

Amazon MSK Kafka 源类型。
ApacheKafka

Apache Kafka 源类型。
AzureBlobStorageEvents

Azure Blob 存储事件源类型。
AzureCosmosDBCDC

Azure Cosmos DB CDC 源类型。
AzureEventHub

Azure 事件中心源类型。
AzureIoTHub

Azure IoT 中心源类型。
AzureSQLDBCDC

Azure SQL DB CDC 源类型。
AzureSQLMIDBCDC

Azure SQL MI DB CDC 源类型。
ConfluentCloud

Confluent Cloud 源类型。
CustomEndpoint

自定义终结点源类型。
FabricCapacityUtilizationEvents

构造容量利用率事件源类型。
FabricJobEvents

Fabric 作业事件源类型。
FabricOneLakeEvents

Fabric One Lake 事件源类型。
FabricWorkspaceItemEvents

Fabric 工作区项事件源类型。
GooglePubSub

Google PubSub 源类型。
MySQLCDC

MySQL CDC 源类型。
PostgreSQLCDC

PostgreSQL CDC 源类型。
SQLServerOnVMDBCDC

VM DB CDC 源类型的 SQL Server。
SampleData

示例数据源类型。

SQLServerOnVMDBCDCSourceResponse

Object

VM DB CDC 源响应上的 Azure SQL Server。

名称 类型 说明
error

ErrorInfo

错误信息。
id

string (uuid)

源的唯一标识符。
inputSchemas

InputSchema[]

源的输入架构。
name

string

源的唯一名称。
properties

BaseSQLCDCSourceProperties

基本 SQL CDC 源属性。
status

NodeStatus

节点的状态。 可能会随着时间的推移添加其他节点状态。
type string:

SQLServerOnVMDBCDC

源的类型。

StreamType

枚举

表示流的类型。 可能会随着时间的推移添加其他流类型。

值 说明
DefaultStream

流是默认流。
DerivedStream

流派生自另一个流。

TumblingWindow

Object
名称 类型 说明
properties

TumblingWindowProperties

翻转窗口的属性。
type string:

Tumbling

窗口的类型。

TumblingWindowProperties

Object

翻转窗口的属性。

名称 类型 说明
duration

OperatorCommonDuration

表示持续时间。
offset

OperatorCommonDuration

表示持续时间。

UnionOperator

Object

Union 运算符。

名称 类型 说明
inputNodes

NodeReference[]

对运算符输入节点的引用的列表。
inputSchemas

InputSchema[]

运算符的输入架构。
name

string

运算符的名称。
properties

UnionOperatorProperties

Union 运算符属性。
type string:

Union

运算符的类型。 可能会随着时间的推移添加其他运算符类型。

UnionOperatorProperties

Object

Union 运算符属性。