你当前正在访问 Microsoft Azure Global Edition 技术文档网站。如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站，请访问 https://docs.azure.cn。

az iot ops dataflow endpoint create

Note

此参考是 Azure CLI（版本 2.67.0 或更高版本）的 azure-iot-ops 扩展的一部分。该扩展将在首次运行 az iot ops dataflow endpoint create 命令时自动安装。了解更多关于扩展的信息。

创建或替换数据流终结点资源。

命令

名称	说明	类型	Status
az iot ops dataflow endpoint create adls	为 Azure Data Lake Storage Gen2 创建或替换数据流终结点资源。	Extension	GA
az iot ops dataflow endpoint create adx	为 Azure 数据资源管理器创建或替换数据流终结点资源。	Extension	GA
az iot ops dataflow endpoint create custom-kafka	为自定义 kafka 中转站创建或替换数据流终结点资源。	Extension	GA
az iot ops dataflow endpoint create custom-mqtt	为自定义 MQTT 代理创建或替换数据流终结点资源。	Extension	GA
az iot ops dataflow endpoint create eventgrid	为 Azure 事件网格创建或替换数据流终结点资源。	Extension	GA
az iot ops dataflow endpoint create eventhub	为已启用 kafka 的 Azure 事件中心命名空间创建或替换数据流终结点资源。	Extension	GA
az iot ops dataflow endpoint create fabric-onelake	为 Microsoft Fabric OneLake 创建或替换数据流终结点资源。	Extension	GA
az iot ops dataflow endpoint create fabric-realtime	创建或替换 Microsoft Fabric Real-Time Intelligence 数据流终结点。	Extension	GA
az iot ops dataflow endpoint create local-mqtt	创建或替换 Azure IoT作本地 MQTT 数据流终结点。	Extension	GA
az iot ops dataflow endpoint create local-storage	创建或替换本地存储数据流终结点。	Extension	GA
az iot ops dataflow endpoint create otel	创建或替换 OpenTelemetry 数据流终结点。	Extension	GA

az iot ops dataflow endpoint create adls

为 Azure Data Lake Storage Gen2 创建或替换数据流终结点资源。

有关 Azure Data Lake Storage Gen2 数据流终结点的详细信息，请参阅 https://aka.ms/adlsv2。注意：使用用户分配的托管标识身份验证方法时，范围将默认为“https://storage.azure.com/.default'”（如果未指定）。--scope

az iot ops dataflow endpoint create adls --instance
                                         --name
                                         --resource-group
                                         --sa --storage-account
                                         [--aud --audience]
                                         [--auth-type {AccessToken, SystemAssignedManagedIdentity, UserAssignedManagedIdentity}]
                                         [--cid --client-id]
                                         [--latency]
                                         [--mc --message-count]
                                         [--scope]
                                         [--secret-name]
                                         [--show-config {false, true}]
                                         [--tenant-id --tid]

示例

使用最小输入创建或替换数据流终结点资源。

az iot ops dataflow endpoint create adls --name myendpoint --instance mycluster-ops-instance --resource-group myresourcegroup --storage-account mystorageaccount

使用用户分配的托管标识身份验证方法创建或替换数据流终结点资源。

az iot ops dataflow endpoint create adls --name myendpoint --instance mycluster-ops-instance --resource-group myresourcegroup --storage-account mystorageaccount --client-id 425cb1e9-1247-4cbc-8cdb-1aac9b429696 --tenant-id bca45660-49a2-4bad-862a-0b9459b4b836 --scope "https://storage.azure.com/.default"

显示用于创建数据流终结点资源的配置。

az iot ops dataflow endpoint create adls --name myendpoint --instance mycluster-ops-instance --resource-group myresourcegroup --storage-account mystorageaccount --latency 70 --message-count 100 --secret-name mysecret --show-config

必需参数

--instance -i

IoT 操作实例名称。

--name -n

数据流终结点名称。

--resource-group -g

资源组的名称。可以使用 az configure --defaults group=<name>配置默认组。

--sa --storage-account

Azure Data Lake Storage Gen2 帐户的名称。

可选参数

以下参数是可选的，但根据上下文，命令可能需要一个或多个参数才能成功执行。

--aud --audience

要对其进行身份验证的服务受众。

属性	值
参数组:	System Assigned Managed Identity Arguments

--auth-type

数据流终结点的身份验证类型。注意：如果未指定，身份验证类型由其他身份验证参数确定。

属性	值
接受的值:	AccessToken, SystemAssignedManagedIdentity, UserAssignedManagedIdentity

--cid --client-id

用户分配标识的客户端 ID。

属性	值
参数组:	User Assigned Managed Identity Arguments

--latency -l

批处理延迟（以毫秒为单位）。最小值：0，最大值：65535。

属性	值
参数组:	Batching Configuration Arguments
默认值:	60

--mc --message-count

批中的最大消息数。最小值：0，最大值：4294967295。

属性	值
参数组:	Batching Configuration Arguments
默认值:	100000

--scope

资源的资源标识符（应用程序 ID URI）带有 .default 后缀。

属性	值
参数组:	User Assigned Managed Identity Arguments

--secret-name -s

包含 SAS 令牌的 kubernetes 机密的名称。

属性	值
参数组:	Access Token Arguments

--show-config

显示生成的资源配置，而不是使用它调用 API。

属性	值
接受的值:	false, true

--tenant-id --tid

用户分配标识的租户 ID。

属性	值
参数组:	User Assigned Managed Identity Arguments

全局参数

--debug

提高日志记录详细程度以显示所有调试日志。

属性	值
默认值:	False

--help -h

显示此帮助消息并退出。

--only-show-errors

只显示错误，取消显示警告。

属性	值
默认值:	False

--output -o

输出格式。

属性	值
默认值:	json
接受的值:	json, jsonc, none, table, tsv, yaml, yamlc

--query

JMESPath 查询字符串。有关更多信息和示例，请参阅 http://jmespath.org/。

--subscription

订阅的名称或 ID。可以使用 az account set -s NAME_OR_ID 配置默认订阅。

--verbose

增加日志记录详细程度。使用 --debug 获取完整的调试日志。

属性	值
默认值:	False

az iot ops dataflow endpoint create adx

为 Azure 数据资源管理器创建或替换数据流终结点资源。

有关 Azure 数据资源管理器数据流终结点的详细信息，请参阅 https://aka.ms/aio-adx。

az iot ops dataflow endpoint create adx --database --db
                                        --host
                                        --instance
                                        --name
                                        --resource-group
                                        [--aud --audience]
                                        [--auth-type {SystemAssignedManagedIdentity, UserAssignedManagedIdentity}]
                                        [--cid --client-id]
                                        [--latency]
                                        [--mc --message-count]
                                        [--scope]
                                        [--show-config {false, true}]
                                        [--tenant-id --tid]

示例

使用最小输入创建或替换数据流终结点资源。

az iot ops dataflow endpoint create adx --name myendpoint --instance mycluster-ops-instance --resource-group myresourcegroup --database mydatabase --host "https://cluster.region.kusto.windows.net"

使用用户分配的托管标识身份验证方法创建或替换数据流终结点资源。

az iot ops dataflow endpoint create adx --name myendpoint --instance mycluster-ops-instance --resource-group myresourcegroup --database mydatabase --host "https://cluster.region.kusto.windows.net" --client-id 425cb1e9-1247-4cbc-8cdb-1aac9b429696 --tenant-id bca45660-49a2-4bad-862a-0b9459b4b836

显示用于创建数据流终结点资源的配置。

