az stream-analytics input

  • Référence

Remarque

Cette référence fait partie de l’extension Stream-Analytics pour Azure CLI (version 2.15.0 ou ultérieure). L’extension installe automatiquement la première fois que vous exécutez une commande d’entrée az stream-analytics. En savoir plus sur les extensions.

Gérez les entrées avec Stream Analytics.

Commandes

Nom Description Type Statut
az stream-analytics input create

Créez une entrée ou remplace une entrée déjà existante sous un travail de streaming existant.

 Extension GA
az stream-analytics input delete

Supprimez une entrée du travail de streaming.

 Extension GA
az stream-analytics input list

Répertorier toutes les entrées sous le travail de diffusion en continu spécifié.

 Extension GA
az stream-analytics input show

Obtenez des détails sur l’entrée spécifiée.

 Extension GA
az stream-analytics input test

Testez si la source de données d’une entrée est accessible et utilisable par le service Azure Stream Analytics.

 Extension GA
az stream-analytics input update

Mettez à jour une entrée existante sous un travail de streaming existant. Cela peut être utilisé pour mettre à jour partiellement (par exemple, mettre à jour une ou deux propriétés) une entrée sans affecter le reste du travail ou de la définition d’entrée.

 Extension GA
az stream-analytics input wait

Placez l’interface CLI dans un état d’attente jusqu’à ce qu’une condition de l’entrée stream-analytics soit remplie.

 Extension GA

az stream-analytics input create

Créez une entrée ou remplace une entrée déjà existante sous un travail de streaming existant.

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

Exemples

Créer une entrée d’objet blob de référence avec sérialisation 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"

Créer une entrée Event Hub de flux avec sérialisation 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"

Créer une entrée IoT Hub de flux avec sérialisation 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"

Créer une entrée d’objet blob de flux avec sérialisation 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"

Paramètres obligatoires

--input-name --name -n

Nom de l'entrée.

--job-name

Nom de la tâche de streaming.

--resource-group -g

Nom du groupe de ressources. Vous pouvez configurer le groupe par défaut en utilisant az configure --defaults group=<name>.

Paramètres facultatifs

--if-match

ETag de l’entrée. Omettez cette valeur pour toujours remplacer l’entrée actuelle. Spécifiez la dernière valeur ETag vue pour empêcher le remplacement accidentel des modifications simultanées.

--if-none-match

Définissez sur « * » pour autoriser la création d’une nouvelle entrée, mais pour empêcher la mise à jour d’une entrée existante. D’autres valeurs entraînent une réponse 412 en cas d’échec de la condition.

--properties

Propriétés associées à une entrée. Obligatoire sur les requêtes PUT (CreateOrReplace). Valeur attendue : json-string/json-file/@json-file.

Paramètres globaux
--debug

Augmentez le niveau de détail de la journalisation pour afficher tous les journaux de débogage.

--help -h

Affichez ce message d’aide et quittez.

--only-show-errors

Afficher uniquement les erreurs, en supprimant les avertissements.

--output -o

Format de sortie.

valeurs acceptées: json, jsonc, none, table, tsv, yaml, yamlc
valeur par défaut: json
--query

Chaîne de requêtes JMESPath. Pour plus d’informations et d’exemples, consultez http://jmespath.org/.

--subscription

Nom ou ID de l’abonnement. Vous pouvez configurer l’abonnement par défaut en utilisant az account set -s NAME_OR_ID.

--verbose

Augmentez le niveau de détail de la journalisation. Utilisez --debug pour des journaux de débogage complets.

az stream-analytics input delete

Supprimez une entrée du travail de streaming.

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

Exemples

Supprimer une entrée

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

Paramètres obligatoires

--input-name --name -n

Nom de l'entrée.

--job-name

Nom de la tâche de streaming.

--resource-group -g

Nom du groupe de ressources. Vous pouvez configurer le groupe par défaut en utilisant az configure --defaults group=<name>.

Paramètres facultatifs

--yes -y

Ne pas demander de confirmation.

valeur par défaut: False
Paramètres globaux
--debug

Augmentez le niveau de détail de la journalisation pour afficher tous les journaux de débogage.

--help -h

Affichez ce message d’aide et quittez.

--only-show-errors

Afficher uniquement les erreurs, en supprimant les avertissements.

--output -o

Format de sortie.

valeurs acceptées: json, jsonc, none, table, tsv, yaml, yamlc
valeur par défaut: json
--query

Chaîne de requêtes JMESPath. Pour plus d’informations et d’exemples, consultez http://jmespath.org/.

