az stream-analytics job
Feljegyzé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 feladatparancs első futtatásakor. További információ a bővítményekről.
Stream-elemzéssel kezelheti a streamelési feladatot.
Parancsok
Name | Description | Típus | Állapot |
---|---|---|---|
az stream-analytics job create |
Streamelési feladat létrehozása vagy egy már meglévő streamelési feladat lecserélése. |
Mellék | FE |
az stream-analytics job delete |
Streamelési feladat törlése. |
Mellék | FE |
az stream-analytics job list |
A megadott erőforráscsoport összes streamelési feladatának listázása. És felsorolja az adott előfizetés összes streamelési feladatát. |
Mellék | FE |
az stream-analytics job scale |
Streamelési feladat skálázása a feladat futtatásakor. |
Mellék | FE |
az stream-analytics job show |
A megadott streamelési feladat részleteinek lekérése. |
Mellék | FE |
az stream-analytics job start |
Streamelési feladat indítása. A feladat elindítása után megkezdi a bemeneti események feldolgozását és a kimenet előállítását. |
Mellék | FE |
az stream-analytics job stop |
Futó streamelési feladat leállítása. Ez azt eredményezi, hogy egy futó streamelési feladat leállítja a bemeneti események feldolgozását és a kimenet előállítását. |
Mellék | FE |
az stream-analytics job update |
Meglévő streamelési feladat frissítése. Ez egy streamelési feladat részleges frissítésére (azaz egy vagy két tulajdonság frissítésére) használható anélkül, hogy a feladat definíciója hatással lenne a többire. |
Mellék | FE |
az stream-analytics job wait |
Helyezze a parancssori felületet várakozási állapotba, amíg a stream-elemzési feladat egy állapota meg nem teljesül. |
Mellék | FE |
az stream-analytics job create
Streamelési feladat létrehozása vagy egy már meglévő streamelési feladat lecserélése.
az stream-analytics job create --job-name
--resource-group
[--arrival-max-delay]
[--compatibility-level {1.0, 1.2}]
[--content-storage-policy {JobStorageAccount, SystemAccount}]
[--data-locale]
[--functions]
[--id]
[--identity]
[--if-match]
[--if-none-match]
[--inputs]
[--job-storage-account]
[--job-type {Cloud, Edge}]
[--location]
[--no-wait]
[--order-max-delay]
[--out-of-order-policy {Adjust, Drop}]
[--output-error-policy {Drop, Stop}]
[--output-start-mode {CustomTime, JobStartTime, LastOutputEventTime}]
[--output-start-time]
[--outputs]
[--tags]
[--transformation]
Példák
Teljes streamelési feladat létrehozása (átalakítással, legalább 1 bemenettel és legalább 1 kimenettel rendelkező streamelési feladat)
az stream-analytics job create --job-name "sj7804" --resource-group "sjrg3276" --location "West US" --compatibility-level "1.0" --data-locale "en-US" --arrival-max-delay 5 --order-max-delay 0 --out-of-order-policy "Drop" --functions "[]" --inputs "[{\"name\":\"inputtest\",\"properties\":{\"type\":\"Stream\",\"datasource\":{\"type\":\"Microsoft.Storage/Blob\",\"properties\":{\"container\":\"containerName\",\"pathPattern\":\"\",\"storageAccounts\":[{\"accountKey\":\"yourAccountKey==\",\"accountName\":\"yourAccountName\"}]}},\"serialization\":{\"type\":\"Json\",\"properties\":{\"encoding\":\"UTF8\"}}}}]" --output-error-policy "Drop" --outputs "[{\"name\":\"outputtest\",\"datasource\":{\"type\":\"Microsoft.Sql/Server/Database\",\"properties\":{\"database\":\"databaseName\",\"password\":\"userPassword\",\"server\":\"serverName\",\"table\":\"tableName\",\"user\":\"<user>\"}}}]" --transformation name="transformationtest" streaming-units=1 query="Select Id, Name from inputtest" --tags key1="value1" key3="value3" randomKey="randomValue"
Streamelési feladathéj létrehozása (bemenetek, kimenetek, átalakítás vagy függvények nélküli streamelési feladat)
az stream-analytics job create --job-name "sj59" --resource-group "sjrg6936" --location "West US" --compatibility-level "1.0" --data-locale "en-US" --arrival-max-delay 16 --order-max-delay 5 --out-of-order-policy "Drop" --functions "[]" --inputs "[]" --output-error-policy "Drop" --outputs "[]" --tags key1="value1" key3="value3" randomKey="randomValue"
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
A maximális elviselhető késleltetés másodpercekben, amikor a késői események is belefoglalhatók. A támogatott tartomány -1 és 1814399 (20.23:59:59 nap), a -1 pedig a határozatlan idejű várakozás megadására szolgál. Ha a tulajdonság hiányzik, a rendszer úgy értelmezi, hogy értéke -1.
Szabályozza a streamelési feladat futásidejének bizonyos viselkedését.
Az érvényes értékek a JobStorageAccount és a SystemAccount. Ha a JobStorageAccount értékre van állítva, a felhasználónak meg kell adnia a jobStorageAccount tulajdonságot is. .
A streamelemzési feladat adat területi beállítása. Az értéknek a készletből https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspxszármazó támogatott .NET-kultúra neve kell legyen. Alapértelmezés szerint "en-US", ha nincs megadva.
A streamelési feladat egy vagy több függvényének listája. Az egyes függvények névtulajdonságára szükség van a tulajdonság PUT-kérelemben való megadásakor. Ez a tulajdonság patch művelettel nem módosítható. Az egyes átalakításokhoz elérhető PATCH API-t kell használnia. Várt érték: json-string/json-file/@json-file.
A fürt erőforrás-azonosítója.
Ismertesse a feladathoz hozzárendelt, rendszer által hozzárendelt felügyelt identitást, amely bemenetekkel és kimenetekkel való hitelesítésre használható.
Használat: --identity tenant-id=XX principal-id=XX type=XX
tenant-id: The identity tenantId principal-id: The identity principal ID type: The identity type.
A streamelési feladat ETagje. Hagyja ki ezt az értéket, hogy mindig felülírja az aktuális rekordhalmazt. 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 streamelési feladat létrehozásához, de egy meglévő rekordkészlet 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 streamelési feladat egy vagy több bemenetének listája. A tulajdonság PUT-kérelemben való megadásakor minden bemenethez meg kell adni a névtulajdonságot. Ez a tulajdonság patch művelettel nem módosítható. Az egyes bemenetekhez elérhető PATCH API-t kell használnia. Várt érték: json-string/json-file/@json-file.
Az MSI-vel rendelkező Azure Storage-fiókhoz társított tulajdonságok.
Használat: --job-storage-account authentication-mode=XX account-name=XX account-key=XX
hitelesítési mód: Hitelesítési mód. fiók neve: Az Azure Storage-fiók neve. PUT (CreateOrReplace) kérelmekhez szükséges. fiókkulcs: Az Azure Storage-fiók fiókkulcsa. PUT (CreateOrReplace) kérelmekhez szükséges.
A feladat típusát ismerteti. Az érvényes módok az Cloud
"Edge" és az "Edge".
Tartózkodási hely beállításnál. Értékek: az account list-locations
. Az alapértelmezett helyet a következővel az configure --defaults location=<location>
konfigurálhatja: .
Ne várja meg, amíg a hosszú ideig futó művelet befejeződik.
A maximális elviselhető késleltetés másodpercekben, amikor a rendelésen kívüli események állíthatók vissza a sorrendbe.
A bemeneti eseményfolyamban sorrendből érkező eseményekre alkalmazandó szabályzatot jelzi.
Azt a házirendet jelzi, amely a kimenetre érkező eseményekre vonatkozik, és nem írható a külső tárolóba helytelen formázás miatt (hiányzó oszlopértékek, helytelen típusú vagy méretű oszlopértékek).
Ezt a tulajdonságot csak akkor szabad használni, ha azt szeretné, hogy a feladat azonnal elinduljon a létrehozáskor. Az érték lehet JobStartTime, CustomTime vagy LastOutputEventTime, amely jelzi, hogy a kimeneti eseményfolyam kezdőpontja a feladat indításakor induljon el, a outputStartTime tulajdonságon keresztül megadott egyéni felhasználói időbélyeggel kezdődjön, vagy az utolsó eseménykimeneti időponttól induljon.
Az érték egy ISO-8601 formátumú időbélyeg, amely a kimeneti eseményfolyam kezdőpontját jelzi, vagy null érték, amely azt jelzi, hogy a kimeneti eseményfolyam a streamelési feladat indításakor elindul. Ennek a tulajdonságnak értékkel kell rendelkeznie, ha az outputStartMode értéke CustomTime.
A streamelési feladat egy vagy több kimenetének listája. A tulajdonság PUT-kérelemben való megadásakor minden kimenethez meg kell adni a névtulajdonságot. Ez a tulajdonság patch művelettel nem módosítható. Az egyes kimenetekhez elérhető PATCH API-t kell használnia. Várt érték: json-string/json-file/@json-file.
Szóközzel elválasztott címkék: key[=value] [key[=value] ...]. Meglévő címkék törlése a "" használatával.
Adja meg a lekérdezést és a streamelési feladathoz használni kívánt streamegységek számát. A tulajdonság PUT-kérelemben való megadásakor az átalakítás névtulajdonsága szükséges. Ez a tulajdonság patch művelettel nem módosítható. Az egyes átalakításokhoz elérhető PATCH API-t kell használnia.
Használat: --transformation streaming-units=XX valid-streaming-units=XX query=XX name=XX
streamelési egységek: A streamelési feladat által használt streamelési egységek számát adja meg. valid-streaming-units: Megadja azokat az érvényes streamelési egységeket, amelyeket a streamelési feladatok méretezhetnek. lekérdezés: A streamelési feladatban futtatandó lekérdezést adja meg. A Stream Analytics lekérdezési nyelvéről (SAQL) itt tudhat meg többet: https://msdn.microsoft.com/library/azure/dn834998 . PUT (CreateOrReplace) kérelmekhez szükséges. név: Erőforrás neve.
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 job delete
Streamelési feladat törlése.
az stream-analytics job delete --job-name
--resource-group
[--no-wait]
[--yes]
Példák
Streamelési feladat törlése
az stream-analytics job delete --job-name "sj59" --resource-group "sjrg6936"
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
Ne várja meg, amíg a hosszú ideig futó művelet befejeződik.
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 job list
A megadott erőforráscsoport összes streamelési feladatának listázása. És felsorolja az adott előfizetés összes streamelési feladatát.
az stream-analytics job list [--expand]
[--resource-group]
Példák
Az erőforráscsoport összes streamelési feladatának listázása, és ne használja a $expand OData lekérdezési paramétert
az stream-analytics job list --resource-group "sjrg6936"
Az erőforráscsoport összes streamelési feladatának listázása és a $expand OData lekérdezési paraméter használata bemenetek, kimenetek, átalakítás és függvények kibontásához
az stream-analytics job list --expand "inputs,outputs,transformation,functions" --resource-group "sjrg3276"
Az előfizetés összes streamelési feladatának listázása, és ne használja az $expand OData lekérdezési paramétert
az stream-analytics job list
Listázhatja az előfizetés összes streamelési feladatát, és az $expand OData lekérdezési paraméterrel bővítheti a bemeneteket, kimeneteket, átalakításokat és függvényeket
az stream-analytics job list --expand "inputs,outputs,transformation,functions"
Opcionális paraméterek
Az $expand OData lekérdezési paraméter. Ez egy vesszővel tagolt lista a válaszba belefoglalandó további streamelési feladatok tulajdonságairól, a paraméter távolléte esetén visszaadott alapértelmezett beállításon túl. Az alapértelmezett készlet a "bemenetek", az "átalakítás", a "kimenetek" és a "függvények" kivételével az összes streamelési feladattulajdonsá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
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 job scale
Streamelési feladat skálázása a feladat futtatásakor.
az stream-analytics job scale --job-name
--resource-group
[--no-wait]
[--streaming-units]
Példák
Streamelési feladat skálázása
az stream-analytics job scale --job-name "sj59" --resource-group "sjrg6936" --streaming-units 36
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
Ne várja meg, amíg a hosszú ideig futó művelet befejeződik.
Megadja, hogy a streamelési feladat hány streamegységre méretezhető.
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 job show
A megadott streamelési feladat részleteinek lekérése.
az stream-analytics job show --job-name
--resource-group
[--expand]
Példák
Streamelési feladat lekérése, és ne használja a $expand OData lekérdezési paramétert
az stream-analytics job show --job-name "sj59" --resource-group "sjrg6936"
Streamelési feladat lekérése és a $expand OData lekérdezési paraméter használata bemenetek, kimenetek, átalakítás és függvények kibontásához
az stream-analytics job show --expand "inputs,outputs,transformation,functions" --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 $expand OData lekérdezési paraméter. Ez egy vesszővel tagolt lista a válaszba belefoglalandó további streamelési feladatok tulajdonságairól, a paraméter távolléte esetén visszaadott alapértelmezett beállításon túl. Az alapértelmezett készlet a "bemenetek", az "átalakítás", a "kimenetek" és a "függvények" kivételével az összes streamelési feladattulajdonság.
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 job start
Streamelési feladat indítása. A feladat elindítása után megkezdi a bemeneti események feldolgozását és a kimenet előállítását.
az stream-analytics job start --job-name
--resource-group
[--no-wait]
[--output-start-mode {CustomTime, JobStartTime, LastOutputEventTime}]
[--output-start-time]
Példák
Streamelési feladat indítása CustomTime kimeneti indítási móddal
az stream-analytics job start --job-name "sj59" --resource-group "sjrg6936" --output-start-mode "CustomTime" --output-start-time "2012-12-12T12:12:12Z"
Streamelési feladat indítása a JobStartTime kimeneti indítási módjával
az stream-analytics job start --job-name "sj59" --resource-group "sjrg6936" --output-start-mode "JobStartTime"
Streamelési feladat indítása LastOutputEventTime kimeneti indítási móddal
az stream-analytics job start --job-name "sj59" --resource-group "sjrg6936" --output-start-mode "LastOutputEventTime"
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
Ne várja meg, amíg a hosszú ideig futó művelet befejeződik.
Az érték lehet JobStartTime, CustomTime vagy LastOutputEventTime, amely jelzi, hogy a kimeneti eseményfolyam kezdőpontja a feladat indításakor induljon el, a outputStartTime tulajdonságon keresztül megadott egyéni felhasználói időbélyeggel kezdődjön, vagy az utolsó eseménykimeneti időponttól induljon.
Az érték egy ISO-8601 formátumú időbélyeg, amely a kimeneti eseményfolyam kezdőpontját jelzi, vagy null érték, amely azt jelzi, hogy a kimeneti eseményfolyam a streamelési feladat indításakor elindul. Ennek a tulajdonságnak értékkel kell rendelkeznie, ha az outputStartMode értéke CustomTime.
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 job stop
Futó streamelési feladat leállítása. Ez azt eredményezi, hogy egy futó streamelési feladat leállítja a bemeneti események feldolgozását és a kimenet előállítását.
az stream-analytics job stop --job-name
--resource-group
[--no-wait]
Példák
Streamelési feladat leállítása
az stream-analytics job stop --job-name "sj59" --resource-group "sjrg6936"
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
Ne várja meg, amíg a hosszú ideig futó művelet befejeződik.
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 job update
Meglévő streamelési feladat frissítése. Ez egy streamelési feladat részleges frissítésére (azaz egy vagy két tulajdonság frissítésére) használható anélkül, hogy a feladat definíciója hatással lenne a többire.
az stream-analytics job update --job-name
--resource-group
[--arrival-max-delay]
[--compatibility-level {1.0, 1.2}]
[--content-storage-policy {JobStorageAccount, SystemAccount}]
[--data-locale]
[--functions]
[--id]
[--identity]
[--if-match]
[--inputs]
[--job-storage-account]
[--job-type {Cloud, Edge}]
[--location]
[--order-max-delay]
[--out-of-order-policy {Adjust, Drop}]
[--output-error-policy {Drop, Stop}]
[--output-start-mode {CustomTime, JobStartTime, LastOutputEventTime}]
[--output-start-time]
[--outputs]
[--tags]
[--transformation]
Példák
Streamelési feladat frissítése
az stream-analytics job update --job-name "sj59" --resource-group "sjrg6936" --arrival-max-delay 13 --order-max-delay 21
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
A maximális elviselhető késleltetés másodpercekben, amikor a késői események is belefoglalhatók. A támogatott tartomány -1 és 1814399 (20.23:59:59 nap), a -1 pedig a határozatlan idejű várakozás megadására szolgál. Ha a tulajdonság hiányzik, a rendszer úgy értelmezi, hogy értéke -1.
Szabályozza a streamelési feladat futásidejének bizonyos viselkedését.
Az érvényes értékek a JobStorageAccount és a SystemAccount. Ha a JobStorageAccount értékre van állítva, a felhasználónak meg kell adnia a jobStorageAccount tulajdonságot is. .
A streamelemzési feladat adat területi beállítása. Az értéknek a készletből https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspxszármazó támogatott .NET-kultúra neve kell legyen. Alapértelmezés szerint "en-US", ha nincs megadva.
A streamelési feladat egy vagy több függvényének listája. Az egyes függvények névtulajdonságára szükség van a tulajdonság PUT-kérelemben való megadásakor. Ez a tulajdonság patch művelettel nem módosítható. Az egyes átalakításokhoz elérhető PATCH API-t kell használnia. Várt érték: json-string/json-file/@json-file.
A fürt erőforrás-azonosítója.
Ismertesse a feladathoz hozzárendelt, rendszer által hozzárendelt felügyelt identitást, amely bemenetekkel és kimenetekkel való hitelesítésre használható.
Használat: --identity tenant-id=XX principal-id=XX type=XX
tenant-id: The identity tenantId principal-id: The identity principal ID type: The identity type.
A streamelési feladat ETagje. Hagyja ki ezt az értéket, hogy mindig felülírja az aktuális rekordhalmazt. 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 streamelési feladat egy vagy több bemenetének listája. A tulajdonság PUT-kérelemben való megadásakor minden bemenethez meg kell adni a névtulajdonságot. Ez a tulajdonság patch művelettel nem módosítható. Az egyes bemenetekhez elérhető PATCH API-t kell használnia. Várt érték: json-string/json-file/@json-file.
Az MSI-vel rendelkező Azure Storage-fiókhoz társított tulajdonságok.
Használat: --job-storage-account authentication-mode=XX account-name=XX account-key=XX
hitelesítési mód: Hitelesítési mód. fiók neve: Az Azure Storage-fiók neve. PUT (CreateOrReplace) kérelmekhez szükséges. fiókkulcs: Az Azure Storage-fiók fiókkulcsa. PUT (CreateOrReplace) kérelmekhez szükséges.
A feladat típusát ismerteti. Az érvényes módok az Cloud
"Edge" és az "Edge".
Tartózkodási hely beállításnál. Értékek: az account list-locations
. Az alapértelmezett helyet a következővel az configure --defaults location=<location>
konfigurálhatja: .
A maximális elviselhető késleltetés másodpercekben, amikor a rendelésen kívüli események állíthatók vissza a sorrendbe.
A bemeneti eseményfolyamban sorrendből érkező eseményekre alkalmazandó szabályzatot jelzi.
Azt a házirendet jelzi, amely a kimenetre érkező eseményekre vonatkozik, és nem írható a külső tárolóba helytelen formázás miatt (hiányzó oszlopértékek, helytelen típusú vagy méretű oszlopértékek).
Ezt a tulajdonságot csak akkor szabad használni, ha azt szeretné, hogy a feladat azonnal elinduljon a létrehozáskor. Az érték lehet JobStartTime, CustomTime vagy LastOutputEventTime, amely jelzi, hogy a kimeneti eseményfolyam kezdőpontja a feladat indításakor induljon el, a outputStartTime tulajdonságon keresztül megadott egyéni felhasználói időbélyeggel kezdődjön, vagy az utolsó eseménykimeneti időponttól induljon.
Az érték egy ISO-8601 formátumú időbélyeg, amely a kimeneti eseményfolyam kezdőpontját jelzi, vagy null érték, amely azt jelzi, hogy a kimeneti eseményfolyam a streamelési feladat indításakor elindul. Ennek a tulajdonságnak értékkel kell rendelkeznie, ha az outputStartMode értéke CustomTime.
A streamelési feladat egy vagy több kimenetének listája. A tulajdonság PUT-kérelemben való megadásakor minden kimenethez meg kell adni a névtulajdonságot. Ez a tulajdonság patch művelettel nem módosítható. Az egyes kimenetekhez elérhető PATCH API-t kell használnia. Várt érték: json-string/json-file/@json-file.
Szóközzel elválasztott címkék: key[=value] [key[=value] ...]. Meglévő címkék törlése a "" használatával.
Adja meg a lekérdezést és a streamelési feladathoz használni kívánt streamegységek számát. A tulajdonság PUT-kérelemben való megadásakor az átalakítás névtulajdonsága szükséges. Ez a tulajdonság patch művelettel nem módosítható. Az egyes átalakításokhoz elérhető PATCH API-t kell használnia.
Használat: --transformation streaming-units=XX valid-streaming-units=XX query=XX name=XX
streamelési egységek: A streamelési feladat által használt streamelési egységek számát adja meg. valid-streaming-units: Megadja azokat az érvényes streamelési egységeket, amelyeket a streamelési feladatok méretezhetnek. lekérdezés: A streamelési feladatban futtatandó lekérdezést adja meg. A Stream Analytics lekérdezési nyelvéről (SAQL) itt tudhat meg többet: https://msdn.microsoft.com/library/azure/dn834998 . PUT (CreateOrReplace) kérelmekhez szükséges. név: Erőforrás neve.
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 job wait
Helyezze a parancssori felületet várakozási állapotba, amíg a stream-elemzési feladat egy állapota meg nem teljesül.
az stream-analytics job wait --job-name
--resource-group
[--created]
[--custom]
[--deleted]
[--exists]
[--expand]
[--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 feladat sikeresen létre nem jön.
az stream-analytics job wait --expand "inputs,outputs,transformation,functions" --job-name "sj7804" --resource-group "sjrg3276" --created
A parancssori felület következő sorának futtatását szüneteltetheti, amíg a stream-elemzési feladat sikeresen nem törlődik.
az stream-analytics job wait --expand "inputs,outputs,transformation,functions" --job-name "sj7804" --resource-group "sjrg3276" --deleted
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
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.
Az $expand OData lekérdezési paraméter. Ez egy vesszővel tagolt lista a válaszba belefoglalandó további streamelési feladatok tulajdonságairól, a paraméter távolléte esetén visszaadott alapértelmezett beállításon túl. Az alapértelmezett készlet a "bemenetek", az "átalakítás", a "kimenetek" és a "függvények" kivételével az összes streamelési feladattulajdonság.
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.