az iot ops dataflow endpoint create
Note
Эта ссылка является частью расширения azure-iot-ops для Azure CLI (версия 2.70.0 или более поздней). Расширение автоматически установит команду создания конечной точки потока данных az iot ops . Подробнее о расширениях.
Создайте или замените ресурс конечной точки потока данных.
Команды
| Имя | Описание | Тип | Состояние |
|---|---|---|---|
| az iot ops dataflow endpoint create adls |
Создайте или замените ресурс конечной точки потока данных для Azure Data Lake Storage 2-го поколения. |
Extension | GA |
| az iot ops dataflow endpoint create adx |
Создайте или замените ресурс конечной точки потока данных для Azure Data Explorer. |
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. |
Extension | GA |
| az iot ops dataflow endpoint create local-mqtt |
Создайте или замените конечную точку потока данных Операции Интернета вещей Azure Local 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 2-го поколения.
Дополнительные сведения о конечной точке потока данных Azure Data Lake Storage 2-го поколения см. в разделе https://aka.ms/adlsv2.
Примечание. При использовании метода проверки подлинности управляемого удостоверения, назначаемой пользователем, область по умолчанию будет иметь значение, https://storage.azure.com/.default если оно не указано --scope.
az iot ops dataflow endpoint create adls --instance
--name
--resource-group
--sa --storage-account
[--acquire-policy-token]
[--aud --audience]
[--auth-type {AccessToken, SystemAssignedManagedIdentity, UserAssignedManagedIdentity}]
[--change-reference]
[--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
Обязательные параметры
Имя экземпляра операций Интернета вещей.
Имя конечной точки потока данных.
Имя группы ресурсов. Вы можете настроить группу по умолчанию с помощью az configure --defaults group=<name>.
Имя учетной записи Azure Data Lake Storage 2-го поколения.
Необязательные параметры
Следующие параметры являются необязательными, но в зависимости от контекста один или несколько могут потребоваться для успешного выполнения команды.
Автоматическое получение маркера Политика Azure для этой операции ресурса.
| Свойство | Значение |
|---|---|
| Группа параметров: | Global Policy Arguments |
Аудитория службы для проверки подлинности.
| Свойство | Значение |
|---|---|
| Группа параметров: | System Assigned Managed Identity Arguments |
Тип проверки подлинности для конечной точки потока данных. Примечание. Если не указано, тип проверки подлинности определяется другими параметрами проверки подлинности.
| Свойство | Значение |
|---|---|
| Допустимые значения: | AccessToken, SystemAssignedManagedIdentity, UserAssignedManagedIdentity |
Связанный идентификатор ссылки на изменение для этой операции ресурса.
| Свойство | Значение |
|---|---|
| Группа параметров: | Global Policy Arguments |
Идентификатор клиента назначаемого пользователем удостоверения.
| Свойство | Значение |
|---|---|
| Группа параметров: | User Assigned Managed Identity Arguments |
Задержка пакетной обработки в секундах. Минимальное значение: 0, максимальное значение: 65535.
| Свойство | Значение |
|---|---|
| Группа параметров: | Batching Configuration Arguments |
| Default value: | 60 |
Максимальное количество сообщений в пакете. Минимальное значение: 0, максимальное значение: 4294967295.
| Свойство | Значение |
|---|---|
| Группа параметров: | Batching Configuration Arguments |
| Default value: | 100000 |
Идентификатор ресурса (URI идентификатора приложения) ресурса, прикрепленный с суффиксом по умолчанию.
| Свойство | Значение |
|---|---|
| Группа параметров: | User Assigned Managed Identity Arguments |
Имя секрета Kubernetes, содержащего маркер SAS.
| Свойство | Значение |
|---|---|
| Группа параметров: | Access Token Arguments |
Отображение созданной конфигурации ресурса вместо вызова API с ним.
| Свойство | Значение |
|---|---|
| Допустимые значения: | false, true |
Идентификатор клиента назначаемого пользователем удостоверения.
| Свойство | Значение |
|---|---|
| Группа параметров: | User Assigned Managed Identity Arguments |
Глобальные параметры
Повышение уровня детализации журнала для включения всех журналов отладки.
| Свойство | Значение |
|---|---|
| Default value: | False |
Показать это сообщение справки и выйти.
Отображать только ошибки, не показывая предупреждения.
| Свойство | Значение |
|---|---|
| Default value: | False |
Формат вывода.
| Свойство | Значение |
|---|---|
| Default value: | json |
| Допустимые значения: | json, jsonc, none, table, tsv, yaml, yamlc |
Строка запроса JMESPath. Дополнительные сведения и примеры см. в разделе http://jmespath.org/.
Имя или идентификатор подписки. Подписку по умолчанию можно настроить с помощью az account set -s NAME_OR_ID.
Увеличьте уровень детализации ведения журнала. Чтобы включить полные журналы отладки, используйте параметр --debug.
| Свойство | Значение |
|---|---|
| Default value: | False |
az iot ops dataflow endpoint create adx
Создайте или замените ресурс конечной точки потока данных для Azure Data Explorer.
Дополнительные сведения о конечной точке потока данных Azure Data Explorer см. в разделе https://aka.ms/aio-adx.
az iot ops dataflow endpoint create adx --database --db
--host
--instance
--name
--resource-group
[--acquire-policy-token]
[--aud --audience]
[--auth-type {SystemAssignedManagedIdentity, UserAssignedManagedIdentity}]
[--change-reference]
[--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
Обязательные параметры
Имя базы данных Azure Data Explorer.
Узел Azure Data Explorer — это URI кластера Azure Data Explorer. В виде https://cluster.region.kusto.windows.net.
Имя экземпляра операций Интернета вещей.
Имя конечной точки потока данных.
Имя группы ресурсов. Вы можете настроить группу по умолчанию с помощью az configure --defaults group=<name>.
Необязательные параметры
Следующие параметры являются необязательными, но в зависимости от контекста один или несколько могут потребоваться для успешного выполнения команды.
Автоматическое получение маркера Политика Azure для этой операции ресурса.
| Свойство | Значение |
|---|---|
| Группа параметров: | Global Policy Arguments |
Аудитория службы для проверки подлинности.
| Свойство | Значение |
|---|---|
| Группа параметров: | System Assigned Managed Identity Arguments |
Тип проверки подлинности для конечной точки потока данных. Примечание. Если не указано, тип проверки подлинности определяется другими параметрами проверки подлинности.
| Свойство | Значение |
|---|---|
| Допустимые значения: | SystemAssignedManagedIdentity, UserAssignedManagedIdentity |
Связанный идентификатор ссылки на изменение для этой операции ресурса.
| Свойство | Значение |
|---|---|
| Группа параметров: | Global Policy Arguments |
Идентификатор клиента назначаемого пользователем удостоверения.
| Свойство | Значение |
|---|---|
| Группа параметров: | User Assigned Managed Identity Arguments |
Задержка пакетной обработки в секундах. Минимальное значение: 0, максимальное значение: 65535.
| Свойство | Значение |
|---|---|
| Группа параметров: | Batching Configuration Arguments |
| Default value: | 60 |
Максимальное количество сообщений в пакете. Минимальное значение: 0, максимальное значение: 4294967295.
| Свойство | Значение |
|---|---|
| Группа параметров: | Batching Configuration Arguments |
| Default value: | 100000 |
Идентификатор ресурса (URI идентификатора приложения) ресурса, прикрепленный с суффиксом по умолчанию.
| Свойство | Значение |
|---|---|
| Группа параметров: | User Assigned Managed Identity Arguments |
Отображение созданной конфигурации ресурса вместо вызова API с ним.
| Свойство | Значение |
|---|---|
| Допустимые значения: | false, true |
Идентификатор клиента назначаемого пользователем удостоверения.
| Свойство | Значение |
|---|---|
| Группа параметров: | User Assigned Managed Identity Arguments |
Глобальные параметры
Повышение уровня детализации журнала для включения всех журналов отладки.
| Свойство | Значение |
|---|---|
| Default value: | False |
Показать это сообщение справки и выйти.
Отображать только ошибки, не показывая предупреждения.
| Свойство | Значение |
|---|---|
| Default value: | False |
Формат вывода.
| Свойство | Значение |
|---|---|
| Default value: | json |
| Допустимые значения: | json, jsonc, none, table, tsv, yaml, yamlc |
Строка запроса JMESPath. Дополнительные сведения и примеры см. в разделе http://jmespath.org/.
Имя или идентификатор подписки. Подписку по умолчанию можно настроить с помощью az account set -s NAME_OR_ID.
Увеличьте уровень детализации ведения журнала. Чтобы включить полные журналы отладки, используйте параметр --debug.
| Свойство | Значение |
|---|---|
| Default value: | 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}]
[--acquire-policy-token]
[--aud --audience]
[--auth-type {Sasl, SystemAssignedManagedIdentity, UserAssignedManagedIdentity}]
[--cea --cloud-event-attribute {CreateOrRemap, Propagate}]
[--change-reference]
[--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
Обязательные параметры
Имя узла узла брокера Kafka.
Имя экземпляра операций Интернета вещей.
Имя конечной точки потока данных.
Номер порта узла брокера Kafka.
Имя группы ресурсов. Вы можете настроить группу по умолчанию с помощью az configure --defaults group=<name>.
Необязательные параметры
Следующие параметры являются необязательными, но в зависимости от контекста один или несколько могут потребоваться для успешного выполнения команды.
Уровень подтверждения от брокера Kafka, чтобы убедиться, что сообщение, отправленное производителем, успешно записывается в раздел и реплицируется в кластере Kafka.
| Свойство | Значение |
|---|---|
| Default value: | All |
| Допустимые значения: | All, One, Zero |
Автоматическое получение маркера Политика Azure для этой операции ресурса.
| Свойство | Значение |
|---|---|
| Группа параметров: | Global Policy Arguments |
Аудитория службы для проверки подлинности.
| Свойство | Значение |
|---|---|
| Группа параметров: | System Assigned Managed Identity Arguments |
Тип проверки подлинности для конечной точки потока данных. Примечание. Если не указано, тип проверки подлинности определяется другими параметрами проверки подлинности.
| Свойство | Значение |
|---|---|
| Допустимые значения: | Sasl, SystemAssignedManagedIdentity, UserAssignedManagedIdentity |
Тип параметров CloudEvent для сопоставления событий с облаком. Для разных параметров требуется другой формат сообщения.
| Свойство | Значение |
|---|---|
| Группа параметров: | Cloud Event Arguments |
| Default value: | Propagate |
| Допустимые значения: | CreateOrRemap, Propagate |
Связанный идентификатор ссылки на изменение для этой операции ресурса.
| Свойство | Значение |
|---|---|
| Группа параметров: | Global Policy Arguments |
Идентификатор клиента назначаемого пользователем удостоверения.
| Свойство | Значение |
|---|---|
| Группа параметров: | User Assigned Managed Identity Arguments |
Справочник по карте конфигурации для доверенного сертификата ЦС для конечной точки Kafka/MQTT. Примечание. Этот ConfigMap должен содержать сертификат ЦС в формате PEM. ConfigMap должен находиться в том же пространстве имен, что и ресурс потока данных Kafka/MQTT.
| Свойство | Значение |
|---|---|
| Группа параметров: | Transport Layer Security (TLS) Arguments |
Тип сжатия для сообщений, отправленных в разделы Kafka.
| Свойство | Значение |
|---|---|
| Default value: | None |
| Допустимые значения: | Gzip, Lz4, None, Snappy |
Отключите пакетную обработку.
| Свойство | Значение |
|---|---|
| Группа параметров: | Batching Configuration Arguments |
| Default value: | False |
| Допустимые значения: | false, true |
Отключите свойства брокера MQTT, скопированные в заголовки пользователей Kafka.
| Свойство | Значение |
|---|---|
| Default value: | False |
| Допустимые значения: | false, true |
Поток данных использует небезопасное подключение к брокеру Kafka/MQTT.
| Свойство | Значение |
|---|---|
| Группа параметров: | Transport Layer Security (TLS) Arguments |
| Default value: | False |
| Допустимые значения: | false, true |
Идентификатор группы потребителей, которую поток данных использует для чтения сообщений из раздела Kafka.
Задержка пакетной обработки в миллисекундах. Минимальное значение: 0, максимальное значение: 65535.
| Свойство | Значение |
|---|---|
| Группа параметров: | Batching Configuration Arguments |
| Default value: | 5 |
Максимальное количество байтов в пакете.
| Свойство | Значение |
|---|---|
| Группа параметров: | Batching Configuration Arguments |
| Default value: | 1000000 |
Максимальное количество сообщений в пакете. Минимальное значение: 0, максимальное значение: 4294967295.
| Свойство | Значение |
|---|---|
| Группа параметров: | Batching Configuration Arguments |
| Default value: | 100000 |
Проверка подлинности для конечной точки отсутствует.
| Свойство | Значение |
|---|---|
| Default value: | False |
| Допустимые значения: | false, true |
Стратегия обработки секций определяет, как сообщения назначаются секциям Kafka при отправке их в разделы Kafka.
| Свойство | Значение |
|---|---|
| Default value: | Default |
| Допустимые значения: | Default, Property, Static, Topic |
Тип проверки подлинности SASL.
| Свойство | Значение |
|---|---|
| Группа параметров: | SASL Authentication Arguments |
| Допустимые значения: | Plain, ScramSha256, ScramSha512 |
Идентификатор ресурса (URI идентификатора приложения) ресурса, прикрепленный с суффиксом по умолчанию.
| Свойство | Значение |
|---|---|
| Группа параметров: | User Assigned Managed Identity Arguments |
Имя секрета Kubernetes, содержащего маркер SASL.
| Свойство | Значение |
|---|---|
| Группа параметров: | SASL Authentication Arguments |
Отображение созданной конфигурации ресурса вместо вызова API с ним.
| Свойство | Значение |
|---|---|
| Допустимые значения: | false, true |
Идентификатор клиента назначаемого пользователем удостоверения.
| Свойство | Значение |
|---|---|
| Группа параметров: | User Assigned Managed Identity Arguments |
Глобальные параметры
Повышение уровня детализации журнала для включения всех журналов отладки.
| Свойство | Значение |
|---|---|
| Default value: | False |
Показать это сообщение справки и выйти.
Отображать только ошибки, не показывая предупреждения.
| Свойство | Значение |
|---|---|
| Default value: | False |
Формат вывода.
| Свойство | Значение |
|---|---|
| Default value: | json |
| Допустимые значения: | json, jsonc, none, table, tsv, yaml, yamlc |
Строка запроса JMESPath. Дополнительные сведения и примеры см. в разделе http://jmespath.org/.
Имя или идентификатор подписки. Подписку по умолчанию можно настроить с помощью az account set -s NAME_OR_ID.
Увеличьте уровень детализации ведения журнала. Чтобы включить полные журналы отладки, используйте параметр --debug.
| Свойство | Значение |
|---|---|
| Default value: | 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
[--acquire-policy-token]
[--auth-type {ServiceAccountToken, SystemAssignedManagedIdentity, UserAssignedManagedIdentity, X509Certificate}]
[--cea --cloud-event-attribute {CreateOrRemap, Propagate}]
[--change-reference]
[--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
Обязательные параметры
Имя узла настраиваемого параметра узла брокера MQTT.
Имя экземпляра операций Интернета вещей.
Имя конечной точки потока данных.
Номер порта настраиваемого параметра узла брокера MQTT.
Имя группы ресурсов. Вы можете настроить группу по умолчанию с помощью az configure --defaults group=<name>.
Необязательные параметры
Следующие параметры являются необязательными, но в зависимости от контекста один или несколько могут потребоваться для успешного выполнения команды.
Автоматическое получение маркера Политика Azure для этой операции ресурса.
| Свойство | Значение |
|---|---|
| Группа параметров: | Global Policy Arguments |
Тип проверки подлинности для конечной точки потока данных. Примечание. Если не указано, тип проверки подлинности определяется другими параметрами проверки подлинности.
| Свойство | Значение |
|---|---|
| Допустимые значения: | ServiceAccountToken, SystemAssignedManagedIdentity, UserAssignedManagedIdentity, X509Certificate |
Тип параметров CloudEvent для сопоставления событий с облаком. Для разных параметров требуется другой формат сообщения.
| Свойство | Значение |
|---|---|
| Группа параметров: | Cloud Event Arguments |
| Default value: | Propagate |
| Допустимые значения: | CreateOrRemap, Propagate |
Связанный идентификатор ссылки на изменение для этой операции ресурса.
| Свойство | Значение |
|---|---|
| Группа параметров: | Global Policy Arguments |
Идентификатор клиента назначаемого пользователем удостоверения.
| Свойство | Значение |
|---|---|
| Группа параметров: | User Assigned Managed Identity Arguments |
Префикс идентификатора клиента для клиента MQTT. Примечание. Изменение префикса идентификатора клиента после развертывания операций Интернета вещей может привести к потере данных.
Справочник по карте конфигурации для доверенного сертификата ЦС для конечной точки Kafka/MQTT. Примечание. Этот ConfigMap должен содержать сертификат ЦС в формате PEM. ConfigMap должен находиться в том же пространстве имен, что и ресурс потока данных Kafka/MQTT.
| Свойство | Значение |
|---|---|
| Группа параметров: | Transport Layer Security (TLS) Arguments |
Поток данных использует небезопасное подключение к брокеру Kafka/MQTT.
| Свойство | Значение |
|---|---|
| Группа параметров: | Transport Layer Security (TLS) Arguments |
| Default value: | False |
| Допустимые значения: | false, true |
Максимальное время в секундах, когда клиент потока данных может быть неактивным перед отправкой сообщения PINGREQ брокеру. Минимальное значение: 0.
| Свойство | Значение |
|---|---|
| Default value: | 60 |
Максимальное количество входящих сообщений, которые может иметь клиент MQTT потока данных. Минимальное значение: 0.
| Свойство | Значение |
|---|---|
| Default value: | 100 |
Проверка подлинности для конечной точки отсутствует.
| Свойство | Значение |
|---|---|
| Default value: | False |
| Допустимые значения: | false, true |
Протокол, используемый для клиентских подключений.
| Свойство | Значение |
|---|---|
| Default value: | Mqtt |
| Допустимые значения: | Mqtt, WebSockets |
Уровень качества обслуживания (QoS) для сообщений MQTT. Поддерживаются только 0 или 1.
| Свойство | Значение |
|---|---|
| Default value: | 1 |
Сохраните параметр, чтобы указать, должен ли поток данных хранить флаг хранения в сообщениях MQTT. Этот параметр гарантирует, имеет ли удаленный брокер те же сообщения, что и локальный брокер.
| Свойство | Значение |
|---|---|
| Default value: | Keep |
| Допустимые значения: | Keep, Never |
Аудитория назначаемого системой управляемого удостоверения.
| Свойство | Значение |
|---|---|
| Группа параметров: | System Assigned Managed Identity Arguments |
Аудитория маркера учетной записи службы Kubernetes (SAT).
| Свойство | Значение |
|---|---|
| Группа параметров: | Kubernetes Service Account Token Arguments |
Идентификатор ресурса (URI идентификатора приложения) ресурса, прикрепленный с суффиксом по умолчанию.
| Свойство | Значение |
|---|---|
| Группа параметров: | User Assigned Managed Identity Arguments |
Имя секрета Kubernetes, содержащего сертификат клиента X509, закрытый ключ, соответствующий сертификату клиента, и промежуточные сертификаты для цепочки сертификатов клиента. Примечание. Сертификат и закрытый ключ должны быть в формате PEM и не защищены паролем.
| Свойство | Значение |
|---|---|
| Группа параметров: | X509 Authentication Arguments |
Интервал истечения срока действия сеанса в секундах для клиента MQTT потока данных. Минимальное значение: 0.
| Свойство | Значение |
|---|---|
| Default value: | 3600 |
Отображение созданной конфигурации ресурса вместо вызова API с ним.
| Свойство | Значение |
|---|---|
| Допустимые значения: | false, true |
Идентификатор клиента назначаемого пользователем удостоверения.
| Свойство | Значение |
|---|---|
| Группа параметров: | User Assigned Managed Identity Arguments |
Глобальные параметры
Повышение уровня детализации журнала для включения всех журналов отладки.
| Свойство | Значение |
|---|---|
| Default value: | False |
Показать это сообщение справки и выйти.
Отображать только ошибки, не показывая предупреждения.
| Свойство | Значение |
|---|---|
| Default value: | False |
Формат вывода.
| Свойство | Значение |
|---|---|
| Default value: | json |
| Допустимые значения: | json, jsonc, none, table, tsv, yaml, yamlc |
Строка запроса JMESPath. Дополнительные сведения и примеры см. в разделе http://jmespath.org/.
Имя или идентификатор подписки. Подписку по умолчанию можно настроить с помощью az account set -s NAME_OR_ID.
Увеличьте уровень детализации ведения журнала. Чтобы включить полные журналы отладки, используйте параметр --debug.
| Свойство | Значение |
|---|---|
| Default value: | 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
[--acquire-policy-token]
[--aud --audience]
[--auth-type {SystemAssignedManagedIdentity, UserAssignedManagedIdentity, X509Certificate}]
[--cea --cloud-event-attribute {CreateOrRemap, Propagate}]
[--change-reference]
[--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
Обязательные параметры
Имя узла пространства имен сетки событий. Можно найти в свойстве Http hostname. В виде NAMESPACE.REGION-1.ts.eventgrid.azure.net.
Имя экземпляра операций Интернета вещей.
Имя конечной точки потока данных.
Имя группы ресурсов. Вы можете настроить группу по умолчанию с помощью az configure --defaults group=<name>.
Необязательные параметры
Следующие параметры являются необязательными, но в зависимости от контекста один или несколько могут потребоваться для успешного выполнения команды.
Автоматическое получение маркера Политика Azure для этой операции ресурса.
| Свойство | Значение |
|---|---|
| Группа параметров: | Global Policy Arguments |
Аудитория службы для проверки подлинности.
| Свойство | Значение |
|---|---|
| Группа параметров: | System Assigned Managed Identity Arguments |
Тип проверки подлинности для конечной точки потока данных. Примечание. Если не указано, тип проверки подлинности определяется другими параметрами проверки подлинности.
| Свойство | Значение |
|---|---|
| Допустимые значения: | SystemAssignedManagedIdentity, UserAssignedManagedIdentity, X509Certificate |
Тип параметров CloudEvent для сопоставления событий с облаком. Для разных параметров требуется другой формат сообщения.
| Свойство | Значение |
|---|---|
| Группа параметров: | Cloud Event Arguments |
| Default value: | Propagate |
| Допустимые значения: | CreateOrRemap, Propagate |
Связанный идентификатор ссылки на изменение для этой операции ресурса.
| Свойство | Значение |
|---|---|
| Группа параметров: | Global Policy Arguments |
Идентификатор клиента назначаемого пользователем удостоверения.
| Свойство | Значение |
|---|---|
| Группа параметров: | User Assigned Managed Identity Arguments |
Префикс идентификатора клиента для клиента MQTT. Примечание. Изменение префикса идентификатора клиента после развертывания операций Интернета вещей может привести к потере данных.
Справочник по карте конфигурации для доверенного сертификата ЦС для конечной точки Kafka/MQTT. Примечание. Этот ConfigMap должен содержать сертификат ЦС в формате PEM. ConfigMap должен находиться в том же пространстве имен, что и ресурс потока данных Kafka/MQTT.
| Свойство | Значение |
|---|---|
| Группа параметров: | Transport Layer Security (TLS) Arguments |
Максимальное время в секундах, когда клиент потока данных может быть неактивным перед отправкой сообщения PINGREQ брокеру. Минимальное значение: 0.
| Свойство | Значение |
|---|---|
| Default value: | 60 |
Максимальное количество входящих сообщений, которые может иметь клиент MQTT потока данных. Минимальное значение: 0.
| Свойство | Значение |
|---|---|
| Default value: | 100 |
Номер порта пространства имен сетки событий.
| Свойство | Значение |
|---|---|
| Default value: | 8883 |
Протокол, используемый для клиентских подключений.
| Свойство | Значение |
|---|---|
| Default value: | Mqtt |
| Допустимые значения: | Mqtt, WebSockets |
Уровень качества обслуживания (QoS) для сообщений MQTT. Поддерживаются только 0 или 1.
| Свойство | Значение |
|---|---|
| Default value: | 1 |
Сохраните параметр, чтобы указать, должен ли поток данных хранить флаг хранения в сообщениях MQTT. Этот параметр гарантирует, имеет ли удаленный брокер те же сообщения, что и локальный брокер.
| Свойство | Значение |
|---|---|
| Default value: | Keep |
| Допустимые значения: | Keep, Never |
Идентификатор ресурса (URI идентификатора приложения) ресурса, прикрепленный с суффиксом по умолчанию.
| Свойство | Значение |
|---|---|
| Группа параметров: | User Assigned Managed Identity Arguments |
Имя секрета Kubernetes, содержащего сертификат клиента X509, закрытый ключ, соответствующий сертификату клиента, и промежуточные сертификаты для цепочки сертификатов клиента. Примечание. Сертификат и закрытый ключ должны быть в формате PEM и не защищены паролем.
| Свойство | Значение |
|---|---|
| Группа параметров: | X509 Authentication Arguments |
Интервал истечения срока действия сеанса в секундах для клиента MQTT потока данных. Минимальное значение: 0.
| Свойство | Значение |
|---|---|
| Default value: | 3600 |
Отображение созданной конфигурации ресурса вместо вызова API с ним.
| Свойство | Значение |
|---|---|
| Допустимые значения: | false, true |
Идентификатор клиента назначаемого пользователем удостоверения.
| Свойство | Значение |
|---|---|
| Группа параметров: | User Assigned Managed Identity Arguments |
Глобальные параметры
Повышение уровня детализации журнала для включения всех журналов отладки.
| Свойство | Значение |
|---|---|
| Default value: | False |
Показать это сообщение справки и выйти.
Отображать только ошибки, не показывая предупреждения.
| Свойство | Значение |
|---|---|
| Default value: | False |
Формат вывода.
| Свойство | Значение |
|---|---|
| Default value: | json |
| Допустимые значения: | json, jsonc, none, table, tsv, yaml, yamlc |
Строка запроса JMESPath. Дополнительные сведения и примеры см. в разделе http://jmespath.org/.
Имя или идентификатор подписки. Подписку по умолчанию можно настроить с помощью az account set -s NAME_OR_ID.
Увеличьте уровень детализации ведения журнала. Чтобы включить полные журналы отладки, используйте параметр --debug.
| Свойство | Значение |
|---|---|
| Default value: | 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}]
[--acquire-policy-token]
[--aud --audience]
[--auth-type {Sasl, SystemAssignedManagedIdentity, UserAssignedManagedIdentity}]
[--cea --cloud-event-attribute {CreateOrRemap, Propagate}]
[--change-reference]
[--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
Обязательные параметры
Имя пространства имен Event Hubs.
Имя экземпляра операций Интернета вещей.
Имя конечной точки потока данных.
Имя группы ресурсов. Вы можете настроить группу по умолчанию с помощью az configure --defaults group=<name>.
Необязательные параметры
Следующие параметры являются необязательными, но в зависимости от контекста один или несколько могут потребоваться для успешного выполнения команды.
Уровень подтверждения от брокера Kafka, чтобы убедиться, что сообщение, отправленное производителем, успешно записывается в раздел и реплицируется в кластере Kafka.
| Свойство | Значение |
|---|---|
| Default value: | All |
| Допустимые значения: | All, One, Zero |
Автоматическое получение маркера Политика Azure для этой операции ресурса.
| Свойство | Значение |
|---|---|
| Группа параметров: | Global Policy Arguments |
Аудитория службы для проверки подлинности.
| Свойство | Значение |
|---|---|
| Группа параметров: | System Assigned Managed Identity Arguments |
Тип проверки подлинности для конечной точки потока данных. Примечание. Если не указано, тип проверки подлинности определяется другими параметрами проверки подлинности.
| Свойство | Значение |
|---|---|
| Допустимые значения: | Sasl, SystemAssignedManagedIdentity, UserAssignedManagedIdentity |
Тип параметров CloudEvent для сопоставления событий с облаком. Для разных параметров требуется другой формат сообщения.
| Свойство | Значение |
|---|---|
| Группа параметров: | Cloud Event Arguments |
| Default value: | Propagate |
| Допустимые значения: | CreateOrRemap, Propagate |
Связанный идентификатор ссылки на изменение для этой операции ресурса.
| Свойство | Значение |
|---|---|
| Группа параметров: | Global Policy Arguments |
Идентификатор клиента назначаемого пользователем удостоверения.
| Свойство | Значение |
|---|---|
| Группа параметров: | User Assigned Managed Identity Arguments |
Справочник по карте конфигурации для доверенного сертификата ЦС для конечной точки Kafka/MQTT. Примечание. Этот ConfigMap должен содержать сертификат ЦС в формате PEM. ConfigMap должен находиться в том же пространстве имен, что и ресурс потока данных Kafka/MQTT.
| Свойство | Значение |
|---|---|
| Группа параметров: | Transport Layer Security (TLS) Arguments |
Тип сжатия для сообщений, отправленных в разделы Kafka.
| Свойство | Значение |
|---|---|
| Default value: | None |
| Допустимые значения: | Gzip, Lz4, None, Snappy |
Отключите пакетную обработку.
| Свойство | Значение |
|---|---|
| Группа параметров: | Batching Configuration Arguments |
| Default value: | False |
| Допустимые значения: | false, true |
Отключите свойства брокера MQTT, скопированные в заголовки пользователей Kafka.
| Свойство | Значение |
|---|---|
| Default value: | False |
| Допустимые значения: | false, true |
Идентификатор группы потребителей, которую поток данных использует для чтения сообщений из раздела Kafka.
Задержка пакетной обработки в миллисекундах. Минимальное значение: 0, максимальное значение: 65535.
| Свойство | Значение |
|---|---|
| Группа параметров: | Batching Configuration Arguments |
| Default value: | 5 |
Максимальное количество байтов в пакете.
| Свойство | Значение |
|---|---|
| Группа параметров: | Batching Configuration Arguments |
| Default value: | 1000000 |
Максимальное количество сообщений в пакете. Минимальное значение: 0, максимальное значение: 4294967295.
| Свойство | Значение |
|---|---|
| Группа параметров: | Batching Configuration Arguments |
| Default value: | 100000 |
Стратегия обработки секций определяет, как сообщения назначаются секциям Kafka при отправке их в разделы Kafka.
| Свойство | Значение |
|---|---|
| Default value: | Default |
| Допустимые значения: | Default, Property, Static, Topic |
Тип проверки подлинности SASL.
| Свойство | Значение |
|---|---|
| Группа параметров: | SASL Authentication Arguments |
| Допустимые значения: | Plain, ScramSha256, ScramSha512 |
Идентификатор ресурса (URI идентификатора приложения) ресурса, прикрепленный с суффиксом по умолчанию.
| Свойство | Значение |
|---|---|
| Группа параметров: | User Assigned Managed Identity Arguments |
Имя секрета Kubernetes, содержащего строка подключения концентратора событий. Примечание. Секрет должен находиться в том же пространстве имен, что и конечная точка потока данных Kafka. Секрет должен содержать как имя пользователя, так и пароль в виде пар "ключ-значение". Дополнительные сведения о формате секрета см. по ссылке в описании команды.
| Свойство | Значение |
|---|---|
| Группа параметров: | SASL Authentication Arguments |
Отображение созданной конфигурации ресурса вместо вызова API с ним.
| Свойство | Значение |
|---|---|
| Допустимые значения: | false, true |
Идентификатор клиента назначаемого пользователем удостоверения.
| Свойство | Значение |
|---|---|
| Группа параметров: | User Assigned Managed Identity Arguments |
Глобальные параметры
Повышение уровня детализации журнала для включения всех журналов отладки.
| Свойство | Значение |
|---|---|
| Default value: | False |
Показать это сообщение справки и выйти.
Отображать только ошибки, не показывая предупреждения.
| Свойство | Значение |
|---|---|
| Default value: | False |
Формат вывода.
| Свойство | Значение |
|---|---|
| Default value: | json |
| Допустимые значения: | json, jsonc, none, table, tsv, yaml, yamlc |
Строка запроса JMESPath. Дополнительные сведения и примеры см. в разделе http://jmespath.org/.
Имя или идентификатор подписки. Подписку по умолчанию можно настроить с помощью az account set -s NAME_OR_ID.
Увеличьте уровень детализации ведения журнала. Чтобы включить полные журналы отладки, используйте параметр --debug.
| Свойство | Значение |
|---|---|
| Default value: | False |
az iot ops dataflow endpoint create fabric-onelake
Создайте или замените ресурс конечной точки потока данных для Microsoft Fabric OneLake.
Дополнительные сведения о конечной точке потока данных OneLake см. в разделе Microsoft Fabric https://aka.ms/fabric-onelake.
az iot ops dataflow endpoint create fabric-onelake --instance
--lakehouse
--name
--path-type --pt {Files, Tables}
--resource-group
--workspace
[--acquire-policy-token]
[--aud --audience]
[--auth-type {SystemAssignedManagedIdentity, UserAssignedManagedIdentity}]
[--change-reference]
[--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
Обязательные параметры
Имя экземпляра операций Интернета вещей.
Имя Microsoft Fabric lakehouse в предоставленной рабочей области.
Имя конечной точки потока данных.
Тип пути, используемого в OneLake.
| Свойство | Значение |
|---|---|
| Допустимые значения: | Files, Tables |
Имя группы ресурсов. Вы можете настроить группу по умолчанию с помощью az configure --defaults group=<name>.
Имя рабочей области Microsoft Fabric. Примечание. Значение по умолчанию "моя рабочая область" не поддерживается.
Необязательные параметры
Следующие параметры являются необязательными, но в зависимости от контекста один или несколько могут потребоваться для успешного выполнения команды.
Автоматическое получение маркера Политика Azure для этой операции ресурса.
| Свойство | Значение |
|---|---|
| Группа параметров: | Global Policy Arguments |
Аудитория службы для проверки подлинности.
| Свойство | Значение |
|---|---|
| Группа параметров: | System Assigned Managed Identity Arguments |
Тип проверки подлинности для конечной точки потока данных. Примечание. Если не указано, тип проверки подлинности определяется другими параметрами проверки подлинности.
| Свойство | Значение |
|---|---|
| Допустимые значения: | SystemAssignedManagedIdentity, UserAssignedManagedIdentity |
Связанный идентификатор ссылки на изменение для этой операции ресурса.
| Свойство | Значение |
|---|---|
| Группа параметров: | Global Policy Arguments |
Идентификатор клиента назначаемого пользователем удостоверения.
| Свойство | Значение |
|---|---|
| Группа параметров: | User Assigned Managed Identity Arguments |
Задержка пакетной обработки в секундах. Минимальное значение: 0, максимальное значение: 65535.
| Свойство | Значение |
|---|---|
| Группа параметров: | Batching Configuration Arguments |
| Default value: | 60 |
Максимальное количество сообщений в пакете. Минимальное значение: 0, максимальное значение: 4294967295.
| Свойство | Значение |
|---|---|
| Группа параметров: | Batching Configuration Arguments |
| Default value: | 100000 |
Идентификатор ресурса (URI идентификатора приложения) ресурса, прикрепленный с суффиксом по умолчанию.
| Свойство | Значение |
|---|---|
| Группа параметров: | User Assigned Managed Identity Arguments |
Отображение созданной конфигурации ресурса вместо вызова API с ним.
| Свойство | Значение |
|---|---|
| Допустимые значения: | false, true |
Идентификатор клиента назначаемого пользователем удостоверения.
| Свойство | Значение |
|---|---|
| Группа параметров: | User Assigned Managed Identity Arguments |
Глобальные параметры
Повышение уровня детализации журнала для включения всех журналов отладки.
| Свойство | Значение |
|---|---|
| Default value: | False |
Показать это сообщение справки и выйти.
Отображать только ошибки, не показывая предупреждения.
| Свойство | Значение |
|---|---|
| Default value: | False |
Формат вывода.
| Свойство | Значение |
|---|---|
| Default value: | json |
| Допустимые значения: | json, jsonc, none, table, tsv, yaml, yamlc |
Строка запроса JMESPath. Дополнительные сведения и примеры см. в разделе http://jmespath.org/.
Имя или идентификатор подписки. Подписку по умолчанию можно настроить с помощью az account set -s NAME_OR_ID.
Увеличьте уровень детализации ведения журнала. Чтобы включить полные журналы отладки, используйте параметр --debug.
| Свойство | Значение |
|---|---|
| Default value: | False |
az iot ops dataflow endpoint create fabric-realtime
Создайте или замените конечную точку потока данных аналитики Microsoft Fabric Real-Time.
Дополнительные сведения о конечной точке потока данных Microsoft Fabric Real-Time аналитики см. в разделе https://aka.ms/aio-fabric-real-time.
az iot ops dataflow endpoint create fabric-realtime --host
--instance
--name
--resource-group
[--acks {All, One, Zero}]
[--acquire-policy-token]
[--aud --audience]
[--auth-type {Sasl, SystemAssignedManagedIdentity, UserAssignedManagedIdentity}]
[--cea --cloud-event-attribute {CreateOrRemap, Propagate}]
[--change-reference]
[--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
Обязательные параметры
Узел Fabric реального времени — это значение сервера Начальной загрузки. Можно найти в целевом месте потока событий — раздел "Проверка подлинности ключа SAS". В виде *.servicebus.windows.net:9093.
Имя экземпляра операций Интернета вещей.
Имя конечной точки потока данных.
Имя группы ресурсов. Вы можете настроить группу по умолчанию с помощью az configure --defaults group=<name>.
Необязательные параметры
Следующие параметры являются необязательными, но в зависимости от контекста один или несколько могут потребоваться для успешного выполнения команды.
Уровень подтверждения от брокера Kafka, чтобы убедиться, что сообщение, отправленное производителем, успешно записывается в раздел и реплицируется в кластере Kafka.
| Свойство | Значение |
|---|---|
| Default value: | All |
| Допустимые значения: | All, One, Zero |
Автоматическое получение маркера Политика Azure для этой операции ресурса.
| Свойство | Значение |
|---|---|
| Группа параметров: | Global Policy Arguments |
Аудитория службы для проверки подлинности.
| Свойство | Значение |
|---|---|
| Группа параметров: | System Assigned Managed Identity Arguments |
Тип проверки подлинности для конечной точки потока данных. Примечание. Если не указано, тип проверки подлинности определяется другими параметрами проверки подлинности.
| Свойство | Значение |
|---|---|
| Допустимые значения: | Sasl, SystemAssignedManagedIdentity, UserAssignedManagedIdentity |
Тип параметров CloudEvent для сопоставления событий с облаком. Для разных параметров требуется другой формат сообщения.
| Свойство | Значение |
|---|---|
| Группа параметров: | Cloud Event Arguments |
| Default value: | Propagate |
| Допустимые значения: | CreateOrRemap, Propagate |
Связанный идентификатор ссылки на изменение для этой операции ресурса.
| Свойство | Значение |
|---|---|
| Группа параметров: | Global Policy Arguments |
Идентификатор клиента назначаемого пользователем удостоверения.
| Свойство | Значение |
|---|---|
| Группа параметров: | User Assigned Managed Identity Arguments |
Справочник по карте конфигурации для доверенного сертификата ЦС для конечной точки Kafka/MQTT. Примечание. Этот ConfigMap должен содержать сертификат ЦС в формате PEM. ConfigMap должен находиться в том же пространстве имен, что и ресурс потока данных Kafka/MQTT.
| Свойство | Значение |
|---|---|
| Группа параметров: | Transport Layer Security (TLS) Arguments |
Тип сжатия для сообщений, отправленных в разделы Kafka.
| Свойство | Значение |
|---|---|
| Default value: | None |
| Допустимые значения: | Gzip, Lz4, None, Snappy |
Отключите пакетную обработку.
| Свойство | Значение |
|---|---|
| Группа параметров: | Batching Configuration Arguments |
| Default value: | False |
| Допустимые значения: | false, true |
Отключите свойства брокера MQTT, скопированные в заголовки пользователей Kafka.
| Свойство | Значение |
|---|---|
| Default value: | False |
| Допустимые значения: | false, true |
Поток данных использует небезопасное подключение к брокеру Kafka/MQTT.
| Свойство | Значение |
|---|---|
| Группа параметров: | Transport Layer Security (TLS) Arguments |
| Default value: | False |
| Допустимые значения: | false, true |
Идентификатор группы потребителей, которую поток данных использует для чтения сообщений из раздела Kafka.
Задержка пакетной обработки в миллисекундах. Минимальное значение: 0, максимальное значение: 65535.
| Свойство | Значение |
|---|---|
| Группа параметров: | Batching Configuration Arguments |
| Default value: | 5 |
Максимальное количество байтов в пакете.
| Свойство | Значение |
|---|---|
| Группа параметров: | Batching Configuration Arguments |
| Default value: | 1000000 |
Максимальное количество сообщений в пакете. Минимальное значение: 0, максимальное значение: 4294967295.
| Свойство | Значение |
|---|---|
| Группа параметров: | Batching Configuration Arguments |
| Default value: | 100000 |
Стратегия обработки секций определяет, как сообщения назначаются секциям Kafka при отправке их в разделы Kafka.
| Свойство | Значение |
|---|---|
| Default value: | Default |
| Допустимые значения: | Default, Property, Static, Topic |
Тип проверки подлинности SASL.
| Свойство | Значение |
|---|---|
| Группа параметров: | SASL Authentication Arguments |
| Допустимые значения: | Plain, ScramSha256, ScramSha512 |
Идентификатор ресурса (URI идентификатора приложения) ресурса, прикрепленный с суффиксом по умолчанию.
| Свойство | Значение |
|---|---|
| Группа параметров: | User Assigned Managed Identity Arguments |
Имя секрета Kubernetes, содержащего значение первичного ключа подключения. Можно найти в целевом месте потока событий — раздел "Проверка подлинности ключа SAS". Примечание. Секрет должен находиться в том же пространстве имен, что и конечная точка потока данных Kafka. Дополнительные сведения о формате секрета см. по ссылке в описании команды.
| Свойство | Значение |
|---|---|
| Группа параметров: | SASL Authentication Arguments |
Отображение созданной конфигурации ресурса вместо вызова API с ним.
| Свойство | Значение |
|---|---|
| Допустимые значения: | false, true |
Идентификатор клиента назначаемого пользователем удостоверения.
| Свойство | Значение |
|---|---|
| Группа параметров: | User Assigned Managed Identity Arguments |
Глобальные параметры
Повышение уровня детализации журнала для включения всех журналов отладки.
| Свойство | Значение |
|---|---|
| Default value: | False |
Показать это сообщение справки и выйти.
Отображать только ошибки, не показывая предупреждения.
| Свойство | Значение |
|---|---|
| Default value: | False |
Формат вывода.
| Свойство | Значение |
|---|---|
| Default value: | json |
| Допустимые значения: | json, jsonc, none, table, tsv, yaml, yamlc |
Строка запроса JMESPath. Дополнительные сведения и примеры см. в разделе http://jmespath.org/.
Имя или идентификатор подписки. Подписку по умолчанию можно настроить с помощью az account set -s NAME_OR_ID.
Увеличьте уровень детализации ведения журнала. Чтобы включить полные журналы отладки, используйте параметр --debug.
| Свойство | Значение |
|---|---|
| Default value: | False |
az iot ops dataflow endpoint create local-mqtt
Создайте или замените конечную точку потока данных Операции Интернета вещей Azure Local MQTT.
Дополнительные сведения о конечной точке потока данных Операции Интернета вещей Azure Local MQTT см. в разделе https://aka.ms/local-mqtt-broker.
az iot ops dataflow endpoint create local-mqtt --hostname
--instance
--name
--port
--resource-group
[--acquire-policy-token]
[--aud --audience]
[--auth-type {ServiceAccountToken, X509Certificate}]
[--cea --cloud-event-attribute {CreateOrRemap, Propagate}]
[--change-reference]
[--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
Обязательные параметры
Имя узла локального брокера MQTT.
Имя экземпляра операций Интернета вещей.
Имя конечной точки потока данных.
Номер порта локального брокера MQTT.
Имя группы ресурсов. Вы можете настроить группу по умолчанию с помощью az configure --defaults group=<name>.
Необязательные параметры
Следующие параметры являются необязательными, но в зависимости от контекста один или несколько могут потребоваться для успешного выполнения команды.
Автоматическое получение маркера Политика Azure для этой операции ресурса.
| Свойство | Значение |
|---|---|
| Группа параметров: | Global Policy Arguments |
Аудитория маркера учетной записи службы Kubernetes (SAT).
| Свойство | Значение |
|---|---|
| Группа параметров: | Kubernetes Service Account Token Arguments |
Тип проверки подлинности для конечной точки потока данных. Примечание. Если не указано, тип проверки подлинности определяется другими параметрами проверки подлинности.
| Свойство | Значение |
|---|---|
| Допустимые значения: | ServiceAccountToken, X509Certificate |
Тип параметров CloudEvent для сопоставления событий с облаком. Для разных параметров требуется другой формат сообщения.
| Свойство | Значение |
|---|---|
| Группа параметров: | Cloud Event Arguments |
| Default value: | Propagate |
| Допустимые значения: | CreateOrRemap, Propagate |
Связанный идентификатор ссылки на изменение для этой операции ресурса.
| Свойство | Значение |
|---|---|
| Группа параметров: | Global Policy Arguments |
Префикс идентификатора клиента для клиента MQTT. Примечание. Изменение префикса идентификатора клиента после развертывания операций Интернета вещей может привести к потере данных.
Справочник по карте конфигурации для доверенного сертификата ЦС для конечной точки Kafka/MQTT. Примечание. Этот ConfigMap должен содержать сертификат ЦС в формате PEM. ConfigMap должен находиться в том же пространстве имен, что и ресурс потока данных Kafka/MQTT.
| Свойство | Значение |
|---|---|
| Группа параметров: | Transport Layer Security (TLS) Arguments |
| Default value: | azure-iot-operations-aio-ca-trust-bundle |
Поток данных использует небезопасное подключение к брокеру Kafka/MQTT.
| Свойство | Значение |
|---|---|
| Группа параметров: | Transport Layer Security (TLS) Arguments |
| Default value: | False |
| Допустимые значения: | false, true |
Максимальное время в секундах, когда клиент потока данных может быть неактивным перед отправкой сообщения PINGREQ брокеру. Минимальное значение: 0.
| Свойство | Значение |
|---|---|
| Default value: | 60 |
Максимальное количество входящих сообщений, которые может иметь клиент MQTT потока данных. Минимальное значение: 0.
| Свойство | Значение |
|---|---|
| Default value: | 100 |
Проверка подлинности для конечной точки отсутствует.
| Свойство | Значение |
|---|---|
| Default value: | False |
| Допустимые значения: | false, true |
Протокол, используемый для клиентских подключений.
| Свойство | Значение |
|---|---|
| Default value: | Mqtt |
| Допустимые значения: | Mqtt, WebSockets |
Уровень качества обслуживания (QoS) для сообщений MQTT. Поддерживаются только 0 или 1.
| Свойство | Значение |
|---|---|
| Default value: | 1 |
Сохраните параметр, чтобы указать, должен ли поток данных хранить флаг хранения в сообщениях MQTT. Этот параметр гарантирует, имеет ли удаленный брокер те же сообщения, что и локальный брокер.
| Свойство | Значение |
|---|---|
| Default value: | Keep |
| Допустимые значения: | Keep, Never |
Имя секрета Kubernetes, содержащего сертификат клиента X509, закрытый ключ, соответствующий сертификату клиента, и промежуточные сертификаты для цепочки сертификатов клиента. Примечание. Сертификат и закрытый ключ должны быть в формате PEM и не защищены паролем.
| Свойство | Значение |
|---|---|
| Группа параметров: | X509 Authentication Arguments |
Интервал истечения срока действия сеанса в секундах для клиента MQTT потока данных. Минимальное значение: 0.
| Свойство | Значение |
|---|---|
| Default value: | 3600 |
Отображение созданной конфигурации ресурса вместо вызова API с ним.
| Свойство | Значение |
|---|---|
| Допустимые значения: | false, true |
Глобальные параметры
Повышение уровня детализации журнала для включения всех журналов отладки.
| Свойство | Значение |
|---|---|
| Default value: | False |
Показать это сообщение справки и выйти.
Отображать только ошибки, не показывая предупреждения.
| Свойство | Значение |
|---|---|
| Default value: | False |
Формат вывода.
| Свойство | Значение |
|---|---|
| Default value: | json |
| Допустимые значения: | json, jsonc, none, table, tsv, yaml, yamlc |
Строка запроса JMESPath. Дополнительные сведения и примеры см. в разделе http://jmespath.org/.
Имя или идентификатор подписки. Подписку по умолчанию можно настроить с помощью az account set -s NAME_OR_ID.
Увеличьте уровень детализации ведения журнала. Чтобы включить полные журналы отладки, используйте параметр --debug.
| Свойство | Значение |
|---|---|
| Default value: | 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
[--acquire-policy-token]
[--change-reference]
[--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
Обязательные параметры
Имя экземпляра операций Интернета вещей.
Имя конечной точки потока данных.
Имя объекта PersistentVolumeClaim (PVC) для локального хранилища. Примечание. ПВХ должен находиться в том же пространстве имен, что и конечная точка потока данных.
Имя группы ресурсов. Вы можете настроить группу по умолчанию с помощью az configure --defaults group=<name>.
Необязательные параметры
Следующие параметры являются необязательными, но в зависимости от контекста один или несколько могут потребоваться для успешного выполнения команды.
Автоматическое получение маркера Политика Azure для этой операции ресурса.
| Свойство | Значение |
|---|---|
| Группа параметров: | Global Policy Arguments |
Связанный идентификатор ссылки на изменение для этой операции ресурса.
| Свойство | Значение |
|---|---|
| Группа параметров: | Global Policy Arguments |
Отображение созданной конфигурации ресурса вместо вызова API с ним.
| Свойство | Значение |
|---|---|
| Допустимые значения: | false, true |
Глобальные параметры
Повышение уровня детализации журнала для включения всех журналов отладки.
| Свойство | Значение |
|---|---|
| Default value: | False |
Показать это сообщение справки и выйти.
Отображать только ошибки, не показывая предупреждения.
| Свойство | Значение |
|---|---|
| Default value: | False |
Формат вывода.
| Свойство | Значение |
|---|---|
| Default value: | json |
| Допустимые значения: | json, jsonc, none, table, tsv, yaml, yamlc |
Строка запроса JMESPath. Дополнительные сведения и примеры см. в разделе http://jmespath.org/.
Имя или идентификатор подписки. Подписку по умолчанию можно настроить с помощью az account set -s NAME_OR_ID.
Увеличьте уровень детализации ведения журнала. Чтобы включить полные журналы отладки, используйте параметр --debug.
| Свойство | Значение |
|---|---|
| Default value: | 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
[--acquire-policy-token]
[--aud --audience]
[--auth-type {ServiceAccountToken, X509Certificate}]
[--change-reference]
[--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
Обязательные параметры
Имя узла открытого параметра телеметрии.
Имя экземпляра операций Интернета вещей.
Имя конечной точки потока данных.
Номер порта открытого параметра телеметрии.
Имя группы ресурсов. Вы можете настроить группу по умолчанию с помощью az configure --defaults group=<name>.
Необязательные параметры
Следующие параметры являются необязательными, но в зависимости от контекста один или несколько могут потребоваться для успешного выполнения команды.
Автоматическое получение маркера Политика Azure для этой операции ресурса.
| Свойство | Значение |
|---|---|
| Группа параметров: | Global Policy Arguments |
Аудитория службы для проверки подлинности.
| Свойство | Значение |
|---|---|
| Группа параметров: | System Assigned Managed Identity Arguments |
Тип проверки подлинности для конечной точки потока данных. Примечание. Если не указано, тип проверки подлинности определяется другими параметрами проверки подлинности.
| Свойство | Значение |
|---|---|
| Допустимые значения: | ServiceAccountToken, X509Certificate |
Связанный идентификатор ссылки на изменение для этой операции ресурса.
| Свойство | Значение |
|---|---|
| Группа параметров: | Global Policy Arguments |
Справочник по карте конфигурации для доверенного сертификата ЦС для конечной точки Kafka/MQTT. Примечание. Этот ConfigMap должен содержать сертификат ЦС в формате PEM. ConfigMap должен находиться в том же пространстве имен, что и ресурс потока данных Kafka/MQTT.
| Свойство | Значение |
|---|---|
| Группа параметров: | Transport Layer Security (TLS) Arguments |
Поток данных использует небезопасное подключение к брокеру Kafka/MQTT.
| Свойство | Значение |
|---|---|
| Группа параметров: | Transport Layer Security (TLS) Arguments |
| Default value: | False |
| Допустимые значения: | false, true |
Задержка пакетной обработки в секундах. Минимальное значение: 0, максимальное значение: 65535.
| Свойство | Значение |
|---|---|
| Группа параметров: | Batching Configuration Arguments |
| Default value: | 60 |
Максимальное количество сообщений в пакете. Минимальное значение: 0, максимальное значение: 4294967295.
| Свойство | Значение |
|---|---|
| Группа параметров: | Batching Configuration Arguments |
| Default value: | 100000 |
Проверка подлинности для конечной точки отсутствует.
| Свойство | Значение |
|---|---|
| Default value: | False |
| Допустимые значения: | false, true |
Имя секрета Kubernetes, содержащего сертификат клиента X509, закрытый ключ, соответствующий сертификату клиента, и промежуточные сертификаты для цепочки сертификатов клиента. Примечание. Сертификат и закрытый ключ должны быть в формате PEM и не защищены паролем.
| Свойство | Значение |
|---|---|
| Группа параметров: | X509 Authentication Arguments |
Отображение созданной конфигурации ресурса вместо вызова API с ним.
| Свойство | Значение |
|---|---|
| Допустимые значения: | false, true |
Глобальные параметры
Повышение уровня детализации журнала для включения всех журналов отладки.
| Свойство | Значение |
|---|---|
| Default value: | False |
Показать это сообщение справки и выйти.
Отображать только ошибки, не показывая предупреждения.
| Свойство | Значение |
|---|---|
| Default value: | False |
Формат вывода.
| Свойство | Значение |
|---|---|
| Default value: | json |
| Допустимые значения: | json, jsonc, none, table, tsv, yaml, yamlc |
Строка запроса JMESPath. Дополнительные сведения и примеры см. в разделе http://jmespath.org/.
Имя или идентификатор подписки. Подписку по умолчанию можно настроить с помощью az account set -s NAME_OR_ID.
Увеличьте уровень детализации ведения журнала. Чтобы включить полные журналы отладки, используйте параметр --debug.
| Свойство | Значение |
|---|---|
| Default value: | False |