Поделиться через

az stream-analytics input

  • Ссылка

Примечание.

Эта ссылка является частью расширения stream-analytics для Azure CLI (версия 2.15.0 или более поздней). Расширение автоматически установит первый раз, когда вы запускаете команду az stream-analytics input . Подробнее о расширениях.

Управление входными данными с помощью stream analytics.

Команды

Имя Описание Тип Состояние
az stream-analytics input create

Создайте входные данные или замените уже существующие входные данные в существующем задании потоковой передачи.

 Расширение Общедоступная версия
az stream-analytics input delete

Удалите входные данные из задания потоковой передачи.

 Расширение Общедоступная версия
az stream-analytics input list

Список всех входных данных в указанном задании потоковой передачи.

 Расширение Общедоступная версия
az stream-analytics input show

Получение сведений об указанных входных данных.

 Расширение Общедоступная версия
az stream-analytics input test

Проверьте, доступен ли источник данных входных данных и доступен ли он в службе Azure Stream Analytics.

 Расширение Общедоступная версия
az stream-analytics input update

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

 Расширение Общедоступная версия
az stream-analytics input wait

Поместите интерфейс командной строки в состояние ожидания до тех пор, пока не будет выполнено условие входных данных stream-analytics.

 Расширение Общедоступная версия

az stream-analytics input create

Создайте входные данные или замените уже существующие входные данные в существующем задании потоковой передачи.

az stream-analytics input create --input-name
                                 --job-name
                                 --resource-group
                                 [--if-match]
                                 [--if-none-match]
                                 [--properties]

Примеры

Создание ссылочных входных данных BLOB-объектов с сериализацией CSV

az stream-analytics input create --properties "{\"type\":\"Reference\",\"datasource\":{\"type\":\"Microsoft.Storage/Blob\",\"properties\":{\"container\":\"state\",\"dateFormat\":\"yyyy/MM/dd\",\"pathPattern\":\"{date}/{time}\",\"storageAccounts\":[{\"accountKey\":\"someAccountKey==\",\"accountName\":\"someAccountName\"}],\"timeFormat\":\"HH\"}},\"serialization\":{\"type\":\"Csv\",\"properties\":{\"encoding\":\"UTF8\",\"fieldDelimiter\":\",\"}}}" --input-name "input7225" --job-name "sj9597" --resource-group "sjrg8440"

Создание входных данных концентратора событий потока с сериализацией JSON

az stream-analytics input create --properties "{\"type\":\"Stream\",\"datasource\":{\"type\":\"Microsoft.ServiceBus/EventHub\",\"properties\":{\"consumerGroupName\":\"sdkconsumergroup\",\"eventHubName\":\"sdkeventhub\",\"serviceBusNamespace\":\"sdktest\",\"sharedAccessPolicyKey\":\"someSharedAccessPolicyKey==\",\"sharedAccessPolicyName\":\"RootManageSharedAccessKey\"}},\"serialization\":{\"type\":\"Json\",\"properties\":{\"encoding\":\"UTF8\"}}}" --input-name "input7425" --job-name "sj197" --resource-group "sjrg3139"

Создание потока Центр Интернета вещей входных данных с помощью сериализации Avro

az stream-analytics input create --properties "{\"type\":\"Stream\",\"datasource\":{\"type\":\"Microsoft.Devices/IotHubs\",\"properties\":{\"consumerGroupName\":\"sdkconsumergroup\",\"endpoint\":\"messages/events\",\"iotHubNamespace\":\"iothub\",\"sharedAccessPolicyKey\":\"sharedAccessPolicyKey=\",\"sharedAccessPolicyName\":\"owner\"}},\"serialization\":{\"type\":\"Avro\"}}" --input-name "input7970" --job-name "sj9742" --resource-group "sjrg3467"

Создание входных данных BLOB-объектов потока с помощью сериализации CSV

az stream-analytics input create --properties "{\"type\":\"Stream\",\"datasource\":{\"type\":\"Microsoft.Storage/Blob\",\"properties\":{\"container\":\"state\",\"dateFormat\":\"yyyy/MM/dd\",\"pathPattern\":\"{date}/{time}\",\"sourcePartitionCount\":16,\"storageAccounts\":[{\"accountKey\":\"someAccountKey==\",\"accountName\":\"someAccountName\"}],\"timeFormat\":\"HH\"}},\"serialization\":{\"type\":\"Csv\",\"properties\":{\"encoding\":\"UTF8\",\"fieldDelimiter\":\",\"}}}" --input-name "input8899" --job-name "sj6695" --resource-group "sjrg8161"

Обязательные параметры

--input-name --name -n

