az stream-analytics input
Notitie
Deze verwijzing maakt deel uit van de Stream Analytics-extensie voor Azure CLI en vereist versie 2.3.1 of hoger. De extensie wordt automatisch geïnstalleerd wanneer u de opdracht az stream-analytics input voor het eerst gebruikt. Meer informatie over extensies.
Opdrachten voor het beheren van stream-analytics-invoer.
Opdracht
| az stream-analytics input create |
Maak een invoer of vervang een bestaande invoer onder een bestaande streaming-taak. |
| az stream-analytics input delete |
Verwijder invoer van de streaming-taak. |
| az stream-analytics input list |
Vermeld alle invoer onder de opgegeven streaming-taak. |
| az stream-analytics input show |
Meer informatie over de opgegeven invoer. |
| az stream-analytics input test |
Een invoer testen. |
az stream-analytics input create
Maak een invoer of vervang een bestaande invoer onder een bestaande streaming-taak.
az stream-analytics input create --datasource
--job-name
--name
--resource-group
--serialization
--type {Reference, Stream}
Voorbeelden
Invoer maken
az stream-analytics input create --resource-group MyResourceGroup --job-name MyJobName \
--name MyInputName --type Stream --datasource @datasource.json --serialization \
@serialization.json
(below is an example of Blob Storage for "datasource.json")
{
"type": "Microsoft.Storage/Blob",
"properties": {
"storageAccounts": [
{
"accountName": "someAccountName",
"accountKey": "someAccountKey=="
}
],
"container": "state",
"pathPattern": "{date}/{time}",
"dateFormat": "yyyy/MM/dd",
"timeFormat": "HH",
"sourcePartitionCount": 16
}
}
(below is an example of Event Hub for "datasource.json")
{
"type": "Microsoft.ServiceBus/EventHub",
"properties": {
"serviceBusNamespace": "sdktest",
"sharedAccessPolicyName": "RootManageSharedAccessKey",
"sharedAccessPolicyKey": "someSharedAccessPolicyKey==",
"eventHubName": "sdkeventhub",
"consumerGroupName": "sdkconsumergroup"
}
}
(below is an example of Iot Hub for "datasource.json")
{
"type": "Microsoft.Devices/IotHubs",
"properties": {
"iotHubNamespace": "iothub",
"sharedAccessPolicyName": "owner",
"sharedAccessPolicyKey": "sharedAccessPolicyKey=",
"consumerGroupName": "sdkconsumergroup",
"endpoint": "messages/events"
}
}
(below is an example of Csv for "serialization.json")
{
"type": "Csv",
"properties": {
"fieldDelimiter": ",",
"encoding": "UTF8"
}
}
(below is an example of Json for "serialization.json")
{
"type": "Json",
"properties": {
"encoding": "UTF8"
}
}
(below is an example of Avro for "serialization.json")
{
"type": "Avro"
}
Vereiste parameters
De gegevensbron van de invoer.
De naam van de streaming-taak.
De naam van de invoer.
De naam van de resourcegroep. U kunt de standaardgroep configureren met az configure --defaults group=<name> behulp van .
De serialisatie van de invoer.
Het type invoer.
Vergroot de logboekbebossing om alle logboeken voor foutopsporing weer te geven.
Laat dit Help-bericht zien en sluit af.
Alleen fouten weergeven, waarschuwingen onderdrukken.
Uitvoerindeling.
JMESPath-queryreeks. Zie http://jmespath.org/ voor meer informatie en voorbeelden.
Vergroot de logboekverkenbaarheid. Gebruik --debug voor volledige logboeken voor foutopsporing.
az stream-analytics input delete
Verwijder invoer van de streaming-taak.
az stream-analytics input delete --job-name
--name
--resource-group
Voorbeelden
Invoer verwijderen
az stream-analytics input delete --resource-group MyResourceGroup --job-name MyJobName --name MyInputName
Vereiste parameters
De naam van de streaming-taak.
De naam van de invoer.
De naam van de resourcegroep. U kunt de standaardgroep configureren met az configure --defaults group=<name> behulp van .
Vergroot de logboekbebossing om alle logboeken voor foutopsporing weer te geven.
Laat dit Help-bericht zien en sluit af.
Alleen fouten weergeven, waarschuwingen onderdrukken.
Uitvoerindeling.
JMESPath-queryreeks. Zie http://jmespath.org/ voor meer informatie en voorbeelden.
Vergroot de logboekverkenbaarheid. Gebruik --debug voor volledige logboeken voor foutopsporing.
az stream-analytics input list
Vermeld alle invoer onder de opgegeven streaming-taak.
az stream-analytics input list --job-name
--resource-group
Voorbeelden
Alle invoer in een streaming-taak bekijken
az stream-analytics input list --resource-group MyResourceGroup --job-name MyJobName
Vereiste parameters
De naam van de streaming-taak.
De naam van de resourcegroep. U kunt de standaardgroep configureren met az configure --defaults group=<name> behulp van .
Vergroot de logboekbebossing om alle logboeken voor foutopsporing weer te geven.
Laat dit Help-bericht zien en sluit af.
Alleen fouten weergeven, waarschuwingen onderdrukken.
Uitvoerindeling.
JMESPath-queryreeks. Zie http://jmespath.org/ voor meer informatie en voorbeelden.
Vergroot de logboekverkenbaarheid. Gebruik --debug voor volledige logboeken voor foutopsporing.
az stream-analytics input show
Meer informatie over de opgegeven invoer.
az stream-analytics input show --job-name
--name
--resource-group
Voorbeelden
Details over opgegeven invoer op halen
az stream-analytics input show --resource-group MyResourceGroup --job-name MyJobName --name MyInputName
Vereiste parameters
De naam van de streaming-taak.
De naam van de invoer.
De naam van de resourcegroep. U kunt de standaardgroep configureren met az configure --defaults group=<name> behulp van .
Vergroot de logboekbebossing om alle logboeken voor foutopsporing weer te geven.
Laat dit Help-bericht zien en sluit af.
Alleen fouten weergeven, waarschuwingen onderdrukken.
Uitvoerindeling.
JMESPath-queryreeks. Zie http://jmespath.org/ voor meer informatie en voorbeelden.
Vergroot de logboekverkenbaarheid. Gebruik --debug voor volledige logboeken voor foutopsporing.
az stream-analytics input test
Een invoer testen.
az stream-analytics input test --job-name
--name
--resource-group
[--no-wait]
Voorbeelden
De verbinding voor invoer testen
az stream-analytics input test --resource-group MyResourceGroup --job-name MyJobName --name MyInputName
Vereiste parameters
De naam van de streaming-taak.
De naam van de invoer.
De naam van de resourcegroep. U kunt de standaardgroep configureren met az configure --defaults group=<name> behulp van .
Optionele parameters
Wacht niet tot de langlopende bewerking is uitgevoerd.
Vergroot de logboekbebossing om alle logboeken voor foutopsporing weer te geven.
Laat dit Help-bericht zien en sluit af.
Alleen fouten weergeven, waarschuwingen onderdrukken.
Uitvoerindeling.
JMESPath-queryreeks. Zie http://jmespath.org/ voor meer informatie en voorbeelden.
Vergroot de logboekverkenbaarheid. Gebruik --debug voor volledige logboeken voor foutopsporing.