Megosztás a következőn keresztül:


az stream-analytics input

Megjegyzés:

Ez a hivatkozás az Azure CLI stream-analytics bővítményének része (2.15.0-s vagy újabb verzió). A bővítmény automatikusan telepíti az az stream-analytics bemeneti parancs első futtatásakor. További információ a bővítményekről.

Bemenet kezelése streamelemzéssel.

Parancsok

Name Description Típus Állapot
az stream-analytics input create

Hozzon létre egy bemenetet, vagy cserélje le a meglévő bemenetet egy meglévő streamelési feladat alatt.

Extension FE
az stream-analytics input delete

Bemenet törlése a streamelési feladatból.

Extension FE
az stream-analytics input list

A megadott streamelési feladat összes bemenetének listázása.

Extension FE
az stream-analytics input show

A megadott bemenet részleteinek lekérése.

Extension FE
az stream-analytics input test

Tesztelje, hogy egy bemeneti adatforrás elérhető és használható-e az Azure Stream Analytics szolgáltatásban.

Extension FE
az stream-analytics input update

Meglévő bemenet frissítése egy meglévő streamelési feladat alatt. Ez egy bemenet részleges frissítésére (azaz egy vagy két tulajdonság frissítésére) használható anélkül, hogy az hatással lenne a feladat vagy a bemeneti definíció többi részére.

Extension FE
az stream-analytics input wait

Helyezze a parancssori felületet várakozási állapotba, amíg a stream-elemzési bemenet egy feltétele nem teljesül.

Extension FE

az stream-analytics input create

Hozzon létre egy bemenetet, vagy cserélje le a meglévő bemenetet egy meglévő streamelési feladat alatt.

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

Példák

Referencia blobbemenet létrehozása CSV-szerializálással

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"

Stream Event Hub-bemenet létrehozása JSON-szerializálással

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"

Stream IoT Hub-bemenet létrehozása Avro szerializálással

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"

Streamblob-bemenet létrehozása CSV-szerializálással

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"

Kötelező paraméterek

--input-name --name -n

A bemenet neve.

--job-name

A streamelési feladat neve.

--resource-group -g

Az erőforráscsoport neve. Az alapértelmezett csoportot konfigurálhatja a következővel az configure --defaults group=<name>: .

Opcionális paraméterek

--if-match

A bemenet ETagje. Hagyja ki ezt az értéket, hogy mindig felülírja az aktuális bemenetet. Adja meg az utolsóként látott ETag értéket, hogy megakadályozza az egyidejű módosítások véletlen felülírását.

--if-none-match

Állítsa a "*" értéket egy új bemenet létrehozásához, de a meglévő bemenetek frissítésének megakadályozásához. Más értékek esetén 412 előfeltétel meghiúsult válasz jelenik meg.

--properties

A bemenethez társított tulajdonságok. PUT (CreateOrReplace) kérelmekhez szükséges. Várt érték: json-string/json-file/@json-file.

Globális paraméterek
--debug

Növelje a naplózás részletességét az összes hibakeresési napló megjelenítéséhez.

--help -h

Jelenítse meg ezt a súgóüzenetet, és lépjen ki.

--only-show-errors

Csak a hibák megjelenítése, a figyelmeztetések mellőzése.

--output -o

Kimeneti formátum.

elfogadott értékek: json, jsonc, none, table, tsv, yaml, yamlc
alapértelmezett érték: json
--query

JMESPath lekérdezési sztring. További információkért és példákért lásd http://jmespath.org/ .

--subscription

Az előfizetés neve vagy azonosítója. Az alapértelmezett előfizetést konfigurálhatja a következővel az account set -s NAME_OR_ID: .

--verbose

A naplózás részletességének növelése. Használja a --debug parancsot a teljes hibakeresési naplókhoz.

az stream-analytics input delete

Bemenet törlése a streamelési feladatból.

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

Példák

Bemenet törlése

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

Kötelező paraméterek

--input-name --name -n

A bemenet neve.

--job-name

A streamelési feladat neve.

--resource-group -g

Az erőforráscsoport neve. Az alapértelmezett csoportot konfigurálhatja a következővel az configure --defaults group=<name>: .

Opcionális paraméterek

--yes -y

Ne kérje a megerősítést.

alapértelmezett érték: False
Globális paraméterek
--debug

Növelje a naplózás részletességét az összes hibakeresési napló megjelenítéséhez.

--help -h

Jelenítse meg ezt a súgóüzenetet, és lépjen ki.

--only-show-errors

Csak a hibák megjelenítése, a figyelmeztetések mellőzése.

--output -o

Kimeneti formátum.

elfogadott értékek: json, jsonc, none, table, tsv, yaml, yamlc
alapértelmezett érték: json
--query