--subscription

Nom ou ID de l’abonnement. Vous pouvez configurer l’abonnement par défaut en utilisant az account set -s NAME_OR_ID.

--verbose

Augmentez le niveau de détail de la journalisation. Utilisez --debug pour des journaux de débogage complets.

az stream-analytics input list

Répertorier toutes les entrées sous le travail de diffusion en continu spécifié.

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

Exemples

Répertorier toutes les entrées dans un travail de streaming

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

Répertorier toutes les entrées dans un travail de streaming et inclure des informations de diagnostic à l’aide du paramètre de requête OData $select

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

Paramètres obligatoires

--job-name

Nom de la tâche de streaming.

--resource-group -g

Nom du groupe de ressources. Vous pouvez configurer le groupe par défaut en utilisant az configure --defaults group=<name>.

Paramètres facultatifs

--select

Paramètre de requête OData $select. Il s’agit d’une liste séparée par des virgules des propriétés structurelles à inclure dans la réponse, ou « » pour inclure toutes les propriétés. Par défaut, toutes les propriétés sont retournées à l’exception des diagnostics. Actuellement, seule la valeur « » est acceptée.

Paramètres globaux
--debug

Augmentez le niveau de détail de la journalisation pour afficher tous les journaux de débogage.

--help -h

Affichez ce message d’aide et quittez.

--only-show-errors

Afficher uniquement les erreurs, en supprimant les avertissements.

--output -o

Format de sortie.

valeurs acceptées: json, jsonc, none, table, tsv, yaml, yamlc
valeur par défaut: json
--query

Chaîne de requêtes JMESPath. Pour plus d’informations et d’exemples, consultez http://jmespath.org/.

--subscription

Nom ou ID de l’abonnement. Vous pouvez configurer l’abonnement par défaut en utilisant az account set -s NAME_OR_ID.

--verbose

Augmentez le niveau de détail de la journalisation. Utilisez --debug pour des journaux de débogage complets.

az stream-analytics input show

Obtenez des détails sur l’entrée spécifiée.

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

Exemples

Obtenir une entrée d’objet blob de référence avec sérialisation CSV

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

Obtenir une entrée Event Hub de flux avec sérialisation JSON

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

Obtenir une entrée IoT Hub de flux avec sérialisation Avro

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

Obtenir une entrée d’objet blob de flux avec sérialisation CSV

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

Paramètres obligatoires

--input-name --name -n

Nom de l'entrée.

--job-name

Nom de la tâche de streaming.

--resource-group -g

Nom du groupe de ressources. Vous pouvez configurer le groupe par défaut en utilisant az configure --defaults group=<name>.

Paramètres globaux
--debug

Augmentez le niveau de détail de la journalisation pour afficher tous les journaux de débogage.

--help -h

Affichez ce message d’aide et quittez.

--only-show-errors

Afficher uniquement les erreurs, en supprimant les avertissements.

--output -o

Format de sortie.

valeurs acceptées: json, jsonc, none, table, tsv, yaml, yamlc
valeur par défaut: json
--query

Chaîne de requêtes JMESPath. Pour plus d’informations et d’exemples, consultez http://jmespath.org/.

--subscription

Nom ou ID de l’abonnement. Vous pouvez configurer l’abonnement par défaut en utilisant az account set -s NAME_OR_ID.

--verbose

Augmentez le niveau de détail de la journalisation. Utilisez --debug pour des journaux de débogage complets.

az stream-analytics input test

Testez si la source de données d’une entrée est accessible et utilisable par le service Azure Stream Analytics.

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

Exemples

Tester la connexion pour une entrée

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

Paramètres obligatoires

--input-name --name -n

Nom de l'entrée.

--job-name

Nom de la tâche de streaming.

--resource-group -g

Nom du groupe de ressources. Vous pouvez configurer le groupe par défaut en utilisant az configure --defaults group=<name>.

Paramètres facultatifs

--no-wait

Ne pas attendre la fin de l’opération de longue durée.

valeur par défaut: False
--properties

Propriétés associées à une entrée. Obligatoire sur les requêtes PUT (CreateOrReplace). Valeur attendue : json-string/json-file/@json-file.

Paramètres globaux
--debug

Augmentez le niveau de détail de la journalisation pour afficher tous les journaux de débogage.

--help -h

Affichez ce message d’aide et quittez.

--only-show-errors

Afficher uniquement les erreurs, en supprimant les avertissements.

--output -o

Format de sortie.