az iot ops dataflow endpoint create adx --name myendpoint --instance mycluster-ops-instance --resource-group myresourcegroup --database mydatabase --host "https://cluster.region.kusto.windows.net" --latency 70 --message-count 100 --audience myaudience --show-config

必需参数

--database --db

Azure 数据资源管理器数据库的名称。

--host

Azure 数据资源管理器的主机是 Azure 数据资源管理器群集 URI。以 . 的形式 https://cluster.region.kusto.windows.net。

--instance -i

IoT 操作实例名称。

--name -n

数据流终结点名称。

--resource-group -g

资源组的名称。可以使用 az configure --defaults group=<name>配置默认组。

可选参数

以下参数是可选的，但根据上下文，命令可能需要一个或多个参数才能成功执行。

--aud --audience

要对其进行身份验证的服务受众。

属性	值
参数组:	System Assigned Managed Identity Arguments

--auth-type

数据流终结点的身份验证类型。注意：如果未指定，身份验证类型由其他身份验证参数确定。

属性	值
接受的值:	SystemAssignedManagedIdentity, UserAssignedManagedIdentity

--cid --client-id

用户分配标识的客户端 ID。

属性	值
参数组:	User Assigned Managed Identity Arguments

--latency -l

批处理延迟（以毫秒为单位）。最小值：0，最大值：65535。

属性	值
参数组:	Batching Configuration Arguments
默认值:	60

--mc --message-count

批中的最大消息数。最小值：0，最大值：4294967295。

属性	值
参数组:	Batching Configuration Arguments
默认值:	100000

--scope

资源的资源标识符（应用程序 ID URI）带有 .default 后缀。

属性	值
参数组:	User Assigned Managed Identity Arguments

--show-config

显示生成的资源配置，而不是使用它调用 API。

属性	值
接受的值:	false, true

--tenant-id --tid

用户分配标识的租户 ID。

属性	值
参数组:	User Assigned Managed Identity Arguments

全局参数

--debug

提高日志记录详细程度以显示所有调试日志。

属性	值
默认值:	False

--help -h

显示此帮助消息并退出。

--only-show-errors

只显示错误，取消显示警告。

属性	值
默认值:	False

--output -o

输出格式。

属性	值
默认值:	json
接受的值:	json, jsonc, none, table, tsv, yaml, yamlc

--query

JMESPath 查询字符串。有关更多信息和示例，请参阅 http://jmespath.org/。

--subscription

订阅的名称或 ID。可以使用 az account set -s NAME_OR_ID 配置默认订阅。

--verbose

增加日志记录详细程度。使用 --debug 获取完整的调试日志。

属性	值
默认值:	False

az iot ops dataflow endpoint create custom-kafka

为自定义 kafka 中转站创建或替换数据流终结点资源。

有关自定义 kafka 数据流终结点的详细信息，请参阅 https://aka.ms/aio-custom-kafka。

az iot ops dataflow endpoint create custom-kafka --hostname
                                                 --instance
                                                 --name
                                                 --port
                                                 --resource-group
                                                 [--acks {All, One, Zero}]
                                                 [--aud --audience]
                                                 [--auth-type {Sasl, SystemAssignedManagedIdentity, UserAssignedManagedIdentity}]
                                                 [--cea --cloud-event-attribute {CreateOrRemap, Propagate}]
                                                 [--cid --client-id]
                                                 [--cm --config-map-ref]
                                                 [--compression {Gzip, Lz4, None, Snappy}]
                                                 [--db --disable-batching {false, true}]
                                                 [--dbpc --disable-broker-props-copy {false, true}]
                                                 [--disable-tls {false, true}]
                                                 [--gid --group-id]
                                                 [--latency]
                                                 [--max-bytes --mb]
                                                 [--mc --message-count]
                                                 [--no-auth {false, true}]
                                                 [--partition-strategy --ps {Default, Property, Static, Topic}]
                                                 [--sasl-type {Plain, ScramSha256, ScramSha512}]
                                                 [--scope]
                                                 [--secret-name]
                                                 [--show-config {false, true}]
                                                 [--tenant-id --tid]

示例

使用最小输入创建或替换数据流终结点资源。

az iot ops dataflow endpoint create custom-kafka --name myendpoint --instance mycluster-ops-instance --resource-group myresourcegroup --hostname mykafkabroker --port 9092

使用 SASL 身份验证方法创建或替换数据流终结点资源。

az iot ops dataflow endpoint create custom-kafka --name myendpoint --instance mycluster-ops-instance --resource-group myresourcegroup --hostname mykafkabroker --port 9092 --sasl-type ScramSha256 --secret-name mysecret

创建或替换没有身份验证的数据流终结点资源。

az iot ops dataflow endpoint create custom-kafka --name myendpoint --instance mycluster-ops-instance --resource-group myresourcegroup --hostname mykafkabroker --port 9092 --no-auth

显示用于创建数据流终结点资源的配置。

az iot ops dataflow endpoint create custom-kafka --name myendpoint --instance mycluster-ops-instance --resource-group myresourcegroup --hostname mykafkabroker --port 9092 --disable-batching --latency 70 --max-bytes 200000 --message-count 100 --audience myaudience --config-map-ref myconfigmap --disable-tls --show-config

必需参数

--hostname

Kafka 中转站主机设置的主机名。

--instance -i

IoT 操作实例名称。

--name -n

数据流终结点名称。

--port

Kafka 中转站主机设置的端口号。

--resource-group -g

资源组的名称。可以使用 az configure --defaults group=<name>配置默认组。

可选参数

以下参数是可选的，但根据上下文，命令可能需要一个或多个参数才能成功执行。

--acks

Kafka 中转站的确认级别，以确保生成者发送的消息已成功写入主题，并在 Kafka 群集中复制。

属性	值
默认值:	All
接受的值:	All, One, Zero

--aud --audience

要对其进行身份验证的服务受众。

属性	值
参数组:	System Assigned Managed Identity Arguments

--auth-type

数据流终结点的身份验证类型。注意：如果未指定，身份验证类型由其他身份验证参数确定。

属性	值
接受的值:	Sasl, SystemAssignedManagedIdentity, UserAssignedManagedIdentity

--cea --cloud-event-attribute

CloudEvent 设置类型，用于将事件映射到云。不同的设置需要不同的消息格式。

属性	值
参数组:	Cloud Event Arguments
默认值:	Propagate
接受的值:	CreateOrRemap, Propagate

--cid --client-id

用户分配标识的客户端 ID。

属性	值
参数组:	User Assigned Managed Identity Arguments

--cm --config-map-ref

Kafka/MQTT 终结点的受信任 CA 证书的配置映射参考。注意：此 ConfigMap 应包含 PEM 格式的 CA 证书。 ConfigMap 必须与 Kafka/MQTT 数据流资源位于同一命名空间中。

属性	值
参数组:	Transport Layer Security (TLS) Arguments

--compression

发送到 Kafka 主题的消息的压缩类型。

属性	值
默认值:	None
接受的值:	Gzip, Lz4, None, Snappy

--db --disable-batching

禁用批处理。

属性	值
参数组:	Batching Configuration Arguments
默认值:	False
接受的值:	false, true

--dbpc --disable-broker-props-copy

禁用 MQTT 代理属性复制到 Kafka 用户标头。

属性	值
默认值:	False
接受的值:	false, true

--disable-tls

数据流使用与 Kafka/MQTT 中转站的不安全连接。

属性	值
参数组:	Transport Layer Security (TLS) Arguments
默认值:	False
接受的值:	false, true