JMESPath lekérdezési sztring. További információkért és példákért lásd http://jmespath.org/ .

--subscription

Az előfizetés neve vagy azonosítója. Az alapértelmezett előfizetést konfigurálhatja a következővel az account set -s NAME_OR_ID: .

--verbose

A naplózás részletességének növelése. Használja a --debug parancsot a teljes hibakeresési naplókhoz.

az stream-analytics input list

A megadott streamelési feladat összes bemenetének listázása.

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

Példák

Streamelési feladat összes bemenetének listázása

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

A streamelési feladat összes bemenetének listázása és diagnosztikai adatok belefoglalása az $select OData lekérdezési paraméter használatával

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

Kötelező paraméterek

--job-name

A streamelési feladat neve.

--resource-group -g

Az erőforráscsoport neve. Az alapértelmezett csoportot konfigurálhatja a következővel az configure --defaults group=<name>: .

Opcionális paraméterek

--select

Az $select OData lekérdezési paraméter. Ez a válaszban szerepeltetni kívánt szerkezeti tulajdonságok vesszővel tagolt listája, vagy "" az összes tulajdonság belefoglalásához. Alapértelmezés szerint a rendszer a diagnosztika kivételével minden tulajdonságot visszaad. Jelenleg csak érvényes értékként fogadja el a "" értéket.

Globális paraméterek
--debug

Növelje a naplózás részletességét az összes hibakeresési napló megjelenítéséhez.

--help -h

Jelenítse meg ezt a súgóüzenetet, és lépjen ki.

--only-show-errors

Csak a hibák megjelenítése, a figyelmeztetések mellőzése.

--output -o

Kimeneti formátum.

elfogadott értékek: json, jsonc, none, table, tsv, yaml, yamlc
alapértelmezett érték: json
--query

JMESPath lekérdezési sztring. További információkért és példákért lásd http://jmespath.org/ .

--subscription

Az előfizetés neve vagy azonosítója. Az alapértelmezett előfizetést konfigurálhatja a következővel az account set -s NAME_OR_ID: .

--verbose

A naplózás részletességének növelése. Használja a --debug parancsot a teljes hibakeresési naplókhoz.

az stream-analytics input show

A megadott bemenet részleteinek lekérése.

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

Példák

Referencia blobbemenet lekérése CSV-szerializálással

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

Stream Event Hub-bemenet lekérése JSON-szerializálással

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

Stream IoT Hub-bemenet lekérése Avro szerializálással

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

Stream blobbemenet lekérése CSV-szerializálással

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

Kötelező paraméterek

--input-name --name -n

A bemenet neve.

--job-name

A streamelési feladat neve.

--resource-group -g

Az erőforráscsoport neve. Az alapértelmezett csoportot konfigurálhatja a következővel az configure --defaults group=<name>: .

Globális paraméterek
--debug

Növelje a naplózás részletességét az összes hibakeresési napló megjelenítéséhez.

--help -h

Jelenítse meg ezt a súgóüzenetet, és lépjen ki.

--only-show-errors

Csak a hibák megjelenítése, a figyelmeztetések mellőzése.

--output -o

Kimeneti formátum.

elfogadott értékek: json, jsonc, none, table, tsv, yaml, yamlc
alapértelmezett érték: json
--query

JMESPath lekérdezési sztring. További információkért és példákért lásd http://jmespath.org/ .

--subscription

Az előfizetés neve vagy azonosítója. Az alapértelmezett előfizetést konfigurálhatja a következővel az account set -s NAME_OR_ID: .

--verbose

A naplózás részletességének növelése. Használja a --debug parancsot a teljes hibakeresési naplókhoz.

az stream-analytics input test

Tesztelje, hogy egy bemeneti adatforrás elérhető és használható-e az Azure Stream Analytics szolgáltatásban.

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

Példák

Bemenet kapcsolatának tesztelése

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

Kötelező paraméterek

--input-name --name -n

A bemenet neve.

--job-name

A streamelési feladat neve.

--resource-group -g

Az erőforráscsoport neve. Az alapértelmezett csoportot konfigurálhatja a következővel az configure --defaults group=<name>: .

Opcionális paraméterek

--no-wait

Ne várja meg, amíg a hosszú ideig futó művelet befejeződik.

alapértelmezett érték: False
--properties

A bemenethez társított tulajdonságok. PUT (CreateOrReplace) kérelmekhez szükséges. Várt érték: json-string/json-file/@json-file.

Globális paraméterek
--debug

Növelje a naplózás részletességét az összes hibakeresési napló megjelenítéséhez.

--help -h

Jelenítse meg ezt a súgóüzenetet, és lépjen ki.

--only-show-errors

Csak a hibák megjelenítése, a figyelmeztetések mellőzése.

--output -o

Kimeneti formátum.

