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 input parancs első futtatásakor. További információ a bővítményekről.
Bemenetek kezelése Stream Analytics használatával.
Parancsok
| az stream-analytics input create |
Hozzon létre egy bemenetet, vagy cserélje le a már meglévő bemenetet egy meglévő streamelési feladat alatt. |
| az stream-analytics input delete |
Bemenet törlése a streamelési feladatból. |
| az stream-analytics input list |
Listázni kell a megadott streamelési feladat összes bemenetét. |
| az stream-analytics input show |
A megadott bemenet részleteinek lekérése. |
| 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 update |
Meglévő bemenet frissítése 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 ez hatással lenne a feladat vagy a bemeneti definíció többi részére. |
| az stream-analytics input wait |
Helyezze a parancssori felületet várakozó állapotba, amíg a Stream-Analytics-bemenet egy feltétele nem teljesül. |
az stream-analytics input create
Hozzon létre egy bemenetet, vagy cserélje le a már 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 a használatával az configure --defaults group=<name>konfigurálhatja.
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átható ETag-értéket, hogy megakadályozza az egyidejű módosítások véletlen felülírását.
A "*" értékre állítva új bemenetet lehet létrehozni, de a meglévő bemenetek frissítésének megakadályozása érdekében. Más értékek esetén a 412 előfeltétel sikertelen válasza lesz.
A bemenethez társított tulajdonságok. PUT (CreateOrReplace) kérelmekhez szükséges. Várt érték: json-string/json-file/@json-file.
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 a használatával az account set -s NAME_OR_IDkonfigurálhatja.
Növelje a naplózás részletességét. 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 a használatával az configure --defaults group=<name>konfigurálhatja.
Opcionális paraméterek
Ne kérje a megerősítést.
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 a használatával az account set -s NAME_OR_IDkonfigurálhatja.
Növelje a naplózás részletességét. Használja a --debug parancsot a teljes hibakeresési naplókhoz.
az stream-analytics input list
Listázni kell a megadott streamelési feladat összes bemenetét.
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 a $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 a használatával az configure --defaults group=<name>konfigurálhatja.
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, a "*" pedig az összes tulajdonságot tartalmazza. Alapértelmezés szerint a rendszer a diagnosztika kivételével minden tulajdonságot visszaad. Jelenleg csak a *értéket fogadja el érvényes értékként.
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 a használatával az account set -s NAME_OR_IDkonfigurálhatja.
Növelje a naplózás részletességét. 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
Referenciablob bemenetének 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"
Streamblob bemenetének 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 a használatával az configure --defaults group=<name>konfigurálhatja.
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 a használatával az account set -s NAME_OR_IDkonfigurálhatja.
Növelje a naplózás részletességét. 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 a használatával az configure --defaults group=<name>konfigurálhatja.
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.
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 a használatával az account set -s NAME_OR_IDkonfigurálhatja.
Növelje a naplózás részletességét. Használja a --debug parancsot a teljes hibakeresési naplókhoz.
az stream-analytics input update
Meglévő bemenet frissítése 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 ez 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
Referenciablob 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 a használatával az configure --defaults group=<name>konfigurálhatja.
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átható 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.
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 a használatával az account set -s NAME_OR_IDkonfigurálhatja.
Növelje a naplózás részletességét. Használja a --debug parancsot a teljes hibakeresési naplókhoz.
az stream-analytics input wait
Helyezze a parancssori felületet várakozó állapotba, amíg a Stream-Analytics-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 következő parancssori felületi szkript végrehajtásának felfüggesztése a Stream-Analytics-bemenet sikeres létrehozásához.
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 a használatával az configure --defaults group=<name>konfigurálhatja.
Opcionális paraméterek
Várjon, amíg létre nem jön a "provisioningState" paraméter a "Succeeded" (Sikeres) állapotban.
Várja meg, amíg a feltétel megfelel egy egyéni JMESPath-lekérdezésnek. Például 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 paraméterrel a "Succeeded" (Sikeres) időpontban.
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 a használatával az account set -s NAME_OR_IDkonfigurálhatja.
Növelje a naplózás részletességét. Használja a --debug parancsot a teljes hibakeresési naplókhoz.
Visszajelzés
Visszajelzés küldése és megtekintése a következőhöz: