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
A bemenet neve.
A streamelési feladat neve.
Az erőforráscsoport neve. Az alapértelmezett csoportot konfigurálhatja a következővel az configure --defaults group=<name>
: .
Opcionális paraméterek
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.
Á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.
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
Növelje a naplózás részletességét az összes hibakeresési napló megjelenítéséhez.
Jelenítse meg ezt a súgóüzenetet, és lépjen ki.
Csak a hibák megjelenítése, a figyelmeztetések mellőzése.
Kimeneti formátum.
JMESPath lekérdezési sztring. További információkért és példákért lásd http://jmespath.org/ .
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
: .
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
A bemenet neve.
A streamelési feladat neve.
Az erőforráscsoport neve. Az alapértelmezett csoportot konfigurálhatja a következővel az configure --defaults group=<name>
: .
Opcionális paraméterek
Ne kérje a megerősítést.
Globális paraméterek
Növelje a naplózás részletességét az összes hibakeresési napló megjelenítéséhez.
Jelenítse meg ezt a súgóüzenetet, és lépjen ki.
Csak a hibák megjelenítése, a figyelmeztetések mellőzése.
Kimeneti formátum.
JMESPath lekérdezési sztring. További információkért és példákért lásd http://jmespath.org/ .
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
: .
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
A streamelési feladat neve.
Az erőforráscsoport neve. Az alapértelmezett csoportot konfigurálhatja a következővel az configure --defaults group=<name>
: .
Opcionális paraméterek
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
Növelje a naplózás részletességét az összes hibakeresési napló megjelenítéséhez.
Jelenítse meg ezt a súgóüzenetet, és lépjen ki.
Csak a hibák megjelenítése, a figyelmeztetések mellőzése.
Kimeneti formátum.
JMESPath lekérdezési sztring. További információkért és példákért lásd http://jmespath.org/ .
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
: .
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
A bemenet neve.
A streamelési feladat neve.
Az erőforráscsoport neve. Az alapértelmezett csoportot konfigurálhatja a következővel az configure --defaults group=<name>
: .
Globális paraméterek
Növelje a naplózás részletességét az összes hibakeresési napló megjelenítéséhez.
Jelenítse meg ezt a súgóüzenetet, és lépjen ki.
Csak a hibák megjelenítése, a figyelmeztetések mellőzése.
Kimeneti formátum.
JMESPath lekérdezési sztring. További információkért és példákért lásd http://jmespath.org/ .
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
: .
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
A bemenet neve.
A streamelési feladat neve.
Az erőforráscsoport neve. Az alapértelmezett csoportot konfigurálhatja a következővel az configure --defaults group=<name>
: .
Opcionális paraméterek
Ne várja meg, amíg a hosszú ideig futó művelet befejeződik.
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
Növelje a naplózás részletességét az összes hibakeresési napló megjelenítéséhez.
Jelenítse meg ezt a súgóüzenetet, és lépjen ki.
Csak a hibák megjelenítése, a figyelmeztetések mellőzése.
Kimeneti formátum.
JMESPath lekérdezési sztring. További információkért és példákért lásd http://jmespath.org/ .
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
: .
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
A bemenet neve.
A streamelési feladat neve.
Az erőforráscsoport neve. Az alapértelmezett csoportot konfigurálhatja a következővel az configure --defaults group=<name>
: .
Opcionális paraméterek
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.
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
Növelje a naplózás részletességét az összes hibakeresési napló megjelenítéséhez.
Jelenítse meg ezt a súgóüzenetet, és lépjen ki.
Csak a hibák megjelenítése, a figyelmeztetések mellőzése.
Kimeneti formátum.
JMESPath lekérdezési sztring. További információkért és példákért lásd http://jmespath.org/ .
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
: .
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
A bemenet neve.
A streamelési feladat neve.
Az erőforráscsoport neve. Az alapértelmezett csoportot konfigurálhatja a következővel az configure --defaults group=<name>
: .
Opcionális paraméterek
Várjon, amíg létre nem jön a "provisioningState" a "Sikeres" helyen.
Várjon, amíg a feltétel megfelel egy egyéni JMESPath-lekérdezésnek. Pl. provisioningState!='InProgress', instanceView.statuses[?code=='PowerState/running"?.
Várjon a törlésig.
Várjon, amíg az erőforrás létezik.
Lekérdezési időköz másodpercben.
Maximális várakozás másodpercben.
Várjon, amíg frissül a provisioningState a következő helyen: "Sikeres".
Globális paraméterek
Növelje a naplózás részletességét az összes hibakeresési napló megjelenítéséhez.
Jelenítse meg ezt a súgóüzenetet, és lépjen ki.
Csak a hibák megjelenítése, a figyelmeztetések mellőzése.
Kimeneti formátum.
JMESPath lekérdezési sztring. További információkért és példákért lásd http://jmespath.org/ .
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
: .
A naplózás részletességének növelése. Használja a --debug parancsot a teljes hibakeresési naplókhoz.