--gid --group-id

数据流用于从 Kafka 主题读取消息的使用者组的 ID。

--latency -l

批处理延迟（以毫秒为单位）。最小值：0，最大值：65535。

属性	值
参数组:	Batching Configuration Arguments
默认值:	5

--max-bytes --mb

批中的最大字节数。

属性	值
参数组:	Batching Configuration Arguments
默认值:	1000000

--mc --message-count

批中的最大消息数。最小值：0，最大值：4294967295。

属性	值
参数组:	Batching Configuration Arguments
默认值:	100000

--no-auth

没有终结点的身份验证。

属性	值
默认值:	False
接受的值:	false, true

--partition-strategy --ps

分区处理策略可控制在将消息发送到 Kafka 主题时如何将其分配给 Kafka 分区。

属性	值
默认值:	Default
接受的值:	Default, Property, Static, Topic

--sasl-type

SASL 身份验证的类型。

属性	值
参数组:	SASL Authentication Arguments
接受的值:	Plain, ScramSha256, ScramSha512

--scope

资源的资源标识符（应用程序 ID URI）带有 .default 后缀。

属性	值
参数组:	User Assigned Managed Identity Arguments

--secret-name -s

包含 SASL 令牌的 Kubernetes 机密的名称。

属性	值
参数组:	SASL Authentication Arguments

--show-config

显示生成的资源配置，而不是使用它调用 API。

属性	值
接受的值:	false, true

--tenant-id --tid

用户分配标识的租户 ID。

属性	值
参数组:	User Assigned Managed Identity Arguments

全局参数

--debug

提高日志记录详细程度以显示所有调试日志。

属性	值
默认值:	False

--help -h

显示此帮助消息并退出。

--only-show-errors

只显示错误，取消显示警告。

属性	值
默认值:	False

--output -o

输出格式。

属性	值
默认值:	json
接受的值:	json, jsonc, none, table, tsv, yaml, yamlc

--query

JMESPath 查询字符串。有关更多信息和示例，请参阅 http://jmespath.org/。

--subscription

订阅的名称或 ID。可以使用 az account set -s NAME_OR_ID 配置默认订阅。

--verbose

增加日志记录详细程度。使用 --debug 获取完整的调试日志。

属性	值
默认值:	False

az iot ops dataflow endpoint create custom-mqtt

为自定义 MQTT 代理创建或替换数据流终结点资源。

有关自定义 MQTT 数据流终结点的详细信息，请参阅 https://aka.ms/aio-custom-mqtt。

az iot ops dataflow endpoint create custom-mqtt --hostname
                                                --instance
                                                --name
                                                --port
                                                --resource-group
                                                [--auth-type {ServiceAccountToken, SystemAssignedManagedIdentity, UserAssignedManagedIdentity, X509Certificate}]
                                                [--cea --cloud-event-attribute {CreateOrRemap, Propagate}]
                                                [--cid --client-id]
                                                [--client-id-prefix]
                                                [--cm --config-map-ref]
                                                [--disable-tls {false, true}]
                                                [--ka --keep-alive]
                                                [--max-inflight-msg --mim]
                                                [--no-auth {false, true}]
                                                [--protocol {Mqtt, WebSockets}]
                                                [--qos]
                                                [--retain {Keep, Never}]
                                                [--sami-aud --sami-audience]
                                                [--sat-aud --sat-audience]
                                                [--scope]
                                                [--secret-name]
                                                [--session-expiry]
                                                [--show-config {false, true}]
                                                [--tenant-id --tid]

示例

使用最小输入创建或替换数据流终结点资源。

az iot ops dataflow endpoint create custom-mqtt --name myendpoint --instance mycluster-ops-instance --resource-group myresourcegroup --hostname mymqttbroker --port 9092

使用 Kubernetes 服务帐户令牌身份验证方法创建或替换数据流终结点资源。

az iot ops dataflow endpoint create custom-mqtt --name myendpoint --instance mycluster-ops-instance --resource-group myresourcegroup --hostname mymqttbroker --port 9092 --sat-audience myaudience --secret-name mysecret

创建或替换没有身份验证的数据流终结点资源。

az iot ops dataflow endpoint create custom-mqtt --name myendpoint --instance mycluster-ops-instance --resource-group myresourcegroup --hostname mymqttbroker --port 9092 --no-auth

显示用于创建数据流终结点资源的配置。

az iot ops dataflow endpoint create custom-mqtt --name myendpoint --instance mycluster-ops-instance --resource-group myresourcegroup --hostname mymqttbroker --port 9092 --client-id-prefix myclientprefix --keep-alive 100 --max-inflight-msg 60 --protocol WebSockets --qos 1 --retain Never --session-expiry 100 --cloud-event-attribute CreateOrRemap --secret-name mysecret --disable-tls --show-config

必需参数

--hostname

自定义 MQTT 代理主机设置的主机名。

--instance -i

IoT 操作实例名称。

--name -n

数据流终结点名称。

--port

自定义 MQTT 代理主机设置的端口号。

--resource-group -g

资源组的名称。可以使用 az configure --defaults group=<name>配置默认组。

可选参数

以下参数是可选的，但根据上下文，命令可能需要一个或多个参数才能成功执行。

--auth-type

数据流终结点的身份验证类型。注意：如果未指定，身份验证类型由其他身份验证参数确定。

属性	值
接受的值:	ServiceAccountToken, SystemAssignedManagedIdentity, UserAssignedManagedIdentity, X509Certificate

--cea --cloud-event-attribute

CloudEvent 设置类型，用于将事件映射到云。不同的设置需要不同的消息格式。

属性	值
参数组:	Cloud Event Arguments
默认值:	Propagate
接受的值:	CreateOrRemap, Propagate

--cid --client-id

用户分配标识的客户端 ID。

属性	值
参数组:	User Assigned Managed Identity Arguments

--client-id-prefix

MQTT 客户端的客户端 ID 前缀。注意：在 IoT作部署后更改客户端 ID 前缀可能会导致数据丢失。

--cm --config-map-ref

属性	值
参数组:	Transport Layer Security (TLS) Arguments

--disable-tls

数据流使用与 Kafka/MQTT 中转站的不安全连接。

属性	值
参数组:	Transport Layer Security (TLS) Arguments
默认值:	False
接受的值:	false, true

--ka --keep-alive

将 PINGREQ 消息发送到中转站之前，数据流客户端可以处于空闲状态的最长时间（以秒为单位）。最小值：0。

属性	值
默认值:	60

--max-inflight-msg --mim

数据流 MQTT 客户端可以拥有的最大飞行消息数。最小值：0。

属性	值
默认值:	100

--no-auth

没有终结点的身份验证。

属性	值
默认值:	False
接受的值:	false, true

--protocol

用于客户端连接的协议。

属性	值
默认值:	Mqtt
接受的值:	Mqtt, WebSockets

--qos

MQTT 消息的服务质量（QoS）级别。仅支持 0 或 1。

属性	值
默认值:	1

--retain

保留设置以指定数据流是否应保留 MQTT 消息上的保留标志。设置此项可确保远程代理是否保留与本地中转站相同的消息。

属性	值
默认值:	Keep
接受的值:	Keep, Never

--sami-aud --sami-audience

系统分配的托管标识的受众。

属性	值
参数组:	System Assigned Managed Identity Arguments

--sat-aud --sat-audience

Kubernetes 服务帐户令牌（SAT）的受众。

属性	值
参数组:	Kubernetes Service Account Token Arguments

--scope

资源的资源标识符（应用程序 ID URI）带有 .default 后缀。

属性	值
参数组:	User Assigned Managed Identity Arguments

--secret-name -s

Kubernetes 机密的名称，其中包含 X509 客户端证书、对应于客户端证书的私钥，以及客户端证书链的中间证书。注意：证书和私钥必须采用 PEM 格式，且不受密码保护。

属性	值
参数组:	X509 Authentication Arguments

--session-expiry

数据流 MQTT 客户端的会话到期间隔（以秒为单位）。最小值：0。

属性	值
默认值:	3600

--show-config

显示生成的资源配置，而不是使用它调用 API。

属性	值
接受的值:	false, true

--tenant-id --tid

用户分配标识的租户 ID。

属性	值
参数组:	User Assigned Managed Identity Arguments

全局参数

--debug

提高日志记录详细程度以显示所有调试日志。

属性	值
默认值:	False

--help -h

显示此帮助消息并退出。

--only-show-errors

只显示错误，取消显示警告。

属性	值
默认值:	False

--output -o

输出格式。

属性	值
默认值:	json
接受的值:	json, jsonc, none, table, tsv, yaml, yamlc

--query

JMESPath 查询字符串。有关更多信息和示例，请参阅 http://jmespath.org/。

--subscription

订阅的名称或 ID。可以使用 az account set -s NAME_OR_ID 配置默认订阅。

--verbose

增加日志记录详细程度。使用 --debug 获取完整的调试日志。

属性	值
默认值:	False

az iot ops dataflow endpoint create eventgrid

为 Azure 事件网格创建或替换数据流终结点资源。

有关 Azure 事件网格数据流终结点的详细信息，请参阅 https://aka.ms/aio-eventgrid。

az iot ops dataflow endpoint create eventgrid --hostname
                                              --instance
                                              --name
                                              --resource-group
                                              [--aud --audience]
                                              [--auth-type {SystemAssignedManagedIdentity, UserAssignedManagedIdentity, X509Certificate}]
                                              [--cea --cloud-event-attribute {CreateOrRemap, Propagate}]
                                              [--cid --client-id]
                                              [--client-id-prefix]
                                              [--cm --config-map-ref]
                                              [--ka --keep-alive]
                                              [--max-inflight-msg --mim]
                                              [--port]
                                              [--protocol {Mqtt, WebSockets}]
                                              [--qos]
                                              [--retain {Keep, Never}]
                                              [--scope]
                                              [--secret-name]
                                              [--session-expiry]
                                              [--show-config {false, true}]
                                              [--tenant-id --tid]

示例

使用最小输入创建或替换数据流终结点资源。

az iot ops dataflow endpoint create eventgrid --name myendpoint --instance mycluster-ops-instance --resource-group myresourcegroup --hostname "namespace.region-1.ts.eventgrid.azure.net" --port 9092

使用 X509 身份验证方法创建或替换数据流终结点资源。

az iot ops dataflow endpoint create eventgrid --name myendpoint --instance mycluster-ops-instance --resource-group myresourcegroup --hostname "namespace.region-1.ts.eventgrid.azure.net" --port 9092 --secret-name mysecret

显示用于创建数据流终结点资源的配置。

az iot ops dataflow endpoint create eventgrid --name myendpoint --instance mycluster-ops-instance --resource-group myresourcegroup --hostname "namespace.region-1.ts.eventgrid.azure.net" --port 9092 --client-id-prefix myclientprefix --keep-alive 100 --max-inflight-msg 60 --protocol WebSockets --qos 1 --retain Never --session-expiry 100 --cloud-event-attribute CreateOrRemap --secret-name mysecret --config-map-ref myconfigmap --show-config

必需参数

--hostname

事件网格命名空间的主机名。可以在“Http 主机名”属性中找到。以 NAMESPACE.REGION-1.ts.eventgrid.azure.net 的形式。

--instance -i

IoT 操作实例名称。

--name -n

数据流终结点名称。

--resource-group -g

资源组的名称。可以使用 az configure --defaults group=<name>配置默认组。

可选参数

以下参数是可选的，但根据上下文，命令可能需要一个或多个参数才能成功执行。

--aud --audience

要对其进行身份验证的服务受众。

属性	值
参数组:	System Assigned Managed Identity Arguments

--auth-type

数据流终结点的身份验证类型。注意：如果未指定，身份验证类型由其他身份验证参数确定。

属性	值
接受的值:	SystemAssignedManagedIdentity, UserAssignedManagedIdentity, X509Certificate

--cea --cloud-event-attribute

CloudEvent 设置类型，用于将事件映射到云。不同的设置需要不同的消息格式。

属性	值
参数组:	Cloud Event Arguments
默认值:	Propagate
接受的值:	CreateOrRemap, Propagate

--cid --client-id

用户分配标识的客户端 ID。

属性	值
参数组:	User Assigned Managed Identity Arguments

--client-id-prefix

MQTT 客户端的客户端 ID 前缀。注意：在 IoT作部署后更改客户端 ID 前缀可能会导致数据丢失。

--cm --config-map-ref

属性	值
参数组:	Transport Layer Security (TLS) Arguments

--ka --keep-alive

将 PINGREQ 消息发送到中转站之前，数据流客户端可以处于空闲状态的最长时间（以秒为单位）。最小值：0。

属性	值
默认值:	60

--max-inflight-msg --mim

数据流 MQTT 客户端可以拥有的最大飞行消息数。最小值：0。

属性	值
默认值:	100

--port

事件网格命名空间的端口号。

属性	值
默认值:	8883

--protocol

用于客户端连接的协议。

属性	值
默认值:	Mqtt
接受的值:	Mqtt, WebSockets

--qos

MQTT 消息的服务质量（QoS）级别。仅支持 0 或 1。

属性	值
默认值:	1

--retain

保留设置以指定数据流是否应保留 MQTT 消息上的保留标志。设置此项可确保远程代理是否保留与本地中转站相同的消息。

属性	值
默认值:	Keep
接受的值:	Keep, Never

--scope

资源的资源标识符（应用程序 ID URI）带有 .default 后缀。

属性	值
参数组:	User Assigned Managed Identity Arguments

--secret-name -s

属性	值
参数组:	X509 Authentication Arguments

--session-expiry

数据流 MQTT 客户端的会话到期间隔（以秒为单位）。最小值：0。

属性	值
默认值:	3600

--show-config

显示生成的资源配置，而不是使用它调用 API。

属性	值
接受的值:	false, true

--tenant-id --tid

用户分配标识的租户 ID。

属性	值
参数组:	User Assigned Managed Identity Arguments

全局参数

--debug

提高日志记录详细程度以显示所有调试日志。

属性	值
默认值:	False

--help -h

显示此帮助消息并退出。

--only-show-errors

只显示错误，取消显示警告。

属性	值
默认值:	False

--output -o

输出格式。

属性	值
默认值:	json
接受的值:	json, jsonc, none, table, tsv, yaml, yamlc

--query

JMESPath 查询字符串。有关更多信息和示例，请参阅 http://jmespath.org/。

--subscription

订阅的名称或 ID。可以使用 az account set -s NAME_OR_ID 配置默认订阅。

--verbose

增加日志记录详细程度。使用 --debug 获取完整的调试日志。

属性	值
默认值:	False

az iot ops dataflow endpoint create eventhub

为已启用 kafka 的 Azure 事件中心命名空间创建或替换数据流终结点资源。

有关 Azure 事件中心数据流终结点的详细信息，请参阅 https://aka.ms/aio-eventhub。

az iot ops dataflow endpoint create eventhub --ehns --eventhub-namespace
                                             --instance
                                             --name
                                             --resource-group
                                             [--acks {All, One, Zero}]
                                             [--aud --audience]
                                             [--auth-type {Sasl, SystemAssignedManagedIdentity, UserAssignedManagedIdentity}]
                                             [--cea --cloud-event-attribute {CreateOrRemap, Propagate}]
                                             [--cid --client-id]
                                             [--cm --config-map-ref]
                                             [--compression {Gzip, Lz4, None, Snappy}]
                                             [--db --disable-batching {false, true}]
                                             [--dbpc --disable-broker-props-copy {false, true}]
                                             [--gid --group-id]
                                             [--latency]
                                             [--max-bytes --mb]
                                             [--mc --message-count]
                                             [--partition-strategy --ps {Default, Property, Static, Topic}]
                                             [--sasl-type {Plain, ScramSha256, ScramSha512}]
                                             [--scope]
                                             [--secret-name]
                                             [--show-config {false, true}]
                                             [--tenant-id --tid]

示例

使用最小输入创建或替换数据流终结点资源。

az iot ops dataflow endpoint create eventhub --name myendpoint --instance mycluster-ops-instance --resource-group myresourcegroup --eventhub-namespace myeventhubnamespace

使用用户分配的托管标识身份验证方法创建或替换数据流终结点资源。

az iot ops dataflow endpoint create eventhub --name myendpoint --instance mycluster-ops-instance --resource-group myresourcegroup --eventhub-namespace myeventhubnamespace --client-id 425cb1e9-1247-4cbc-8cdb-1aac9b429696 --tenant-id bca45660-49a2-4bad-862a-0b9459b4b836 --scope "https://eventhubs.azure.net/.default"

显示用于创建数据流终结点资源的配置。

az iot ops dataflow endpoint create eventhub --name myendpoint --instance mycluster-ops-instance --resource-group myresourcegroup --eventhub-namespace myeventhubnamespace --acks One --compression Gzip --disable-broker-props-copy --group-id mygroupid --partition-strategy Static --max-bytes 200000 --message-count 100 --latency 70 --cloud-event-attribute CreateOrRemap --sasl-type ScramSha256 --secret-name mysecret --config-map-ref myconfigmap --show-config

必需参数

--ehns --eventhub-namespace

事件中心命名空间的名称。

--instance -i

IoT 操作实例名称。

--name -n

数据流终结点名称。

--resource-group -g

资源组的名称。可以使用 az configure --defaults group=<name>配置默认组。

可选参数

以下参数是可选的，但根据上下文，命令可能需要一个或多个参数才能成功执行。

--acks

Kafka 中转站的确认级别，以确保生成者发送的消息已成功写入主题，并在 Kafka 群集中复制。

属性	值
默认值:	All
接受的值:	All, One, Zero

--aud --audience

要对其进行身份验证的服务受众。

属性	值
参数组:	System Assigned Managed Identity Arguments

--auth-type

数据流终结点的身份验证类型。注意：如果未指定，身份验证类型由其他身份验证参数确定。

属性	值
接受的值:	Sasl, SystemAssignedManagedIdentity, UserAssignedManagedIdentity

--cea --cloud-event-attribute

CloudEvent 设置类型，用于将事件映射到云。不同的设置需要不同的消息格式。

属性	值
参数组:	Cloud Event Arguments
默认值:	Propagate
接受的值:	CreateOrRemap, Propagate

--cid --client-id

用户分配标识的客户端 ID。

属性	值
参数组:	User Assigned Managed Identity Arguments

--cm --config-map-ref

属性	值
参数组:	Transport Layer Security (TLS) Arguments

--compression

发送到 Kafka 主题的消息的压缩类型。

属性	值
默认值:	None
接受的值:	Gzip, Lz4, None, Snappy

--db --disable-batching

禁用批处理。

属性	值
参数组:	Batching Configuration Arguments
默认值:	False
接受的值:	false, true

--dbpc --disable-broker-props-copy

禁用 MQTT 代理属性复制到 Kafka 用户标头。

属性	值
默认值:	False
接受的值:	false, true

--gid --group-id

数据流用于从 Kafka 主题读取消息的使用者组的 ID。

--latency -l

批处理延迟（以毫秒为单位）。最小值：0，最大值：65535。

属性	值
参数组:	Batching Configuration Arguments
默认值:	5

--max-bytes --mb

批中的最大字节数。

属性	值
参数组:	Batching Configuration Arguments
默认值:	1000000

--mc --message-count

批中的最大消息数。最小值：0，最大值：4294967295。

属性	值
参数组:	Batching Configuration Arguments
默认值:	100000

--partition-strategy --ps

分区处理策略可控制在将消息发送到 Kafka 主题时如何将其分配给 Kafka 分区。

属性	值
默认值:	Default
接受的值:	Default, Property, Static, Topic

--sasl-type

SASL 身份验证的类型。

属性	值
参数组:	SASL Authentication Arguments
接受的值:	Plain, ScramSha256, ScramSha512

--scope

资源的资源标识符（应用程序 ID URI）带有 .default 后缀。

属性	值
参数组:	User Assigned Managed Identity Arguments

--secret-name -s

包含事件中心连接字符串的 kubernetes 机密的名称。注意：机密必须与 Kafka 数据流终结点位于同一命名空间中。机密必须同时拥有用户名和密码作为密钥值对。有关机密格式的详细信息，请参阅命令说明中的链接。

属性	值
参数组:	SASL Authentication Arguments

--show-config

显示生成的资源配置，而不是使用它调用 API。

属性	值
接受的值:	false, true

--tenant-id --tid

用户分配标识的租户 ID。

属性	值
参数组:	User Assigned Managed Identity Arguments

全局参数

--debug

提高日志记录详细程度以显示所有调试日志。

属性	值
默认值:	False

--help -h

显示此帮助消息并退出。

--only-show-errors

只显示错误，取消显示警告。

属性	值
默认值:	False

--output -o

输出格式。

属性	值
默认值:	json
接受的值:	json, jsonc, none, table, tsv, yaml, yamlc

--query

JMESPath 查询字符串。有关更多信息和示例，请参阅 http://jmespath.org/。

--subscription

订阅的名称或 ID。可以使用 az account set -s NAME_OR_ID 配置默认订阅。

--verbose

增加日志记录详细程度。使用 --debug 获取完整的调试日志。

属性	值
默认值:	False

az iot ops dataflow endpoint create fabric-onelake

为 Microsoft Fabric OneLake 创建或替换数据流终结点资源。

有关 Microsoft Fabric OneLake 数据流终结点的详细信息，请参阅 https://aka.ms/fabric-onelake。

az iot ops dataflow endpoint create fabric-onelake --instance
                                                   --lakehouse
                                                   --name
                                                   --path-type --pt {Files, Tables}
                                                   --resource-group
                                                   --workspace
                                                   [--aud --audience]
                                                   [--auth-type {SystemAssignedManagedIdentity, UserAssignedManagedIdentity}]
                                                   [--cid --client-id]
                                                   [--latency]
                                                   [--mc --message-count]
                                                   [--scope]
                                                   [--show-config {false, true}]
                                                   [--tenant-id --tid]

示例

使用最小输入创建或替换数据流终结点资源。

az iot ops dataflow endpoint create fabric-onelake --name myendpoint --instance mycluster-ops-instance --resource-group myresourcegroup --lakehouse mylakehouse --workspace myworkspace --path-type Files

使用用户分配的托管标识身份验证方法创建或替换数据流终结点资源。

az iot ops dataflow endpoint create fabric-onelake --name myendpoint --instance mycluster-ops-instance --resource-group myresourcegroup --lakehouse mylakehouse --workspace myworkspace --path-type Files --client-id 425cb1e9-1247-4cbc-8cdb-1aac9b429696 --tenant-id bca45660-49a2-4bad-862a-0b9459b4b836

显示用于创建数据流终结点资源的配置。

az iot ops dataflow endpoint create fabric-onelake --name myendpoint --instance mycluster-ops-instance --resource-group myresourcegroup --lakehouse mylakehouse --workspace myworkspace --path-type Files --latency 70 --message-count 100 --audience myaudience --show-config

必需参数

--instance -i

IoT 操作实例名称。

--lakehouse

提供的工作区下Microsoft Fabric lakehouse 名称。

--name -n

数据流终结点名称。

--path-type --pt

OneLake 中使用的路径类型。

属性	值
接受的值:	Files, Tables

--resource-group -g

资源组的名称。可以使用 az configure --defaults group=<name>配置默认组。

--workspace

Microsoft Fabric 工作区名称。注意：不支持默认的“我的工作区”。

可选参数

以下参数是可选的，但根据上下文，命令可能需要一个或多个参数才能成功执行。

--aud --audience

要对其进行身份验证的服务受众。

属性	值
参数组:	System Assigned Managed Identity Arguments

--auth-type

数据流终结点的身份验证类型。注意：如果未指定，身份验证类型由其他身份验证参数确定。

属性	值
接受的值:	SystemAssignedManagedIdentity, UserAssignedManagedIdentity

--cid --client-id

用户分配标识的客户端 ID。

属性	值
参数组:	User Assigned Managed Identity Arguments

--latency -l

批处理延迟（以毫秒为单位）。最小值：0，最大值：65535。

属性	值
参数组:	Batching Configuration Arguments
默认值:	60

--mc --message-count

批中的最大消息数。最小值：0，最大值：4294967295。

属性	值
参数组:	Batching Configuration Arguments
默认值:	100000

--scope

资源的资源标识符（应用程序 ID URI）带有 .default 后缀。

属性	值
参数组:	User Assigned Managed Identity Arguments

--show-config

显示生成的资源配置，而不是使用它调用 API。

属性	值
接受的值:	false, true

--tenant-id --tid

用户分配标识的租户 ID。

属性	值
参数组:	User Assigned Managed Identity Arguments

全局参数

--debug

提高日志记录详细程度以显示所有调试日志。

属性	值
默认值:	False

--help -h

显示此帮助消息并退出。

--only-show-errors

只显示错误，取消显示警告。

属性	值
默认值:	False

--output -o

输出格式。

属性	值
默认值:	json
接受的值:	json, jsonc, none, table, tsv, yaml, yamlc

--query

JMESPath 查询字符串。有关更多信息和示例，请参阅 http://jmespath.org/。

--subscription

订阅的名称或 ID。可以使用 az account set -s NAME_OR_ID 配置默认订阅。

--verbose

增加日志记录详细程度。使用 --debug 获取完整的调试日志。

属性	值
默认值:	False

az iot ops dataflow endpoint create fabric-realtime

创建或替换 Microsoft Fabric Real-Time Intelligence 数据流终结点。

有关 Microsoft Fabric Real-Time Intelligence 数据流终结点的详细信息，请参阅 https://aka.ms/aio-fabric-real-time。

az iot ops dataflow endpoint create fabric-realtime --host
                                                    --instance
                                                    --name
                                                    --resource-group
                                                    [--acks {All, One, Zero}]
                                                    [--aud --audience]
                                                    [--auth-type {Sasl, SystemAssignedManagedIdentity, UserAssignedManagedIdentity}]
                                                    [--cea --cloud-event-attribute {CreateOrRemap, Propagate}]
                                                    [--cid --client-id]
                                                    [--cm --config-map-ref]
                                                    [--compression {Gzip, Lz4, None, Snappy}]
                                                    [--db --disable-batching {false, true}]
                                                    [--dbpc --disable-broker-props-copy {false, true}]
                                                    [--disable-tls {false, true}]
                                                    [--gid --group-id]
                                                    [--latency]
                                                    [--max-bytes --mb]
                                                    [--mc --message-count]
                                                    [--partition-strategy --ps {Default, Property, Static, Topic}]
                                                    [--sasl-type {Plain, ScramSha256, ScramSha512}]
                                                    [--scope]
                                                    [--secret-name]
                                                    [--show-config {false, true}]
                                                    [--tenant-id --tid]

示例

使用最小输入创建或替换数据流终结点资源。

az iot ops dataflow endpoint create fabric-realtime --name myendpoint --instance mycluster-ops-instance --resource-group myresourcegroup --host "fabricrealtime.servicebus.windows.net:9093"

使用 SASL 身份验证方法创建或替换数据流终结点资源。

az iot ops dataflow endpoint create fabric-realtime --name myendpoint --instance mycluster-ops-instance --resource-group myresourcegroup --host "fabricrealtime.servicebus.windows.net:9093" --sasl-type ScramSha256 --secret-name mysecret

显示用于创建数据流终结点资源的配置。

az iot ops dataflow endpoint create fabric-realtime --name myendpoint --instance mycluster-ops-instance --resource-group myresourcegroup --host "fabricrealtime.servicebus.windows.net:9093" --acks One --compression Gzip --group-id mygroupid --partition-strategy Static --max-bytes 200000 --cloud-event-attribute CreateOrRemap --disable-tls --show-config

必需参数

--host

Fabric 实时主机是“Bootstrap 服务器”值。可以在事件流目标 -- “SAS 密钥身份验证”部分找到。以 *.servicebus.windows.net:9093 的形式。

--instance -i

IoT 操作实例名称。

--name -n

数据流终结点名称。

--resource-group -g

资源组的名称。可以使用 az configure --defaults group=<name>配置默认组。

可选参数

以下参数是可选的，但根据上下文，命令可能需要一个或多个参数才能成功执行。

--acks

Kafka 中转站的确认级别，以确保生成者发送的消息已成功写入主题，并在 Kafka 群集中复制。

属性	值
默认值:	All
接受的值:	All, One, Zero

--aud --audience

要对其进行身份验证的服务受众。

属性	值
参数组:	System Assigned Managed Identity Arguments

--auth-type

数据流终结点的身份验证类型。注意：如果未指定，身份验证类型由其他身份验证参数确定。

属性	值
接受的值:	Sasl, SystemAssignedManagedIdentity, UserAssignedManagedIdentity

--cea --cloud-event-attribute

CloudEvent 设置类型，用于将事件映射到云。不同的设置需要不同的消息格式。

属性	值
参数组:	Cloud Event Arguments
默认值:	Propagate
接受的值:	CreateOrRemap, Propagate

--cid --client-id

用户分配标识的客户端 ID。

属性	值
参数组:	User Assigned Managed Identity Arguments

--cm --config-map-ref

属性	值
参数组:	Transport Layer Security (TLS) Arguments

--compression

发送到 Kafka 主题的消息的压缩类型。

属性	值
默认值:	None
接受的值:	Gzip, Lz4, None, Snappy

--db --disable-batching

禁用批处理。

属性	值
参数组:	Batching Configuration Arguments
默认值:	False
接受的值:	false, true

--dbpc --disable-broker-props-copy

禁用 MQTT 代理属性复制到 Kafka 用户标头。