Имя входа.

--job-name

Имя задания потоковой передачи.

--resource-group -g

Имя группы ресурсов. Вы можете настроить расположение по умолчанию с помощью az configure --defaults group=<name>.

Необязательные параметры

--if-match

ETag входных данных. Опустите это значение, чтобы всегда перезаписать текущие входные данные. Укажите последнее значение ETag, чтобы предотвратить случайное перезапись одновременных изменений.

--if-none-match

Установите значение "*", чтобы разрешить создание новых входных данных, но для предотвращения обновления существующих входных данных. Другие значения приводят к сбою ответа 412 pre-condition.

--properties

Свойства, связанные с входными данными. Требуется для запросов PUT (CreateOrReplace). Ожидаемое значение: json-string/json-file/@json-file.

Глобальные параметры
--debug

Повышение уровня детализации журнала для включения всех журналов отладки.

--help -h

Отображение этого справочного сообщения и выход.

--only-show-errors

Показывать только ошибки, блокируя предупреждения.

--output -o

Формат вывода.

допустимые значения: json, jsonc, none, table, tsv, yaml, yamlc
значение по умолчанию: json
--query

Строка запроса JMESPath. Дополнительные сведения и примеры см. в разделе http://jmespath.org/.

--subscription

Имя или идентификатор подписки Подписку по умолчанию можно настроить с помощью az account set -s NAME_OR_ID.

--verbose

Повышение уровня детализации журнала. Чтобы включить полные журналы отладки, используйте параметр --debug.

az stream-analytics input delete

Удалите входные данные из задания потоковой передачи.

az stream-analytics input delete --input-name
                                 --job-name
                                 --resource-group
                                 [--yes]

Примеры

Удаление входных данных

az stream-analytics input delete --input-name "input7225" --job-name "sj9597" --resource-group "sjrg8440"

Обязательные параметры

--input-name --name -n

Имя входа.

--job-name

Имя задания потоковой передачи.

--resource-group -g

Имя группы ресурсов. Вы можете настроить расположение по умолчанию с помощью az configure --defaults group=<name>.

Необязательные параметры

--yes -y

Не запрашивать подтверждение.

значение по умолчанию: False
Глобальные параметры
--debug

Повышение уровня детализации журнала для включения всех журналов отладки.

--help -h

Отображение этого справочного сообщения и выход.

--only-show-errors

Показывать только ошибки, блокируя предупреждения.

--output -o

Формат вывода.

допустимые значения: json, jsonc, none, table, tsv, yaml, yamlc
значение по умолчанию: json
--query

Строка запроса JMESPath. Дополнительные сведения и примеры см. в разделе http://jmespath.org/.

--subscription

Имя или идентификатор подписки Подписку по умолчанию можно настроить с помощью az account set -s NAME_OR_ID.

--verbose

Повышение уровня детализации журнала. Чтобы включить полные журналы отладки, используйте параметр --debug.

az stream-analytics input list

Список всех входных данных в указанном задании потоковой передачи.

az stream-analytics input list --job-name
                               --resource-group
                               [--select]

Примеры

Вывод списка всех входных данных в задании потоковой передачи

az stream-analytics input list --job-name "sj9597" --resource-group "sjrg8440"

Перечислить все входные данные в задании потоковой передачи и включить диагностические сведения с помощью параметра запроса OData $select

az stream-analytics input list --select "*" --job-name "sj7804" --resource-group "sjrg3276"

Обязательные параметры

--job-name

Имя задания потоковой передачи.

--resource-group -g

Имя группы ресурсов. Вы можете настроить расположение по умолчанию с помощью az configure --defaults group=<name>.

Необязательные параметры

--select

Параметр запроса OData $select. Это разделенный запятыми список структурных свойств для включения в ответ или "" для включения всех свойств. По умолчанию возвращаются все свойства, кроме диагностика. В настоящее время принимает только "" в качестве допустимого значения.

Глобальные параметры
--debug

Повышение уровня детализации журнала для включения всех журналов отладки.

--help -h

Отображение этого справочного сообщения и выход.

--only-show-errors

Показывать только ошибки, блокируя предупреждения.

--output -o

Формат вывода.

допустимые значения: json, jsonc, none, table, tsv, yaml, yamlc
значение по умолчанию: json
--query

Строка запроса JMESPath. Дополнительные сведения и примеры см. в разделе http://jmespath.org/.

--subscription

Имя или идентификатор подписки Подписку по умолчанию можно настроить с помощью az account set -s NAME_OR_ID.

--verbose

Повышение уровня детализации журнала. Чтобы включить полные журналы отладки, используйте параметр --debug.

az stream-analytics input show