elfogadott értékek: json, jsonc, none, table, tsv, yaml, yamlc
alapértelmezett érték: json
--query

JMESPath lekérdezési sztring. További információkért és példákért lásd http://jmespath.org/ .

--subscription

Az előfizetés neve vagy azonosítója. Az alapértelmezett előfizetést konfigurálhatja a következővel az account set -s NAME_OR_ID: .

--verbose

A naplózás részletességének növelése. Használja a --debug parancsot a teljes hibakeresési naplókhoz.

az stream-analytics input update

Meglévő bemenet frissítése egy meglévő streamelési feladat alatt. Ez egy bemenet részleges frissítésére (azaz egy vagy két tulajdonság frissítésére) használható anélkül, hogy az hatással lenne a feladat vagy a bemeneti definíció többi részére.

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

Példák

Hivatkozási blob bemenetének frissítése

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"

Stream Event Hub-bemenet frissítése

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"

Stream IoT Hub-bemenet frissítése

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"

Streamblob bemenetének frissítése

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"

Kötelező paraméterek

--input-name --name -n

A bemenet neve.

--job-name

A streamelési feladat neve.

--resource-group -g

Az erőforráscsoport neve. Az alapértelmezett csoportot konfigurálhatja a következővel az configure --defaults group=<name>: .

Opcionális paraméterek

--if-match

A bemenet ETagje. Hagyja ki ezt az értéket, hogy mindig felülírja az aktuális bemenetet. Adja meg az utolsóként látott ETag értéket, hogy megakadályozza az egyidejű módosítások véletlen felülírását.

--properties

A bemenethez társított tulajdonságok. PUT (CreateOrReplace) kérelmekhez szükséges. Várt érték: json-string/json-file/@json-file.

Globális paraméterek
--debug

Növelje a naplózás részletességét az összes hibakeresési napló megjelenítéséhez.

--help -h

Jelenítse meg ezt a súgóüzenetet, és lépjen ki.

--only-show-errors

Csak a hibák megjelenítése, a figyelmeztetések mellőzése.

--output -o

Kimeneti formátum.

elfogadott értékek: json, jsonc, none, table, tsv, yaml, yamlc
alapértelmezett érték: json
--query

JMESPath lekérdezési sztring. További információkért és példákért lásd http://jmespath.org/ .

--subscription

Az előfizetés neve vagy azonosítója. Az alapértelmezett előfizetést konfigurálhatja a következővel az account set -s NAME_OR_ID: .

--verbose

A naplózás részletességének növelése. Használja a --debug parancsot a teljes hibakeresési naplókhoz.

az stream-analytics input wait

Helyezze a parancssori felületet várakozási állapotba, amíg a stream-elemzési bemenet egy feltétele nem teljesül.

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

Példák

A parancssori felület következő sorának futtatását szüneteltetheti, amíg a stream-elemzési bemenet sikeresen létre nem jön.

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

Kötelező paraméterek

--input-name --name -n

A bemenet neve.

--job-name

A streamelési feladat neve.

--resource-group -g

Az erőforráscsoport neve. Az alapértelmezett csoportot konfigurálhatja a következővel az configure --defaults group=<name>: .

Opcionális paraméterek

--created

Várjon, amíg létre nem jön a "provisioningState" a "Sikeres" helyen.

alapértelmezett érték: False
--custom

Várjon, amíg a feltétel megfelel egy egyéni JMESPath-lekérdezésnek. Pl. provisioningState!='InProgress', instanceView.statuses[?code=='PowerState/running"?.

--deleted

Várjon a törlésig.

alapértelmezett érték: False
--exists

Várjon, amíg az erőforrás létezik.

alapértelmezett érték: False
--interval

Lekérdezési időköz másodpercben.

alapértelmezett érték: 30
--timeout

Maximális várakozás másodpercben.

alapértelmezett érték: 3600
--updated

Várjon, amíg frissül a provisioningState a következő helyen: "Sikeres".

alapértelmezett érték: False
Globális paraméterek
--debug

Növelje a naplózás részletességét az összes hibakeresési napló megjelenítéséhez.

--help -h

Jelenítse meg ezt a súgóüzenetet, és lépjen ki.

--only-show-errors

Csak a hibák megjelenítése, a figyelmeztetések mellőzése.

--output -o

Kimeneti formátum.

elfogadott értékek: json, jsonc, none, table, tsv, yaml, yamlc
alapértelmezett érték: json
--query

JMESPath lekérdezési sztring. További információkért és példákért lásd http://jmespath.org/ .

--subscription

Az előfizetés neve vagy azonosítója. Az alapértelmezett előfizetést konfigurálhatja a következővel az account set -s NAME_OR_ID: .

--verbose

A naplózás részletességének növelése. Használja a --debug parancsot a teljes hibakeresési naplókhoz.