属性	值
默认值:	False
接受的值:	false, true

--disable-tls

数据流使用与 Kafka/MQTT 中转站的不安全连接。

属性	值
参数组:	Transport Layer Security (TLS) Arguments
默认值:	False
接受的值:	false, true

--gid --group-id

数据流用于从 Kafka 主题读取消息的使用者组的 ID。

--latency -l

批处理延迟（以毫秒为单位）。最小值：0，最大值：65535。

属性	值
参数组:	Batching Configuration Arguments
默认值:	5

--max-bytes --mb

批中的最大字节数。

属性	值
参数组:	Batching Configuration Arguments
默认值:	1000000

--mc --message-count

批中的最大消息数。最小值：0，最大值：4294967295。

属性	值
参数组:	Batching Configuration Arguments
默认值:	100000

--partition-strategy --ps

分区处理策略可控制在将消息发送到 Kafka 主题时如何将其分配给 Kafka 分区。

属性	值
默认值:	Default
接受的值:	Default, Property, Static, Topic

--sasl-type

SASL 身份验证的类型。

属性	值
参数组:	SASL Authentication Arguments
接受的值:	Plain, ScramSha256, ScramSha512

--scope

资源的资源标识符（应用程序 ID URI）带有 .default 后缀。

属性	值
参数组:	User Assigned Managed Identity Arguments

--secret-name -s

包含连接字符串-主键值的 kubernetes 机密的名称。可以在事件流目标 -- “SAS 密钥身份验证”部分找到。注意：机密必须与 Kafka 数据流终结点位于同一命名空间中。有关机密格式的详细信息，请参阅命令说明中的链接。

属性	值
参数组:	SASL Authentication Arguments

--show-config

显示生成的资源配置，而不是使用它调用 API。

属性	值
接受的值:	false, true

--tenant-id --tid

用户分配标识的租户 ID。

属性	值
参数组:	User Assigned Managed Identity Arguments

全局参数

--debug

提高日志记录详细程度以显示所有调试日志。

属性	值
默认值:	False

--help -h

显示此帮助消息并退出。

--only-show-errors

只显示错误，取消显示警告。

属性	值
默认值:	False

--output -o

输出格式。

属性	值
默认值:	json
接受的值:	json, jsonc, none, table, tsv, yaml, yamlc

--query

JMESPath 查询字符串。有关更多信息和示例，请参阅 http://jmespath.org/。

--subscription

订阅的名称或 ID。可以使用 az account set -s NAME_OR_ID 配置默认订阅。

--verbose

增加日志记录详细程度。使用 --debug 获取完整的调试日志。

属性	值
默认值:	False

az iot ops dataflow endpoint create local-mqtt

创建或替换 Azure IoT作本地 MQTT 数据流终结点。

有关 Azure IoT作本地 MQTT 数据流终结点的详细信息，请参阅 https://aka.ms/local-mqtt-broker。

az iot ops dataflow endpoint create local-mqtt --hostname
                                               --instance
                                               --name
                                               --port
                                               --resource-group
                                               [--aud --audience]
                                               [--auth-type {ServiceAccountToken, X509Certificate}]
                                               [--cea --cloud-event-attribute {CreateOrRemap, Propagate}]
                                               [--client-id-prefix]
                                               [--cm --config-map-ref]
                                               [--disable-tls {false, true}]
                                               [--ka --keep-alive]
                                               [--max-inflight-msg --mim]
                                               [--no-auth {false, true}]
                                               [--protocol {Mqtt, WebSockets}]
                                               [--qos]
                                               [--retain {Keep, Never}]
                                               [--secret-name]
                                               [--session-expiry]
                                               [--show-config {false, true}]

示例

使用最小输入创建或替换数据流终结点资源。

az iot ops dataflow endpoint create local-mqtt --name myendpoint --instance mycluster-ops-instance --resource-group myresourcegroup --hostname aio-broker --port 1883

使用 X509 身份验证方法创建或替换数据流终结点资源。

az iot ops dataflow endpoint create local-mqtt --name myendpoint --instance mycluster-ops-instance --resource-group myresourcegroup --hostname aio-broker --port 1883 --secret-name mysecret

创建或替换没有身份验证的数据流终结点资源。

az iot ops dataflow endpoint create local-mqtt --name myendpoint --instance mycluster-ops-instance --resource-group myresourcegroup --hostname aio-broker --port 1883 --no-auth

显示用于创建数据流终结点资源的配置。

az iot ops dataflow endpoint create local-mqtt --name myendpoint --instance mycluster-ops-instance --resource-group myresourcegroup --hostname aio-broker --port 1883 --client-id-prefix myclientprefix --keep-alive 100 --max-inflight-msg 70 --protocol WebSockets --qos 0 --retain Never --show-config

必需参数

--hostname

本地 MQTT 代理的主机名。

--instance -i

IoT 操作实例名称。

--name -n

数据流终结点名称。

--port

本地 MQTT 代理的端口号。

--resource-group -g

资源组的名称。可以使用 az configure --defaults group=<name>配置默认组。

可选参数

以下参数是可选的，但根据上下文，命令可能需要一个或多个参数才能成功执行。

--aud --audience

Kubernetes 服务帐户令牌（SAT）的受众。

属性	值
参数组:	Kubernetes Service Account Token Arguments

--auth-type

数据流终结点的身份验证类型。注意：如果未指定，身份验证类型由其他身份验证参数确定。

属性	值
接受的值:	ServiceAccountToken, X509Certificate

--cea --cloud-event-attribute

CloudEvent 设置类型，用于将事件映射到云。不同的设置需要不同的消息格式。

属性	值
参数组:	Cloud Event Arguments
默认值:	Propagate
接受的值:	CreateOrRemap, Propagate

--client-id-prefix

MQTT 客户端的客户端 ID 前缀。注意：在 IoT作部署后更改客户端 ID 前缀可能会导致数据丢失。

--cm --config-map-ref

属性	值
参数组:	Transport Layer Security (TLS) Arguments
默认值:	azure-iot-operations-aio-ca-trust-bundle

--disable-tls

数据流使用与 Kafka/MQTT 中转站的不安全连接。

属性	值
参数组:	Transport Layer Security (TLS) Arguments
默认值:	False
接受的值:	false, true

--ka --keep-alive

将 PINGREQ 消息发送到中转站之前，数据流客户端可以处于空闲状态的最长时间（以秒为单位）。最小值：0。

属性	值
默认值:	60

--max-inflight-msg --mim

数据流 MQTT 客户端可以拥有的最大飞行消息数。最小值：0。

属性	值
默认值:	100

--no-auth

没有终结点的身份验证。

属性	值
默认值:	False
接受的值:	false, true

--protocol

用于客户端连接的协议。

属性	值
默认值:	Mqtt
接受的值:	Mqtt, WebSockets

--qos

MQTT 消息的服务质量（QoS）级别。仅支持 0 或 1。

属性	值
默认值:	1

--retain

保留设置以指定数据流是否应保留 MQTT 消息上的保留标志。设置此项可确保远程代理是否保留与本地中转站相同的消息。

属性	值
默认值:	Keep
接受的值:	Keep, Never

--secret-name -s

属性	值
参数组:	X509 Authentication Arguments

--session-expiry

数据流 MQTT 客户端的会话到期间隔（以秒为单位）。最小值：0。

属性	值
默认值:	3600

--show-config

显示生成的资源配置，而不是使用它调用 API。

属性	值
接受的值:	false, true

全局参数

--debug