Получение сведений об указанных входных данных.

az stream-analytics input show --input-name
                               --job-name
                               --resource-group

Примеры

Получение ссылочных входных данных BLOB-объектов с помощью сериализации CSV

az stream-analytics input show --input-name "input7225" --job-name "sj9597" --resource-group "sjrg8440"

Получение входных данных концентратора событий потока с помощью сериализации JSON

az stream-analytics input show --input-name "input7425" --job-name "sj197" --resource-group "sjrg3139"

Получение потока Центр Интернета вещей входных данных с помощью сериализации Avro

az stream-analytics input show --input-name "input7970" --job-name "sj9742" --resource-group "sjrg3467"

Получение входных данных большого двоичного объекта потока с сериализацией CSV

az stream-analytics input show --input-name "input8899" --job-name "sj6695" --resource-group "sjrg8161"

Обязательные параметры

--input-name --name -n

Имя входа.

--job-name

Имя задания потоковой передачи.

--resource-group -g

Имя группы ресурсов. Вы можете настроить расположение по умолчанию с помощью az configure --defaults group=<name>.

Глобальные параметры
--debug

Повышение уровня детализации журнала для включения всех журналов отладки.

--help -h

Отображение этого справочного сообщения и выход.

--only-show-errors

Показывать только ошибки, блокируя предупреждения.

--output -o

Формат вывода.

допустимые значения: json, jsonc, none, table, tsv, yaml, yamlc
значение по умолчанию: json
--query

Строка запроса JMESPath. Дополнительные сведения и примеры см. в разделе http://jmespath.org/.

--subscription

Имя или идентификатор подписки Подписку по умолчанию можно настроить с помощью az account set -s NAME_OR_ID.

--verbose

Повышение уровня детализации журнала. Чтобы включить полные журналы отладки, используйте параметр --debug.

az stream-analytics input test

Проверьте, доступен ли источник данных входных данных и доступен ли он в службе Azure Stream Analytics.

az stream-analytics input test --input-name
                               --job-name
                               --resource-group
                               [--no-wait]
                               [--properties]

Примеры

Проверка подключения для входных данных

az stream-analytics input test --input-name "input7225" --job-name "sj9597" --resource-group "sjrg8440"

Обязательные параметры

--input-name --name -n

Имя входа.

--job-name

Имя задания потоковой передачи.

--resource-group -g

Имя группы ресурсов. Вы можете настроить расположение по умолчанию с помощью az configure --defaults group=<name>.

Необязательные параметры

--no-wait

Не ожидать завершения длительной операции.

значение по умолчанию: False
--properties

Свойства, связанные с входными данными. Требуется для запросов PUT (CreateOrReplace). Ожидаемое значение: json-string/json-file/@json-file.

Глобальные параметры
--debug

Повышение уровня детализации журнала для включения всех журналов отладки.

--help -h

Отображение этого справочного сообщения и выход.

--only-show-errors

Показывать только ошибки, блокируя предупреждения.

--output -o

Формат вывода.

допустимые значения: json, jsonc, none, table, tsv, yaml, yamlc
значение по умолчанию: json
--query

Строка запроса JMESPath. Дополнительные сведения и примеры см. в разделе http://jmespath.org/.

--subscription

Имя или идентификатор подписки Подписку по умолчанию можно настроить с помощью az account set -s NAME_OR_ID.

--verbose

Повышение уровня детализации журнала. Чтобы включить полные журналы отладки, используйте параметр --debug.

az stream-analytics input update

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

az stream-analytics input update --input-name
                                 --job-name
                                 --resource-group
                                 [--if-match]
                                 [--properties]

Примеры

Обновление входных данных ссылочного BLOB-объекта

az stream-analytics input update --properties "{\"type\":\"Reference\",\"datasource\":{\"type\":\"Microsoft.Storage/Blob\",\"properties\":{\"container\":\"differentContainer\"}},\"serialization\":{\"type\":\"Csv\",\"properties\":{\"encoding\":\"UTF8\",\"fieldDelimiter\":\"|\"}}}" --input-name "input7225" --job-name "sj9597" --resource-group "sjrg8440"

Обновление входных данных концентратора событий потока

az stream-analytics input update --properties "{\"type\":\"Stream\",\"datasource\":{\"type\":\"Microsoft.ServiceBus/EventHub\",\"properties\":{\"consumerGroupName\":\"differentConsumerGroupName\"}},\"serialization\":{\"type\":\"Avro\"}}" --input-name "input7425" --job-name "sj197" --resource-group "sjrg3139"

Обновление потока Центр Интернета вещей входных данных