valeurs acceptées: json, jsonc, none, table, tsv, yaml, yamlc
valeur par défaut: json
--query

Chaîne de requêtes JMESPath. Pour plus d’informations et d’exemples, consultez http://jmespath.org/.

--subscription

Nom ou ID de l’abonnement. Vous pouvez configurer l’abonnement par défaut en utilisant az account set -s NAME_OR_ID.

--verbose

Augmentez le niveau de détail de la journalisation. Utilisez --debug pour des journaux de débogage complets.

az stream-analytics input update

Mettez à jour une entrée existante sous un travail de streaming existant. Cela peut être utilisé pour mettre à jour partiellement (par exemple, mettre à jour une ou deux propriétés) une entrée sans affecter le reste du travail ou de la définition d’entrée.

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

Exemples

Mettre à jour une entrée d’objet blob de référence

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"

Mettre à jour une entrée Event Hub de flux

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"

Mettre à jour une entrée IoT Hub de flux

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"

Mettre à jour une entrée d’objet blob de flux

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"

Paramètres obligatoires

--input-name --name -n

Nom de l'entrée.

--job-name

Nom de la tâche de streaming.

--resource-group -g

Nom du groupe de ressources. Vous pouvez configurer le groupe par défaut en utilisant az configure --defaults group=<name>.

Paramètres facultatifs

--if-match

ETag de l’entrée. Omettez cette valeur pour toujours remplacer l’entrée actuelle. Spécifiez la dernière valeur ETag vue pour empêcher le remplacement accidentel des modifications simultanées.

--properties

Propriétés associées à une entrée. Obligatoire sur les requêtes PUT (CreateOrReplace). Valeur attendue : json-string/json-file/@json-file.

Paramètres globaux
--debug

Augmentez le niveau de détail de la journalisation pour afficher tous les journaux de débogage.

--help -h

Affichez ce message d’aide et quittez.

--only-show-errors

Afficher uniquement les erreurs, en supprimant les avertissements.

--output -o

Format de sortie.

valeurs acceptées: json, jsonc, none, table, tsv, yaml, yamlc
valeur par défaut: json
--query

Chaîne de requêtes JMESPath. Pour plus d’informations et d’exemples, consultez http://jmespath.org/.

--subscription

Nom ou ID de l’abonnement. Vous pouvez configurer l’abonnement par défaut en utilisant az account set -s NAME_OR_ID.

--verbose

Augmentez le niveau de détail de la journalisation. Utilisez --debug pour des journaux de débogage complets.

az stream-analytics input wait

Placez l’interface CLI dans un état d’attente jusqu’à ce qu’une condition de l’entrée stream-analytics soit remplie.

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

Exemples

Suspendre l’exécution de la ligne de script CLI suivante jusqu’à ce que l’entrée stream-analytics soit correctement créée.

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

Paramètres obligatoires

--input-name --name -n

Nom de l'entrée.

--job-name

Nom de la tâche de streaming.

--resource-group -g

Nom du groupe de ressources. Vous pouvez configurer le groupe par défaut en utilisant az configure --defaults group=<name>.

Paramètres facultatifs

--created

Attendez la création avec « provisioningState » sur « Succeeded ».

valeur par défaut: False
--custom

Attendez que la condition réponde à une requête JMESPath personnalisée. Par exemple, provisioningState !='InProgress', instanceView.statuses[ ?code=='PowerState/running'].

--deleted

Attendez la suppression.

valeur par défaut: False
--exists

Attendez que la ressource existe.

valeur par défaut: False
--interval

Intervalle d’interrogation en secondes.

valeur par défaut: 30
--timeout

Délai maximal d’attente en secondes.

valeur par défaut: 3600
--updated

Attendez la mise à jour avec provisioningState sur « Réussi ».

valeur par défaut: False
Paramètres globaux
--debug

Augmentez le niveau de détail de la journalisation pour afficher tous les journaux de débogage.

--help -h

Affichez ce message d’aide et quittez.

--only-show-errors

Afficher uniquement les erreurs, en supprimant les avertissements.

--output -o

Format de sortie.

valeurs acceptées: json, jsonc, none, table, tsv, yaml, yamlc
valeur par défaut: json
--query

Chaîne de requêtes JMESPath. Pour plus d’informations et d’exemples, consultez http://jmespath.org/.

--subscription

Nom ou ID de l’abonnement. Vous pouvez configurer l’abonnement par défaut en utilisant az account set -s NAME_OR_ID.

--verbose

Augmentez le niveau de détail de la journalisation. Utilisez --debug pour des journaux de débogage complets.