az stream-analytics output
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-uitvoeropdracht uitvoert. Meer informatie over extensies.
Uitvoer beheren met Stream Analytics.
Opdracht
Name | Description | Type | Status |
---|---|---|---|
az stream-analytics output create |
Maak een uitvoer of vervang een al bestaande uitvoer onder een bestaande streamingtaak. |
Toestel | GA |
az stream-analytics output delete |
Verwijder een uitvoer uit de streamingtaak. |
Toestel | GA |
az stream-analytics output list |
Geef alle uitvoer weer onder de opgegeven streamingtaak. |
Toestel | GA |
az stream-analytics output show |
Details over de opgegeven uitvoer ophalen. |
Toestel | GA |
az stream-analytics output test |
Test of de gegevensbron van een uitvoer bereikbaar en bruikbaar is door de Azure Stream Analytics-service. |
Toestel | GA |
az stream-analytics output update |
Werk een bestaande uitvoer bij onder een bestaande streamingtaak. Dit kan worden gebruikt om een uitvoer gedeeltelijk bij te werken (bijvoorbeeld om een of twee eigenschappen bij te werken) zonder dat dit van invloed is op de rest van de taak of uitvoerdefinitie. |
Toestel | GA |
az stream-analytics output wait |
Plaats de CLI in een wachtstatus totdat aan een voorwaarde van de stream-analytics-uitvoer wordt voldaan. |
Toestel | GA |
az stream-analytics output create
Maak een uitvoer of vervang een al bestaande uitvoer onder een bestaande streamingtaak.
az stream-analytics output create --job-name
--name
--resource-group
[--datasource]
[--if-match]
[--if-none-match]
[--serialization]
[--size-window]
[--time-window]
Voorbeelden
Een DocumentDB-uitvoer maken
az stream-analytics output create --job-name "sj2331" --datasource "{\"type\":\"Microsoft.Storage/DocumentDB\",\"properties\":{\"accountId\":\"someAccountId\",\"accountKey\":\"accountKey==\",\"collectionNamePattern\":\"collection\",\"database\":\"db01\",\"documentId\":\"documentId\",\"partitionKey\":\"key\"}}" --output-name "output3022" --resource-group "sjrg7983"
Een Power BI-uitvoer maken
az stream-analytics output create --job-name "sj2331" --datasource "{\"type\":\"PowerBI\",\"properties\":{\"dataset\":\"someDataset\",\"groupId\":\"ac40305e-3e8d-43ac-8161-c33799f43e95\",\"groupName\":\"MyPowerBIGroup\",\"refreshToken\":\"someRefreshToken==\",\"table\":\"someTable\",\"tokenUserDisplayName\":\"Bob Smith\",\"tokenUserPrincipalName\":\"bobsmith@contoso.com\"}}" --output-name "output3022" --resource-group "sjrg7983"
Een Service Bus-wachtrijuitvoer maken met Avro-serialisatie
az stream-analytics output create --job-name "sj5095" --datasource "{\"type\":\"Microsoft.ServiceBus/Queue\",\"properties\":{\"propertyColumns\":[\"column1\",\"column2\"],\"queueName\":\"sdkqueue\",\"serviceBusNamespace\":\"sdktest\",\"sharedAccessPolicyKey\":\"sharedAccessPolicyKey=\",\"sharedAccessPolicyName\":\"RootManageSharedAccessKey\",\"systemPropertyColumns\":{\"MessageId\":\"col3\",\"PartitionKey\":\"col4\"}}}" --serialization "{\"type\":\"Avro\"}" --output-name "output3456" --resource-group "sjrg3410"
Een Service Bus-onderwerpuitvoer maken met CSV-serialisatie
az stream-analytics output create --job-name "sj7094" --datasource "{\"type\":\"Microsoft.ServiceBus/Topic\",\"properties\":{\"propertyColumns\":[\"column1\",\"column2\"],\"serviceBusNamespace\":\"sdktest\",\"sharedAccessPolicyKey\":\"sharedAccessPolicyKey=\",\"sharedAccessPolicyName\":\"RootManageSharedAccessKey\",\"topicName\":\"sdktopic\"}}" --serialization "{\"type\":\"Csv\",\"properties\":{\"encoding\":\"UTF8\",\"fieldDelimiter\":\",\"}}" --output-name "output7886" --resource-group "sjrg6450"
Een blobuitvoer maken met CSV-serialisatie
az stream-analytics output create --job-name "sj900" --datasource "{\"type\":\"Microsoft.Storage/Blob\",\"properties\":{\"container\":\"state\",\"dateFormat\":\"yyyy/MM/dd\",\"pathPattern\":\"{date}/{time}\",\"storageAccounts\":[{\"accountKey\":\"accountKey==\",\"accountName\":\"someAccountName\"}],\"timeFormat\":\"HH\"}}" --serialization "{\"type\":\"Csv\",\"properties\":{\"encoding\":\"UTF8\",\"fieldDelimiter\":\",\"}}" --output-name "output1623" --resource-group "sjrg5023"
Een Azure Data Lake Store-uitvoer maken met JSON-serialisatie
az stream-analytics output create --job-name "sj3310" --datasource "{\"type\":\"Microsoft.DataLake/Accounts\",\"properties\":{\"accountName\":\"someaccount\",\"dateFormat\":\"yyyy/MM/dd\",\"filePathPrefix\":\"{date}/{time}\",\"refreshToken\":\"someRefreshToken==\",\"tenantId\":\"cea4e98b-c798-49e7-8c40-4a2b3beb47dd\",\"timeFormat\":\"HH\",\"tokenUserDisplayName\":\"Bob Smith\",\"tokenUserPrincipalName\":\"bobsmith@contoso.com\"}}" --serialization "{\"type\":\"Json\",\"properties\":{\"format\":\"Array\",\"encoding\":\"UTF8\"}}" --output-name "output5195" --resource-group "sjrg6912"
Een Azure SQL-database-uitvoer maken
az stream-analytics output create --job-name "sj6458" --datasource "{\"type\":\"Microsoft.Sql/Server/Database\",\"properties\":{\"database\":\"someDatabase\",\"password\":\"somePassword\",\"server\":\"someServer\",\"table\":\"someTable\",\"user\":\"<user>\"}}" --output-name "output1755" --resource-group "sjrg2157"
Een Azure Table-uitvoer maken
az stream-analytics output create --job-name "sj2790" --datasource "{\"type\":\"Microsoft.Storage/Table\",\"properties\":{\"accountKey\":\"accountKey==\",\"accountName\":\"someAccountName\",\"batchSize\":25,\"columnsToRemove\":[\"column1\",\"column2\"],\"partitionKey\":\"partitionKey\",\"rowKey\":\"rowKey\",\"table\":\"samples\"}}" --output-name "output958" --resource-group "sjrg5176"
Een Event Hub-uitvoer maken met JSON-serialisatie
az stream-analytics output create --job-name "sj3310" --datasource "{\"type\":\"Microsoft.ServiceBus/EventHub\",\"properties\":{\"eventHubName\":\"sdkeventhub\",\"partitionKey\":\"partitionKey\",\"serviceBusNamespace\":\"sdktest\",\"sharedAccessPolicyKey\":\"sharedAccessPolicyKey=\",\"sharedAccessPolicyName\":\"RootManageSharedAccessKey\"}}" --serialization "{\"type\":\"Json\",\"properties\":{\"format\":\"Array\",\"encoding\":\"UTF8\"}}" --output-name "output5195" --resource-group "sjrg6912"
Vereiste parameters
De naam van de streamingtaak.
De naam van de uitvoer.
De naam van de resourcegroep. U kunt de standaardgroep configureren met behulp van az configure --defaults group=<name>
.
Optionele parameters
Beschrijft de gegevensbron waarnaar uitvoer wordt geschreven. Vereist voor PUT-aanvragen (CreateOrReplace). Verwachte waarde: json-string/json-file/@json-file.
De ETag van de uitvoer. Laat deze waarde weg om altijd de huidige uitvoer 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 er een nieuwe uitvoer kan worden gemaakt, maar om te voorkomen dat een bestaande uitvoer wordt bijgewerkt. Andere waarden resulteren in een reactie van 412 Pre-condition Failed.
Beschrijft hoe gegevens van een invoer worden geserialiseerd of hoe gegevens worden geserialiseerd wanneer ze naar een uitvoer worden geschreven. Vereist voor PUT-aanvragen (CreateOrReplace). Verwachte waarde: json-string/json-file/@json-file.
Het venster Grootte om een Stream Analytics-uitvoer te beperken tot.
Het tijdsbestek voor het filteren van Stream Analytics-taakuitvoer.
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 output delete
Verwijder een uitvoer uit de streamingtaak.
az stream-analytics output delete --job-name
--name
--resource-group
[--yes]
Voorbeelden
Een uitvoer verwijderen
az stream-analytics output delete --job-name "sj6458" --name "output1755" --resource-group "sjrg2157"
Vereiste parameters
De naam van de streamingtaak.
De naam van de uitvoer.
De naam van de resourcegroep. U kunt de standaardgroep configureren met behulp van az configure --defaults group=<name>
.
Optionele parameters
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 output list
Geef alle uitvoer weer onder de opgegeven streamingtaak.
az stream-analytics output list --job-name
--resource-group
[--select]
Voorbeelden
Alle uitvoer in een streamingtaak weergeven
az stream-analytics output list --job-name "sj6458" --resource-group "sjrg2157"
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 $select OData-queryparameter. Dit is een door komma's gescheiden lijst met structurele eigenschappen die moeten worden opgenomen in het antwoord of '' om alle eigenschappen op te nemen. Standaard worden alle eigenschappen geretourneerd, behalve diagnostische gegevens. Accepteert momenteel alleen '' als een geldige waarde.
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 output show
Details over de opgegeven uitvoer ophalen.
az stream-analytics output show --job-name
--name
--resource-group
Voorbeelden
Een DocumentDB-uitvoer ophalen
az stream-analytics output show --job-name "sj2331" --output-name "output3022" --resource-group "sjrg7983"
Een Power BI-uitvoer ophalen
az stream-analytics output show --job-name "sj2331" --output-name "output3022" --resource-group "sjrg7983"
Uitvoer van een Service Bus-wachtrij ophalen met Avro-serialisatie
az stream-analytics output show --job-name "sj5095" --output-name "output3456" --resource-group "sjrg3410"
Een Service Bus-onderwerpuitvoer ophalen met CSV-serialisatie
az stream-analytics output show --job-name "sj7094" --output-name "output7886" --resource-group "sjrg6450"
Een blobuitvoer ophalen met CSV-serialisatie
az stream-analytics output show --job-name "sj900" --output-name "output1623" --resource-group "sjrg5023"
Een Azure Data Lake Store-uitvoer ophalen met JSON-serialisatie
az stream-analytics output show --job-name "sj3310" --output-name "output5195" --resource-group "sjrg6912"
Uitvoer van Azure Data Warehouse ophalen
az stream-analytics output show --job-name "sjName" --output-name "output958" --resource-group "sjrg"
Uitvoer van een Azure SQL-database ophalen
az stream-analytics output show --job-name "sj6458" --output-name "output1755" --resource-group "sjrg2157"
Uitvoer van Een Azure-tabel ophalen
az stream-analytics output show --job-name "sj2790" --output-name "output958" --resource-group "sjrg5176"
Een Event Hub-uitvoer ophalen met JSON-serialisatie
az stream-analytics output show --job-name "sj3310" --output-name "output5195" --resource-group "sjrg6912"
Vereiste parameters
De naam van de streamingtaak.
De naam van de uitvoer.
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 output test
Test of de gegevensbron van een uitvoer bereikbaar en bruikbaar is door de Azure Stream Analytics-service.
az stream-analytics output test --job-name
--name
--resource-group
[--datasource]
[--no-wait]
[--serialization]
[--size-window]
[--time-window]
Voorbeelden
De verbinding testen voor een uitvoer
az stream-analytics output test --job-name "sj6458" --output-name "output1755" --resource-group "sjrg2157"
Vereiste parameters
De naam van de streamingtaak.
De naam van de uitvoer.
De naam van de resourcegroep. U kunt de standaardgroep configureren met behulp van az configure --defaults group=<name>
.
Optionele parameters
Beschrijft de gegevensbron waarnaar uitvoer wordt geschreven. Vereist voor PUT-aanvragen (CreateOrReplace). Verwachte waarde: json-string/json-file/@json-file.
Wacht niet totdat de langdurige bewerking is voltooid.
Beschrijft hoe gegevens van een invoer worden geserialiseerd of hoe gegevens worden geserialiseerd wanneer ze naar een uitvoer worden geschreven. Vereist voor PUT-aanvragen (CreateOrReplace). Verwachte waarde: json-string/json-file/@json-file.
Het venster Grootte om een Stream Analytics-uitvoer te beperken tot.
Het tijdsbestek voor het filteren van Stream Analytics-taakuitvoer.
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 output update
Werk een bestaande uitvoer bij onder een bestaande streamingtaak. Dit kan worden gebruikt om een uitvoer gedeeltelijk bij te werken (bijvoorbeeld om een of twee eigenschappen bij te werken) zonder dat dit van invloed is op de rest van de taak of uitvoerdefinitie.
az stream-analytics output update --job-name
--name
--resource-group
[--datasource]
[--if-match]
[--serialization]
[--size-window]
[--time-window]
Voorbeelden
DocumentDB-uitvoer bijwerken
az stream-analytics output update --job-name "sj2331" --datasource "{\"type\":\"Microsoft.Storage/DocumentDB\",\"properties\":{\"partitionKey\":\"differentPartitionKey\"}}" --output-name "output3022" --resource-group "sjrg7983"
Een Power BI-uitvoer bijwerken
az stream-analytics output update --job-name "sj2331" --datasource "{\"type\":\"PowerBI\",\"properties\":{\"dataset\":\"differentDataset\"}}" --output-name "output3022" --resource-group "sjrg7983"
Uitvoer van een Service Bus-wachtrij bijwerken met Avro-serialisatie
az stream-analytics output update --job-name "sj5095" --datasource "{\"type\":\"Microsoft.ServiceBus/Queue\",\"properties\":{\"queueName\":\"differentQueueName\"}}" --serialization "{\"type\":\"Json\",\"properties\":{\"format\":\"LineSeparated\",\"encoding\":\"UTF8\"}}" --output-name "output3456" --resource-group "sjrg3410"
Een Service Bus-onderwerpuitvoer bijwerken met CSV-serialisatie
az stream-analytics output update --job-name "sj7094" --datasource "{\"type\":\"Microsoft.ServiceBus/Topic\",\"properties\":{\"topicName\":\"differentTopicName\"}}" --serialization "{\"type\":\"Csv\",\"properties\":{\"encoding\":\"UTF8\",\"fieldDelimiter\":\"|\"}}" --output-name "output7886" --resource-group "sjrg6450"
Een blobuitvoer bijwerken met CSV-serialisatie
az stream-analytics output update --job-name "sj900" --datasource "{\"type\":\"Microsoft.Storage/Blob\",\"properties\":{\"container\":\"differentContainer\"}}" --serialization "{\"type\":\"Csv\",\"properties\":{\"encoding\":\"UTF8\",\"fieldDelimiter\":\"|\"}}" --output-name "output1623" --resource-group "sjrg5023"
Een Azure Data Lake Store-uitvoer bijwerken met JSON-serialisatie
az stream-analytics output update --job-name "sj3310" --datasource "{\"type\":\"Microsoft.DataLake/Accounts\",\"properties\":{\"accountName\":\"differentaccount\"}}" --serialization "{\"type\":\"Json\",\"properties\":{\"format\":\"LineSeparated\",\"encoding\":\"UTF8\"}}" --output-name "output5195" --resource-group "sjrg6912"
Uitvoer van een Azure SQL-database bijwerken
az stream-analytics output update --job-name "sj6458" --datasource "{\"type\":\"Microsoft.Sql/Server/Database\",\"properties\":{\"table\":\"differentTable\"}}" --output-name "output1755" --resource-group "sjrg2157"
Uitvoer van Een Azure-tabel bijwerken
az stream-analytics output update --job-name "sj2790" --datasource "{\"type\":\"Microsoft.Storage/Table\",\"properties\":{\"partitionKey\":\"differentPartitionKey\"}}" --output-name "output958" --resource-group "sjrg5176"
Een Event Hub-uitvoer bijwerken met JSON-serialisatie
az stream-analytics output update --job-name "sj3310" --datasource "{\"type\":\"Microsoft.ServiceBus/EventHub\",\"properties\":{\"partitionKey\":\"differentPartitionKey\"}}" --serialization "{\"type\":\"Json\",\"properties\":{\"format\":\"LineSeparated\",\"encoding\":\"UTF8\"}}" --output-name "output5195" --resource-group "sjrg6912"
Vereiste parameters
De naam van de streamingtaak.
De naam van de uitvoer.
De naam van de resourcegroep. U kunt de standaardgroep configureren met behulp van az configure --defaults group=<name>
.
Optionele parameters
Beschrijft de gegevensbron waarnaar uitvoer wordt geschreven. Vereist voor PUT-aanvragen (CreateOrReplace). Verwachte waarde: json-string/json-file/@json-file.
De ETag van de uitvoer. Laat deze waarde weg om altijd de huidige uitvoer te overschrijven. Geef de laatst geziene ETag-waarde op om te voorkomen dat gelijktijdige wijzigingen per ongeluk worden overschreven.
Beschrijft hoe gegevens van een invoer worden geserialiseerd of hoe gegevens worden geserialiseerd wanneer ze naar een uitvoer worden geschreven. Vereist voor PUT-aanvragen (CreateOrReplace). Verwachte waarde: json-string/json-file/@json-file.
Het venster Grootte om een Stream Analytics-uitvoer te beperken tot.
Het tijdsbestek voor het filteren van Stream Analytics-taakuitvoer.
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 output wait
Plaats de CLI in een wachtstatus totdat aan een voorwaarde van de stream-analytics-uitvoer wordt voldaan.
az stream-analytics output wait --job-name
--name
--resource-group
[--created]
[--custom]
[--deleted]
[--exists]
[--interval]
[--timeout]
[--updated]
Voorbeelden
Pauzeer het uitvoeren van de volgende regel van het CLI-script totdat de stream-analytics-uitvoer is gemaakt.
az stream-analytics output wait --job-name "sj3310" --output-name "output5195" --resource-group "sjrg6912" --created
Vereiste parameters
De naam van de streamingtaak.
De naam van de uitvoer.
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.
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.