az stream-analytics input update --properties "{\"type\":\"Stream\",\"datasource\":{\"type\":\"Microsoft.Devices/IotHubs\",\"properties\":{\"endpoint\":\"messages/operationsMonitoringEvents\"}},\"serialization\":{\"type\":\"Csv\",\"properties\":{\"encoding\":\"UTF8\",\"fieldDelimiter\":\"|\"}}}" --input-name "input7970" --job-name "sj9742" --resource-group "sjrg3467"

Обновление входных данных большого двоичного объекта потока

az stream-analytics input update --properties "{\"type\":\"Stream\",\"datasource\":{\"type\":\"Microsoft.Storage/Blob\",\"properties\":{\"sourcePartitionCount\":32}},\"serialization\":{\"type\":\"Csv\",\"properties\":{\"encoding\":\"UTF8\",\"fieldDelimiter\":\"|\"}}}" --input-name "input8899" --job-name "sj6695" --resource-group "sjrg8161"

Обязательные параметры

--input-name --name -n

Имя входа.

--job-name

Имя задания потоковой передачи.

--resource-group -g

Имя группы ресурсов. Вы можете настроить расположение по умолчанию с помощью az configure --defaults group=<name>.

Необязательные параметры

--if-match

ETag входных данных. Опустите это значение, чтобы всегда перезаписать текущие входные данные. Укажите последнее значение ETag, чтобы предотвратить случайное перезапись одновременных изменений.

--properties

Свойства, связанные с входными данными. Требуется для запросов PUT (CreateOrReplace). Ожидаемое значение: json-string/json-file/@json-file.

Глобальные параметры
--debug

Повышение уровня детализации журнала для включения всех журналов отладки.

--help -h

Отображение этого справочного сообщения и выход.

--only-show-errors

Показывать только ошибки, блокируя предупреждения.

--output -o

Формат вывода.

допустимые значения: json, jsonc, none, table, tsv, yaml, yamlc
значение по умолчанию: json
--query

Строка запроса JMESPath. Дополнительные сведения и примеры см. в разделе http://jmespath.org/.

--subscription

Имя или идентификатор подписки Подписку по умолчанию можно настроить с помощью az account set -s NAME_OR_ID.

--verbose

Повышение уровня детализации журнала. Чтобы включить полные журналы отладки, используйте параметр --debug.

az stream-analytics input wait

Поместите интерфейс командной строки в состояние ожидания до тех пор, пока не будет выполнено условие входных данных stream-analytics.

az stream-analytics input wait --input-name
                               --job-name
                               --resource-group
                               [--created]
                               [--custom]
                               [--deleted]
                               [--exists]
                               [--interval]
                               [--timeout]
                               [--updated]

Примеры

Приостанавливает выполнение следующей строки скрипта CLI до тех пор, пока входные данные stream-analytics не будут успешно созданы.

az stream-analytics input wait --input-name "input8899" --job-name "sj6695" --resource-group "sjrg8161" --created

Обязательные параметры

--input-name --name -n

Имя входа.

--job-name

Имя задания потоковой передачи.

--resource-group -g

Имя группы ресурсов. Вы можете настроить расположение по умолчанию с помощью az configure --defaults group=<name>.

Необязательные параметры

--created

Подождите, пока не будет создано с помощью provisioningState по адресу "Успешно".

значение по умолчанию: False
--custom

Подождите, пока условие не будет удовлетворено пользовательским запросом JMESPath. Например, provisioningState!='InProgress', instanceView.statuses[?code='PowerState/running'].

--deleted

Дождитесь удаления.

значение по умолчанию: False
--exists

Подождите, пока ресурс не существует.

значение по умолчанию: False
--interval

Интервал опроса в секундах.

значение по умолчанию: 30
--timeout

Максимальное ожидание в секундах.

значение по умолчанию: 3600
--updated

Подождите, пока не будет обновлено с помощью provisioningState по адресу "Успешно".

значение по умолчанию: False
Глобальные параметры
--debug

Повышение уровня детализации журнала для включения всех журналов отладки.

--help -h

Отображение этого справочного сообщения и выход.

--only-show-errors

Показывать только ошибки, блокируя предупреждения.

--output -o

Формат вывода.

допустимые значения: json, jsonc, none, table, tsv, yaml, yamlc
значение по умолчанию: json
--query

Строка запроса JMESPath. Дополнительные сведения и примеры см. в разделе http://jmespath.org/.

--subscription

Имя или идентификатор подписки Подписку по умолчанию можно настроить с помощью az account set -s NAME_OR_ID.

--verbose

Повышение уровня детализации журнала. Чтобы включить полные журналы отладки, используйте параметр --debug.