提高日志记录详细程度以显示所有调试日志。

属性	值
默认值:	False

--help -h

显示此帮助消息并退出。

--only-show-errors

只显示错误，取消显示警告。

属性	值
默认值:	False

--output -o

输出格式。

属性	值
默认值:	json
接受的值:	json, jsonc, none, table, tsv, yaml, yamlc

--query

JMESPath 查询字符串。有关更多信息和示例，请参阅 http://jmespath.org/。

--subscription

订阅的名称或 ID。可以使用 az account set -s NAME_OR_ID 配置默认订阅。

--verbose

增加日志记录详细程度。使用 --debug 获取完整的调试日志。

属性	值
默认值:	False

az iot ops dataflow endpoint create local-storage

创建或替换本地存储数据流终结点。

有关本地存储数据流终结点的详细信息，请参阅 https://aka.ms/local-storage-endpoint。

az iot ops dataflow endpoint create local-storage --instance
                                                  --name
                                                  --pvc-ref
                                                  --resource-group
                                                  [--show-config {false, true}]

示例

使用最小输入创建或替换数据流终结点资源。

az iot ops dataflow endpoint create local-storage --name myendpoint --instance mycluster-ops-instance --resource-group myresourcegroup --pvc-ref mypvc

显示用于创建数据流终结点资源的配置。

az iot ops dataflow endpoint create local-storage --name myendpoint --instance mycluster-ops-instance --resource-group myresourcegroup --pvc-ref mypvc --show-config

必需参数

--instance -i

IoT 操作实例名称。

--name -n

数据流终结点名称。

--pvc-ref

要用于本地存储的 PersistentVolumeClaim (PVC) 的名称。注意：PVC 必须与数据流终结点位于同一命名空间中。

--resource-group -g

资源组的名称。可以使用 az configure --defaults group=<name>配置默认组。

可选参数

以下参数是可选的，但根据上下文，命令可能需要一个或多个参数才能成功执行。

--show-config

显示生成的资源配置，而不是使用它调用 API。

属性	值
接受的值:	false, true

全局参数

--debug

提高日志记录详细程度以显示所有调试日志。

属性	值
默认值:	False

--help -h

显示此帮助消息并退出。

--only-show-errors

只显示错误，取消显示警告。

属性	值
默认值:	False

--output -o

输出格式。

属性	值
默认值:	json
接受的值:	json, jsonc, none, table, tsv, yaml, yamlc

--query

JMESPath 查询字符串。有关更多信息和示例，请参阅 http://jmespath.org/。

--subscription

订阅的名称或 ID。可以使用 az account set -s NAME_OR_ID 配置默认订阅。

--verbose

增加日志记录详细程度。使用 --debug 获取完整的调试日志。

属性	值
默认值:	False

az iot ops dataflow endpoint create otel

创建或替换 OpenTelemetry 数据流终结点。

有关 OpenTelemetry 数据流终结点的详细信息，请参阅 https://aka.ms/opentelemetry-endpoint。

az iot ops dataflow endpoint create otel --hostname
                                         --instance
                                         --name
                                         --port
                                         --resource-group
                                         [--aud --audience]
                                         [--auth-type {ServiceAccountToken, X509Certificate}]
                                         [--cm --config-map-ref]
                                         [--disable-tls {false, true}]
                                         [--latency]
                                         [--mc --message-count]
                                         [--no-auth {false, true}]
                                         [--secret-name]
                                         [--show-config {false, true}]

示例

使用最小输入创建或替换数据流终结点资源。

az iot ops dataflow endpoint create otel --name myendpoint --instance mycluster-ops-instance --resource-group myresourcegroup --name myendpoint --hostname https://otel-collector.monitoring.svc.cluster.local --port 4317 --no-auth

显示用于创建数据流终结点资源的配置。

az iot ops dataflow endpoint create otel --name myendpoint --instance mycluster-ops-instance --resource-group myresourcegroup --hostname https://otel-collector.monitoring.svc.cluster.local --port 4317 --no-auth --show-config

使用 X509 身份验证方法创建或替换数据流终结点资源。

az iot ops dataflow endpoint create otel --name myendpoint --instance mycluster-ops-instance --resource-group myresourcegroup --hostname https://otel-collector.monitoring.svc.cluster.local --port 4317 --secret-name mysecret

必需参数

--hostname

打开的遥测设置的主机名。

--instance -i

IoT 操作实例名称。

--name -n

数据流终结点名称。

--port

打开的遥测设置的端口号。

--resource-group -g

资源组的名称。可以使用 az configure --defaults group=<name>配置默认组。

可选参数

以下参数是可选的，但根据上下文，命令可能需要一个或多个参数才能成功执行。

--aud --audience

要对其进行身份验证的服务受众。

属性	值
参数组:	System Assigned Managed Identity Arguments

--auth-type

数据流终结点的身份验证类型。注意：如果未指定，身份验证类型由其他身份验证参数确定。

属性	值
接受的值:	ServiceAccountToken, X509Certificate

--cm --config-map-ref

属性	值
参数组:	Transport Layer Security (TLS) Arguments

--disable-tls

数据流使用与 Kafka/MQTT 中转站的不安全连接。

属性	值
参数组:	Transport Layer Security (TLS) Arguments
默认值:	False
接受的值:	false, true

--latency -l

批处理延迟（以毫秒为单位）。最小值：0，最大值：65535。

属性	值
参数组:	Batching Configuration Arguments
默认值:	60

--mc --message-count

批中的最大消息数。最小值：0，最大值：4294967295。

属性	值
参数组:	Batching Configuration Arguments
默认值:	100000

--no-auth

没有终结点的身份验证。

属性	值
默认值:	False
接受的值:	false, true

--secret-name -s

属性	值
参数组:	X509 Authentication Arguments

--show-config

显示生成的资源配置，而不是使用它调用 API。

属性	值
接受的值:	false, true

全局参数

--debug

提高日志记录详细程度以显示所有调试日志。

属性	值
默认值:	False

--help -h

显示此帮助消息并退出。

--only-show-errors

只显示错误，取消显示警告。

属性	值
默认值:	False

--output -o

输出格式。

属性	值
默认值:	json
接受的值:	json, jsonc, none, table, tsv, yaml, yamlc

--query

JMESPath 查询字符串。有关更多信息和示例，请参阅 http://jmespath.org/。

--subscription

订阅的名称或 ID。可以使用 az account set -s NAME_OR_ID 配置默认订阅。

--verbose

增加日志记录详细程度。使用 --debug 获取完整的调试日志。

属性	值
默认值:	False

反馈

此页面是否有帮助？

通过

az iot ops dataflow endpoint create

命令

az iot ops dataflow endpoint create adls

示例

必需参数

可选参数

az iot ops dataflow endpoint create adx

示例

必需参数

可选参数

az iot ops dataflow endpoint create custom-kafka

示例

必需参数

可选参数

az iot ops dataflow endpoint create custom-mqtt

示例

必需参数

可选参数

az iot ops dataflow endpoint create eventgrid

示例

必需参数

可选参数

az iot ops dataflow endpoint create eventhub

示例

必需参数

可选参数

az iot ops dataflow endpoint create fabric-onelake

示例

必需参数

可选参数

az iot ops dataflow endpoint create fabric-realtime

示例

必需参数

可选参数

az iot ops dataflow endpoint create local-mqtt

示例

必需参数

可选参数

az iot ops dataflow endpoint create local-storage

示例

必需参数

可选参数

az iot ops dataflow endpoint create otel

示例

必需参数

可选参数

反馈