az stream-analytics job
Notitie
Deze verwijzing maakt deel uit van de stream-analytics-extensie voor de Azure CLI (versie 2.15.0 of hoger). De extensie installeert automatisch de eerste keer dat u een az stream-analytics-taakopdracht uitvoert. Meer informatie over extensies.
Streamingtaak beheren met Stream Analytics.
Opdracht
| Name | Description | Type | Status |
|---|---|---|---|
| az stream-analytics job create |
Maak een streamingtaak of vervang een al bestaande streamingtaak. |
Toestel | GA |
| az stream-analytics job delete |
Een streamingtaak verwijderen. |
Toestel | GA |
| az stream-analytics job list |
Alle streamingtaken in de opgegeven resourcegroep weergeven. En een lijst met alle streamingtaken in het opgegeven abonnement. |
Toestel | GA |
| az stream-analytics job scale |
Schaal een streamingtaak wanneer de taak wordt uitgevoerd. |
Toestel | GA |
| az stream-analytics job show |
Details over de opgegeven streamingtaak ophalen. |
Toestel | GA |
| az stream-analytics job start |
Een streamingtaak starten. Zodra een taak is gestart, wordt de invoer gebeurtenissen verwerkt en wordt de uitvoer geproduceerd. |
Toestel | GA |
| az stream-analytics job stop |
Stop een actieve streamingtaak. Hierdoor stopt een actieve streamingtaak met het verwerken van invoerevenementen en het produceren van uitvoer. |
Toestel | GA |
| az stream-analytics job update |
Een bestaande streamingtaak bijwerken. Dit kan worden gebruikt om een streamingtaak gedeeltelijk bij te werken (bijvoorbeeld om een of twee eigenschappen bij te werken) zonder dat dit van invloed is op de rest van de taakdefinitie. |
Toestel | GA |
| az stream-analytics job wait |
Plaats de CLI in een wachtstatus totdat aan een voorwaarde van de stream-analytics-taak wordt voldaan. |
Toestel | GA |
az stream-analytics job create
Maak een streamingtaak of vervang een al bestaande streamingtaak.
az stream-analytics job create --job-name
--resource-group
[--arrival-max-delay]
[--compatibility-level {1.0, 1.2}]
[--content-storage-policy {JobStorageAccount, SystemAccount}]
[--data-locale]
[--functions]
[--id]
[--identity]
[--if-match]
[--if-none-match]
[--inputs]
[--job-storage-account]
[--job-type {Cloud, Edge}]
[--location]
[--no-wait]
[--order-max-delay]
[--out-of-order-policy {Adjust, Drop}]
[--output-error-policy {Drop, Stop}]
[--output-start-mode {CustomTime, JobStartTime, LastOutputEventTime}]
[--output-start-time]
[--outputs]
[--tags]
[--transformation]Voorbeelden
Een volledige streamingtaak maken (een streamingtaak met een transformatie, ten minste 1 invoer en ten minste 1 uitvoer)
az stream-analytics job create --job-name "sj7804" --resource-group "sjrg3276" --location "West US" --compatibility-level "1.0" --data-locale "en-US" --arrival-max-delay 5 --order-max-delay 0 --out-of-order-policy "Drop" --functions "[]" --inputs "[{\"name\":\"inputtest\",\"properties\":{\"type\":\"Stream\",\"datasource\":{\"type\":\"Microsoft.Storage/Blob\",\"properties\":{\"container\":\"containerName\",\"pathPattern\":\"\",\"storageAccounts\":[{\"accountKey\":\"yourAccountKey==\",\"accountName\":\"yourAccountName\"}]}},\"serialization\":{\"type\":\"Json\",\"properties\":{\"encoding\":\"UTF8\"}}}}]" --output-error-policy "Drop" --outputs "[{\"name\":\"outputtest\",\"datasource\":{\"type\":\"Microsoft.Sql/Server/Database\",\"properties\":{\"database\":\"databaseName\",\"password\":\"userPassword\",\"server\":\"serverName\",\"table\":\"tableName\",\"user\":\"<user>\"}}}]" --transformation name="transformationtest" streaming-units=1 query="Select Id, Name from inputtest" --tags key1="value1" key3="value3" randomKey="randomValue"Een streamingtaakshell maken (een streamingtaak zonder invoer, uitvoer, transformatie of functies)
az stream-analytics job create --job-name "sj59" --resource-group "sjrg6936" --location "West US" --compatibility-level "1.0" --data-locale "en-US" --arrival-max-delay 16 --order-max-delay 5 --out-of-order-policy "Drop" --functions "[]" --inputs "[]" --output-error-policy "Drop" --outputs "[]" --tags key1="value1" key3="value3" randomKey="randomValue"Vereiste parameters
De naam van de streamingtaak.
De naam van de resourcegroep. U kunt de standaardgroep configureren met behulp van az configure --defaults group=<name>.
Optionele parameters
De maximaal toelaatbare vertraging in seconden waarin gebeurtenissen die te laat aankomen, kunnen worden opgenomen. Ondersteund bereik is -1 tot 1814399 (20.23:59:59 dagen) en -1 wordt gebruikt om voor onbepaalde tijd te wachten. Als de eigenschap afwezig is, wordt deze geïnterpreteerd als een waarde van -1.
Bepaalt bepaalde runtimegedrag van de streamingtaak.
Geldige waarden zijn JobStorageAccount en SystemAccount. Als deze optie is ingesteld op JobStorageAccount, moet de gebruiker ook de eigenschap jobStorageAccount opgeven. .
De landinstellingen van de stream analytics-taak. Waarde moet de naam zijn van een ondersteunde .NET-cultuur uit de set https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspx. Standaard ingesteld op 'en-US' als er geen is opgegeven.
Een lijst met een of meer functies voor de streamingtaak. De naameigenschap voor elke functie is vereist bij het opgeven van deze eigenschap in een PUT-aanvraag. Deze eigenschap kan niet worden gewijzigd via een PATCH-bewerking. U moet de PATCH-API gebruiken die beschikbaar is voor de afzonderlijke transformatie. Verwachte waarde: json-string/json-file/@json-file.
De resource-id van het cluster.
Beschrijf de door het systeem toegewezen beheerde identiteit die aan deze taak is toegewezen, die kan worden gebruikt voor verificatie met invoer en uitvoer.
Gebruik: --identity tenant-id=XX principal-id=XX type=XX
tenant-id: de id tenantId principal-id: het id-type id van de identiteit: het identiteitstype.
De ETag van de streamingtaak. Laat deze waarde weg om de huidige recordset altijd te overschrijven. Geef de laatst geziene ETag-waarde op om te voorkomen dat gelijktijdige wijzigingen per ongeluk worden overschreven.
Stel deze optie in op *, zodat een nieuwe streamingtaak kan worden gemaakt, maar om te voorkomen dat een bestaande recordset wordt bijgewerkt. Andere waarden resulteren in een reactie van 412 Pre-condition Failed.
Een lijst met een of meer invoergegevens voor de streamingtaak. De naameigenschap voor elke invoer is vereist bij het opgeven van deze eigenschap in een PUT-aanvraag. Deze eigenschap kan niet worden gewijzigd via een PATCH-bewerking. U moet de PATCH-API gebruiken die beschikbaar is voor de afzonderlijke invoer. Verwachte waarde: json-string/json-file/@json-file.
De eigenschappen die zijn gekoppeld aan een Azure Storage-account met MSI.
Gebruik: --job-storage-account authentication-mode=XX account-name=XX account-key=XX
verificatiemodus: verificatiemodus. accountnaam: de naam van het Azure Storage-account. Vereist voor PUT-aanvragen (CreateOrReplace). accountsleutel: de accountsleutel voor het Azure Storage-account. Vereist voor PUT-aanvragen (CreateOrReplace).
Beschrijft het type taak. Geldige modi zijn Cloud en 'Edge'.
Locatie. Waarden van: az account list-locations. U kunt de standaardlocatie configureren met behulp van az configure --defaults location=<location>.
Wacht niet totdat de langdurige bewerking is voltooid.
De maximaal toelaatbare vertraging in seconden waarbij out-of-ordergebeurtenissen kunnen worden aangepast om weer in volgorde te zijn.
Hiermee wordt het beleid aangegeven dat moet worden toegepast op gebeurtenissen die niet in de volgorde van de invoer gebeurtenisstroom aankomen.
Geeft het beleid aan dat moet worden toegepast op gebeurtenissen die binnenkomen bij de uitvoer en niet naar de externe opslag kunnen worden geschreven vanwege een onjuiste indeling (ontbrekende kolomwaarden, kolomwaarden van onjuist type of grootte).
Deze eigenschap mag alleen worden gebruikt wanneer u wilt dat de taak onmiddellijk na het maken wordt gestart. Waarde kan JobStartTime, CustomTime of LastOutputEventTime zijn om aan te geven of het beginpunt van de uitvoergebeurtenisstroom moet worden gestart wanneer de taak wordt gestart, beginnen bij een aangepast gebruikerstijdstempel dat is opgegeven via de eigenschap outputStartTime of beginnen vanaf de laatste uitvoertijd van de gebeurtenis.
Waarde is een iso-8601-geformatteerde tijdstempel die het beginpunt van de uitvoergebeurtenisstroom aangeeft of null om aan te geven dat de uitvoergebeurtenisstroom wordt gestart wanneer de streamingtaak wordt gestart. Deze eigenschap moet een waarde hebben als outputStartMode is ingesteld op CustomTime.
Een lijst met een of meer uitvoer voor de streamingtaak. De naameigenschap voor elke uitvoer is vereist bij het opgeven van deze eigenschap in een PUT-aanvraag. Deze eigenschap kan niet worden gewijzigd via een PATCH-bewerking. U moet de PATCH-API gebruiken die beschikbaar is voor de afzonderlijke uitvoer. Verwachte waarde: json-string/json-file/@json-file.
Door spaties gescheiden tags: key[=value] [key[=value] ...]. Gebruik '' om bestaande tags te wissen.
Geef de query en het aantal streaming-eenheden aan dat moet worden gebruikt voor de streamingtaak. De naameigenschap van de transformatie is vereist bij het opgeven van deze eigenschap in een PUT-aanvraag. Deze eigenschap kan niet worden gewijzigd via een PATCH-bewerking. U moet de PATCH-API gebruiken die beschikbaar is voor de afzonderlijke transformatie.
Gebruik: --transformation streaming-units=XX valid-streaming-units=XX query=XX name=XX
streaming-eenheden: hiermee geeft u het aantal streaming-eenheden op dat door de streamingtaak wordt gebruikt. geldige streaming-eenheden: hiermee geeft u de geldige streaming-eenheden op waarmee een streamingtaak kan worden geschaald. query: hiermee geeft u de query op die wordt uitgevoerd in de streamingtaak. Hier vindt u meer informatie over de Stream Analytics Query Language (SAQL): https://msdn.microsoft.com/library/azure/dn834998 Vereist voor PUT-aanvragen (CreateOrReplace). naam: Resourcenaam.
Globale parameters
Vergroot de uitgebreidheid van logboekregistratie om alle logboeken voor foutopsporing weer te geven.
Dit Help-bericht weergeven en afsluiten.
Alleen fouten weergeven, waarschuwingen onderdrukken.
Uitvoerindeling.
JMESPath-queryreeks. Zie http://jmespath.org/ voor meer informatie en voorbeelden.
Naam of id van het abonnement. U kunt het standaardabonnement configureren met behulp van az account set -s NAME_OR_ID.
Vergroot de uitgebreidheid van logboekregistratie. Gebruik --debug voor volledige foutopsporingslogboeken.
az stream-analytics job delete
Een streamingtaak verwijderen.
az stream-analytics job delete --job-name
--resource-group
[--no-wait]
[--yes]Voorbeelden
Een streamingtaak verwijderen
az stream-analytics job delete --job-name "sj59" --resource-group "sjrg6936"Vereiste parameters
De naam van de streamingtaak.
De naam van de resourcegroep. U kunt de standaardgroep configureren met behulp van az configure --defaults group=<name>.
Optionele parameters
Wacht niet totdat de langdurige bewerking is voltooid.
Niet vragen om bevestiging.
Globale parameters
Vergroot de uitgebreidheid van logboekregistratie om alle logboeken voor foutopsporing weer te geven.
Dit Help-bericht weergeven en afsluiten.
Alleen fouten weergeven, waarschuwingen onderdrukken.
Uitvoerindeling.
JMESPath-queryreeks. Zie http://jmespath.org/ voor meer informatie en voorbeelden.
Naam of id van het abonnement. U kunt het standaardabonnement configureren met behulp van az account set -s NAME_OR_ID.
Vergroot de uitgebreidheid van logboekregistratie. Gebruik --debug voor volledige foutopsporingslogboeken.
az stream-analytics job list
Alle streamingtaken in de opgegeven resourcegroep weergeven. En een lijst met alle streamingtaken in het opgegeven abonnement.
az stream-analytics job list [--expand]
[--resource-group]Voorbeelden
Alle streamingtaken in een resourcegroep weergeven en de $expand OData-queryparameter niet gebruiken
az stream-analytics job list --resource-group "sjrg6936"Alle streamingtaken in een resourcegroep weergeven en de $expand OData-queryparameter gebruiken om invoer, uitvoer, transformatie en functies uit te breiden
az stream-analytics job list --expand "inputs,outputs,transformation,functions" --resource-group "sjrg3276"Alle streamingtaken in een abonnement weergeven en de $expand OData-queryparameter niet gebruiken
az stream-analytics job listGeef alle streamingtaken in een abonnement weer en gebruik de $expand OData-queryparameter om invoer, uitvoer, transformatie en functies uit te breiden
az stream-analytics job list --expand "inputs,outputs,transformation,functions"Optionele parameters
De $expand OData-queryparameter. Dit is een door komma's gescheiden lijst met aanvullende streamingtaakeigenschappen die moeten worden opgenomen in het antwoord, buiten de standaardset die wordt geretourneerd wanneer deze parameter afwezig is. De standaardset is alle eigenschappen van streamingtaken anders dan 'invoer', 'transformatie', 'uitvoer' en 'functies'.
De naam van de resourcegroep. U kunt de standaardgroep configureren met behulp van az configure --defaults group=<name>.
Globale parameters
Vergroot de uitgebreidheid van logboekregistratie om alle logboeken voor foutopsporing weer te geven.
Dit Help-bericht weergeven en afsluiten.
Alleen fouten weergeven, waarschuwingen onderdrukken.
Uitvoerindeling.
JMESPath-queryreeks. Zie http://jmespath.org/ voor meer informatie en voorbeelden.
Naam of id van het abonnement. U kunt het standaardabonnement configureren met behulp van az account set -s NAME_OR_ID.
Vergroot de uitgebreidheid van logboekregistratie. Gebruik --debug voor volledige foutopsporingslogboeken.
az stream-analytics job scale
Schaal een streamingtaak wanneer de taak wordt uitgevoerd.
az stream-analytics job scale --job-name
--resource-group
[--no-wait]
[--streaming-units]Voorbeelden
Een streamingtaak schalen
az stream-analytics job scale --job-name "sj59" --resource-group "sjrg6936" --streaming-units 36Vereiste parameters
De naam van de streamingtaak.
De naam van de resourcegroep. U kunt de standaardgroep configureren met behulp van az configure --defaults group=<name>.
Optionele parameters
Wacht niet totdat de langdurige bewerking is voltooid.
Hiermee geeft u het aantal streaming-eenheden op waarnaar de streamingtaak wordt geschaald.
Globale parameters
Vergroot de uitgebreidheid van logboekregistratie om alle logboeken voor foutopsporing weer te geven.
Dit Help-bericht weergeven en afsluiten.
Alleen fouten weergeven, waarschuwingen onderdrukken.
Uitvoerindeling.
JMESPath-queryreeks. Zie http://jmespath.org/ voor meer informatie en voorbeelden.
Naam of id van het abonnement. U kunt het standaardabonnement configureren met behulp van az account set -s NAME_OR_ID.
Vergroot de uitgebreidheid van logboekregistratie. Gebruik --debug voor volledige foutopsporingslogboeken.
az stream-analytics job show
Details over de opgegeven streamingtaak ophalen.
az stream-analytics job show --job-name
--resource-group
[--expand]Voorbeelden
Een streamingtaak ophalen en de $expand OData-queryparameter niet gebruiken
az stream-analytics job show --job-name "sj59" --resource-group "sjrg6936"Een streamingtaak ophalen en de $expand OData-queryparameter gebruiken om invoer, uitvoer, transformatie en functies uit te breiden
az stream-analytics job show --expand "inputs,outputs,transformation,functions" --job-name "sj7804" --resource-group "sjrg3276"Vereiste parameters
De naam van de streamingtaak.
De naam van de resourcegroep. U kunt de standaardgroep configureren met behulp van az configure --defaults group=<name>.
Optionele parameters
De $expand OData-queryparameter. Dit is een door komma's gescheiden lijst met aanvullende streamingtaakeigenschappen die moeten worden opgenomen in het antwoord, buiten de standaardset die wordt geretourneerd wanneer deze parameter afwezig is. De standaardset is alle eigenschappen van streamingtaken anders dan 'invoer', 'transformatie', 'uitvoer' en 'functies'.
Globale parameters
Vergroot de uitgebreidheid van logboekregistratie om alle logboeken voor foutopsporing weer te geven.
Dit Help-bericht weergeven en afsluiten.
Alleen fouten weergeven, waarschuwingen onderdrukken.
Uitvoerindeling.
JMESPath-queryreeks. Zie http://jmespath.org/ voor meer informatie en voorbeelden.
Naam of id van het abonnement. U kunt het standaardabonnement configureren met behulp van az account set -s NAME_OR_ID.
Vergroot de uitgebreidheid van logboekregistratie. Gebruik --debug voor volledige foutopsporingslogboeken.
az stream-analytics job start
Een streamingtaak starten. Zodra een taak is gestart, wordt de invoer gebeurtenissen verwerkt en wordt de uitvoer geproduceerd.
az stream-analytics job start --job-name
--resource-group
[--no-wait]
[--output-start-mode {CustomTime, JobStartTime, LastOutputEventTime}]
[--output-start-time]Voorbeelden
Een streamingtaak starten met de startmodus customTime-uitvoer
az stream-analytics job start --job-name "sj59" --resource-group "sjrg6936" --output-start-mode "CustomTime" --output-start-time "2012-12-12T12:12:12Z"Een streamingtaak starten met de startmodus JobStartTime-uitvoer
az stream-analytics job start --job-name "sj59" --resource-group "sjrg6936" --output-start-mode "JobStartTime"Een streamingtaak starten met de uitvoerstartmodus LastOutputEventTime
az stream-analytics job start --job-name "sj59" --resource-group "sjrg6936" --output-start-mode "LastOutputEventTime"Vereiste parameters
De naam van de streamingtaak.
De naam van de resourcegroep. U kunt de standaardgroep configureren met behulp van az configure --defaults group=<name>.
Optionele parameters
Wacht niet totdat de langdurige bewerking is voltooid.
Waarde kan JobStartTime, CustomTime of LastOutputEventTime zijn om aan te geven of het beginpunt van de uitvoergebeurtenisstroom moet worden gestart wanneer de taak wordt gestart, beginnen bij een aangepast gebruikerstijdstempel dat is opgegeven via de eigenschap outputStartTime of beginnen vanaf de laatste uitvoertijd van de gebeurtenis.
Waarde is een iso-8601-geformatteerde tijdstempel die het beginpunt van de uitvoergebeurtenisstroom aangeeft of null om aan te geven dat de uitvoergebeurtenisstroom wordt gestart wanneer de streamingtaak wordt gestart. Deze eigenschap moet een waarde hebben als outputStartMode is ingesteld op CustomTime.
Globale parameters
Vergroot de uitgebreidheid van logboekregistratie om alle logboeken voor foutopsporing weer te geven.
Dit Help-bericht weergeven en afsluiten.
Alleen fouten weergeven, waarschuwingen onderdrukken.
Uitvoerindeling.
JMESPath-queryreeks. Zie http://jmespath.org/ voor meer informatie en voorbeelden.
Naam of id van het abonnement. U kunt het standaardabonnement configureren met behulp van az account set -s NAME_OR_ID.
Vergroot de uitgebreidheid van logboekregistratie. Gebruik --debug voor volledige foutopsporingslogboeken.
az stream-analytics job stop
Stop een actieve streamingtaak. Hierdoor stopt een actieve streamingtaak met het verwerken van invoerevenementen en het produceren van uitvoer.
az stream-analytics job stop --job-name
--resource-group
[--no-wait]Voorbeelden
Een streamingtaak stoppen
az stream-analytics job stop --job-name "sj59" --resource-group "sjrg6936"Vereiste parameters
De naam van de streamingtaak.
De naam van de resourcegroep. U kunt de standaardgroep configureren met behulp van az configure --defaults group=<name>.
Optionele parameters
Wacht niet totdat de langdurige bewerking is voltooid.
Globale parameters
Vergroot de uitgebreidheid van logboekregistratie om alle logboeken voor foutopsporing weer te geven.
Dit Help-bericht weergeven en afsluiten.
Alleen fouten weergeven, waarschuwingen onderdrukken.
Uitvoerindeling.
JMESPath-queryreeks. Zie http://jmespath.org/ voor meer informatie en voorbeelden.
Naam of id van het abonnement. U kunt het standaardabonnement configureren met behulp van az account set -s NAME_OR_ID.
Vergroot de uitgebreidheid van logboekregistratie. Gebruik --debug voor volledige foutopsporingslogboeken.
az stream-analytics job update
Een bestaande streamingtaak bijwerken. Dit kan worden gebruikt om een streamingtaak gedeeltelijk bij te werken (bijvoorbeeld om een of twee eigenschappen bij te werken) zonder dat dit van invloed is op de rest van de taakdefinitie.
az stream-analytics job update --job-name
--resource-group
[--arrival-max-delay]
[--compatibility-level {1.0, 1.2}]
[--content-storage-policy {JobStorageAccount, SystemAccount}]
[--data-locale]
[--functions]
[--id]
[--identity]
[--if-match]
[--inputs]
[--job-storage-account]
[--job-type {Cloud, Edge}]
[--location]
[--order-max-delay]
[--out-of-order-policy {Adjust, Drop}]
[--output-error-policy {Drop, Stop}]
[--output-start-mode {CustomTime, JobStartTime, LastOutputEventTime}]
[--output-start-time]
[--outputs]
[--tags]
[--transformation]Voorbeelden
Een streamingtaak bijwerken
az stream-analytics job update --job-name "sj59" --resource-group "sjrg6936" --arrival-max-delay 13 --order-max-delay 21Vereiste parameters
De naam van de streamingtaak.
De naam van de resourcegroep. U kunt de standaardgroep configureren met behulp van az configure --defaults group=<name>.
Optionele parameters
De maximaal toelaatbare vertraging in seconden waarin gebeurtenissen die te laat aankomen, kunnen worden opgenomen. Ondersteund bereik is -1 tot 1814399 (20.23:59:59 dagen) en -1 wordt gebruikt om voor onbepaalde tijd te wachten. Als de eigenschap afwezig is, wordt deze geïnterpreteerd als een waarde van -1.
Bepaalt bepaalde runtimegedrag van de streamingtaak.
Geldige waarden zijn JobStorageAccount en SystemAccount. Als deze optie is ingesteld op JobStorageAccount, moet de gebruiker ook de eigenschap jobStorageAccount opgeven. .
De landinstellingen van de stream analytics-taak. Waarde moet de naam zijn van een ondersteunde .NET-cultuur uit de set https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspx. Standaard ingesteld op 'en-US' als er geen is opgegeven.
Een lijst met een of meer functies voor de streamingtaak. De naameigenschap voor elke functie is vereist bij het opgeven van deze eigenschap in een PUT-aanvraag. Deze eigenschap kan niet worden gewijzigd via een PATCH-bewerking. U moet de PATCH-API gebruiken die beschikbaar is voor de afzonderlijke transformatie. Verwachte waarde: json-string/json-file/@json-file.
De resource-id van het cluster.
Beschrijf de door het systeem toegewezen beheerde identiteit die aan deze taak is toegewezen, die kan worden gebruikt voor verificatie met invoer en uitvoer.
Gebruik: --identity tenant-id=XX principal-id=XX type=XX
tenant-id: de id tenantId principal-id: het id-type id van de identiteit: het identiteitstype.
De ETag van de streamingtaak. Laat deze waarde weg om de huidige recordset altijd te overschrijven. Geef de laatst geziene ETag-waarde op om te voorkomen dat gelijktijdige wijzigingen per ongeluk worden overschreven.
Een lijst met een of meer invoergegevens voor de streamingtaak. De naameigenschap voor elke invoer is vereist bij het opgeven van deze eigenschap in een PUT-aanvraag. Deze eigenschap kan niet worden gewijzigd via een PATCH-bewerking. U moet de PATCH-API gebruiken die beschikbaar is voor de afzonderlijke invoer. Verwachte waarde: json-string/json-file/@json-file.
De eigenschappen die zijn gekoppeld aan een Azure Storage-account met MSI.
Gebruik: --job-storage-account authentication-mode=XX account-name=XX account-key=XX
verificatiemodus: verificatiemodus. accountnaam: de naam van het Azure Storage-account. Vereist voor PUT-aanvragen (CreateOrReplace). accountsleutel: de accountsleutel voor het Azure Storage-account. Vereist voor PUT-aanvragen (CreateOrReplace).
Beschrijft het type taak. Geldige modi zijn Cloud en 'Edge'.
Locatie. Waarden van: az account list-locations. U kunt de standaardlocatie configureren met behulp van az configure --defaults location=<location>.
De maximaal toelaatbare vertraging in seconden waarbij out-of-ordergebeurtenissen kunnen worden aangepast om weer in volgorde te zijn.
Hiermee wordt het beleid aangegeven dat moet worden toegepast op gebeurtenissen die niet in de volgorde van de invoer gebeurtenisstroom aankomen.
Geeft het beleid aan dat moet worden toegepast op gebeurtenissen die binnenkomen bij de uitvoer en niet naar de externe opslag kunnen worden geschreven vanwege een onjuiste indeling (ontbrekende kolomwaarden, kolomwaarden van onjuist type of grootte).
Deze eigenschap mag alleen worden gebruikt wanneer u wilt dat de taak onmiddellijk na het maken wordt gestart. Waarde kan JobStartTime, CustomTime of LastOutputEventTime zijn om aan te geven of het beginpunt van de uitvoergebeurtenisstroom moet worden gestart wanneer de taak wordt gestart, beginnen bij een aangepast gebruikerstijdstempel dat is opgegeven via de eigenschap outputStartTime of beginnen vanaf de laatste uitvoertijd van de gebeurtenis.
Waarde is een iso-8601-geformatteerde tijdstempel die het beginpunt van de uitvoergebeurtenisstroom aangeeft of null om aan te geven dat de uitvoergebeurtenisstroom wordt gestart wanneer de streamingtaak wordt gestart. Deze eigenschap moet een waarde hebben als outputStartMode is ingesteld op CustomTime.
Een lijst met een of meer uitvoer voor de streamingtaak. De naameigenschap voor elke uitvoer is vereist bij het opgeven van deze eigenschap in een PUT-aanvraag. Deze eigenschap kan niet worden gewijzigd via een PATCH-bewerking. U moet de PATCH-API gebruiken die beschikbaar is voor de afzonderlijke uitvoer. Verwachte waarde: json-string/json-file/@json-file.
Door spaties gescheiden tags: key[=value] [key[=value] ...]. Gebruik '' om bestaande tags te wissen.
Geef de query en het aantal streaming-eenheden aan dat moet worden gebruikt voor de streamingtaak. De naameigenschap van de transformatie is vereist bij het opgeven van deze eigenschap in een PUT-aanvraag. Deze eigenschap kan niet worden gewijzigd via een PATCH-bewerking. U moet de PATCH-API gebruiken die beschikbaar is voor de afzonderlijke transformatie.
Gebruik: --transformation streaming-units=XX valid-streaming-units=XX query=XX name=XX
streaming-eenheden: hiermee geeft u het aantal streaming-eenheden op dat door de streamingtaak wordt gebruikt. geldige streaming-eenheden: hiermee geeft u de geldige streaming-eenheden op waarmee een streamingtaak kan worden geschaald. query: hiermee geeft u de query op die wordt uitgevoerd in de streamingtaak. Hier vindt u meer informatie over de Stream Analytics Query Language (SAQL): https://msdn.microsoft.com/library/azure/dn834998 Vereist voor PUT-aanvragen (CreateOrReplace). naam: Resourcenaam.
Globale parameters
Vergroot de uitgebreidheid van logboekregistratie om alle logboeken voor foutopsporing weer te geven.
Dit Help-bericht weergeven en afsluiten.
Alleen fouten weergeven, waarschuwingen onderdrukken.
Uitvoerindeling.
JMESPath-queryreeks. Zie http://jmespath.org/ voor meer informatie en voorbeelden.
Naam of id van het abonnement. U kunt het standaardabonnement configureren met behulp van az account set -s NAME_OR_ID.
Vergroot de uitgebreidheid van logboekregistratie. Gebruik --debug voor volledige foutopsporingslogboeken.
az stream-analytics job wait
Plaats de CLI in een wachtstatus totdat aan een voorwaarde van de stream-analytics-taak wordt voldaan.
az stream-analytics job wait --job-name
--resource-group
[--created]
[--custom]
[--deleted]
[--exists]
[--expand]
[--interval]
[--timeout]
[--updated]Voorbeelden
Pauzeer het uitvoeren van de volgende regel van het CLI-script totdat de stream-analytics-taak is gemaakt.
az stream-analytics job wait --expand "inputs,outputs,transformation,functions" --job-name "sj7804" --resource-group "sjrg3276" --createdPauzeer het uitvoeren van de volgende regel van het CLI-script totdat de stream-analytics-taak is verwijderd.
az stream-analytics job wait --expand "inputs,outputs,transformation,functions" --job-name "sj7804" --resource-group "sjrg3276" --deletedVereiste parameters
De naam van de streamingtaak.
De naam van de resourcegroep. U kunt de standaardgroep configureren met behulp van az configure --defaults group=<name>.
Optionele parameters
Wacht totdat u 'provisioningState' hebt gemaakt bij 'Succeeded'.
Wacht tot de voorwaarde voldoet aan een aangepaste JMESPath-query. Bijvoorbeeld provisioningState!='InProgress', instanceView.statuses[?code=='PowerState/running'].
Wacht totdat deze is verwijderd.
Wacht tot de resource bestaat.
De $expand OData-queryparameter. Dit is een door komma's gescheiden lijst met aanvullende streamingtaakeigenschappen die moeten worden opgenomen in het antwoord, buiten de standaardset die wordt geretourneerd wanneer deze parameter afwezig is. De standaardset is alle eigenschappen van streamingtaken anders dan 'invoer', 'transformatie', 'uitvoer' en 'functies'.
Polling-interval in seconden.
Maximale wachttijd in seconden.
Wacht totdat deze is bijgewerkt met provisioningState op 'Succeeded'.
Globale parameters
Vergroot de uitgebreidheid van logboekregistratie om alle logboeken voor foutopsporing weer te geven.
Dit Help-bericht weergeven en afsluiten.
Alleen fouten weergeven, waarschuwingen onderdrukken.
Uitvoerindeling.
JMESPath-queryreeks. Zie http://jmespath.org/ voor meer informatie en voorbeelden.
Naam of id van het abonnement. U kunt het standaardabonnement configureren met behulp van az account set -s NAME_OR_ID.
Vergroot de uitgebreidheid van logboekregistratie. Gebruik --debug voor volledige foutopsporingslogboeken.
Feedback
Binnenkort beschikbaar: In de loop van 2024 zullen we GitHub-problemen geleidelijk uitfaseren als het feedbackmechanisme voor inhoud en deze vervangen door een nieuw feedbacksysteem. Zie voor meer informatie: https://aka.ms/ContentUserFeedback.
Feedback verzenden en weergeven voor