az stream-analytics job

Not

Bu başvuru, Azure CLI (sürüm 2.15.0 veya üzeri) için stream-analytics uzantısının bir parçasıdır. Uzantı, bir az stream-analytics job komutunu ilk kez çalıştırdığınızda otomatik olarak yüklenir. Uzantılar hakkında daha fazla bilgi edinin.

Akış analizi ile akış işini yönetin.

Komutlar

Name	Description	Tür	Durum
az stream-analytics job create	Bir akış işi oluşturun veya zaten var olan bir akış işinin yerini alır.	Dahili	GA
az stream-analytics job delete	Akış işini silme.	Dahili	GA
az stream-analytics job list	Belirtilen kaynak grubundaki tüm akış işlerini listeleyin. Ve Verilen abonelikteki tüm akış işlerini listeler.	Dahili	GA
az stream-analytics job scale	İş çalışırken akış işini ölçeklendirme.	Dahili	GA
az stream-analytics job show	Belirtilen akış işi hakkındaki ayrıntıları alın.	Dahili	GA
az stream-analytics job start	Bir akış işi başlatın. bir iş başlatıldıktan sonra giriş olaylarını işlemeye başlar ve çıkış üretir.	Dahili	GA
az stream-analytics job stop	Çalışan bir akış işini durdurun. Bu, çalışan bir akış işinin giriş olaylarını işlemeyi ve çıkış üretmeyi durdurmasına neden olur.	Dahili	GA
az stream-analytics job update	Mevcut bir akış işini güncelleştirin. Bu, iş tanımının geri kalanını etkilemeden bir akış işini kısmen güncelleştirmek (bir veya iki özelliği güncelleştirmek) için kullanılabilir.	Dahili	GA
az stream-analytics job wait	Akış analizi işinin bir koşulu karşılanıncaya kadar CLI'yi bekleme durumuna yerleştirin.	Dahili	GA

az stream-analytics job create

Bir akış işi oluşturun veya zaten var olan bir akış işinin yerini alır.

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]

Örnekler

Eksiksiz bir akış işi oluşturma (dönüştürme, en az 1 giriş ve en az 1 çıkış içeren bir akış işi)

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"

Akış işi kabuğu oluşturma (giriş, çıkış, dönüştürme veya işlev içermeyen bir akış işi)

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"

Gerekli Parametreler

--job-name --name -n

Akış işinin adı.

--resource-group -g

Kaynak grubunun adı. kullanarak varsayılan grubu az configure --defaults group=<name>yapılandırabilirsiniz.

İsteğe Bağlı Parametreler

--arrival-max-delay

Geç gelen olayların dahil edilebileceği saniye cinsinden en yüksek tolerans gecikmesi. Desteklenen aralık -1 ile 1814399 arasıdır (20.23:59:59 gün) ve süresiz beklemeyi belirtmek için -1 kullanılır. Özelliği yoksa, -1 değerine sahip olduğu yorumlanır.

--compatibility-level

Akış işinin belirli çalışma zamanı davranışlarını denetler.

kabul edilen değerler: 1.0, 1.2

--content-storage-policy

Geçerli değerler JobStorageAccount ve SystemAccount değerleridir. JobStorageAccount olarak ayarlanırsa bu, kullanıcının jobStorageAccount özelliğini de belirtmesini gerektirir. .

kabul edilen değerler: JobStorageAccount, SystemAccount

--data-locale

Akış analizi işinin veri yerel ayarı. Değer, kümesinden https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspxdesteklenen bir .NET Kültürünün adı olmalıdır. Belirtilmemişse varsayılan olarak 'en-US' olur.

--functions

Akış işi için bir veya daha fazla işlevin listesi. Put isteğinde bu özellik belirtilirken her işlevin name özelliği gereklidir. Bu özellik patch işlemi aracılığıyla değiştirilemez. Tek tek dönüştürme için kullanılabilir PATCH API'sini kullanmanız gerekir. Beklenen değer: json-string/json-file/@json-file.

--id

Kümenin kaynak kimliği.

--identity

Girişler ve çıkışlarla kimlik doğrulaması yapmak için kullanılabilecek, bu işe atanan sistem tarafından atanan yönetilen kimliği açıklayın.

Kullanım: --identity tenant-id=XX principal-id=XX type=XX

tenant-id: Identity tenantId principal-id: Kimlik sorumlusu kimlik türü: Kimlik türü.

--if-match

Akış işinin ETag'i. Geçerli kayıt kümesinin üzerine her zaman yazmak için bu değeri atla. Eşzamanlı değişikliklerin yanlışlıkla üzerine yazılmasını önlemek için son görülen ETag değerini belirtin.

--if-none-match

Yeni bir akış işinin oluşturulmasına izin vermek, ancak var olan bir kayıt kümesinin güncelleştirilmesini önlemek için '*' olarak ayarlayın. Diğer değerler 412 Ön Koşul Başarısız yanıtına neden olur.

--inputs

Akış işi için bir veya daha fazla girişin listesi. Put isteğinde bu özellik belirtilirken her girişin name özelliği gereklidir. Bu özellik patch işlemi aracılığıyla değiştirilemez. Tek tek giriş için kullanılabilir PATCH API'sini kullanmanız gerekir. Beklenen değer: json-string/json-file/@json-file.

--job-storage-account

MSI ile bir Azure Depolama hesabıyla ilişkili özellikler.

Kullanım: --job-storage-account authentication-mode=XX account-name=XX account-key=XX

kimlik doğrulama modu: Kimlik Doğrulama Modu. hesap-adı: Azure Depolama hesabının adı. PUT (CreateOrReplace) isteklerinde gereklidir. account-key: Azure Depolama hesabının hesap anahtarı. PUT (CreateOrReplace) isteklerinde gereklidir.

--job-type

İşin türünü açıklar. Geçerli modlar ve Cloud 'Edge'.

kabul edilen değerler: Cloud, Edge

--location -l

Konum. Değerleri: az account list-locations. kullanarak az configure --defaults location=<location>varsayılan konumu yapılandırabilirsiniz.

--no-wait

Uzun süre çalışan işlemin bitmesini beklemeyin.

varsayılan değer: False

--order-max-delay

Sıra dışı olayların sırayla geri döndürülecek şekilde ayarlanabildiği saniye cinsinden en yüksek tolerans gecikmesi.

--out-of-order-policy

Giriş olay akışında sıra dışı gelen olaylara uygulanacak ilkeyi gösterir.

kabul edilen değerler: Adjust, Drop

--output-error-policy

Çıkışa ulaşan ve hatalı biçimlendirilmiş (eksik sütun değerleri, yanlış türde veya boyuttaki sütun değerleri) nedeniyle dış depolamaya yazılamayan olaylara uygulanacak ilkeyi gösterir.

kabul edilen değerler: Drop, Stop

--output-start-mode

Bu özellik yalnızca işin oluşturma işleminden hemen sonra başlatılması istendiğinde kullanılmalıdır. Değer JobStartTime, CustomTime veya LastOutputEventTime olabilir. Bu değer, iş her başlatıldığında çıkış olay akışının başlangıç noktasının mı, outputStartTime özelliğiyle belirtilen özel bir kullanıcı zaman damgasından mı yoksa son olay çıktı zamanından mı başlayacağını belirtmek için olabilir.

kabul edilen değerler: CustomTime, JobStartTime, LastOutputEventTime

--output-start-time

Değer, çıkış olay akışının başlangıç noktasını gösteren ISO-8601 biçimli bir zaman damgası veya akış işi her başlatıldığında çıkış olay akışının başlatılacağını belirtmek için null olur. outputStartMode CustomTime olarak ayarlandıysa bu özelliğin bir değeri olmalıdır.

--outputs

Akış işi için bir veya daha fazla çıkışın listesi. Put isteğinde bu özellik belirtilirken her çıkışın name özelliği gereklidir. Bu özellik patch işlemi aracılığıyla değiştirilemez. Tek çıkış için kullanılabilir PATCH API'sini kullanmanız gerekir. Beklenen değer: json-string/json-file/@json-file.

--tags

Boşlukla ayrılmış etiketler: key[=value] [key[=value] ...]. Mevcut etiketleri temizlemek için "" kullanın.

--transformation

Sorguyu ve akış işi için kullanılacak akış birimi sayısını belirtin. Bir PUT isteğinde bu özellik belirtilirken dönüştürmenin ad özelliği gereklidir. Bu özellik patch işlemi aracılığıyla değiştirilemez. Tek tek dönüştürme için kullanılabilir PATCH API'sini kullanmanız gerekir.

Kullanım: --transformation streaming-units=XX valid-streaming-units=XX query=XX name=XX

akış birimleri: Akış işinin kullandığı akış birimi sayısını belirtir. valid-streaming-units: Bir akış işinin ölçeklenebileceği geçerli akış birimlerini belirtir. query: Akış işinde çalıştırılacak sorguyu belirtir. Stream Analytics Sorgu Dili (SAQL) hakkında daha fazla bilgiyi burada bulabilirsiniz: https://msdn.microsoft.com/library/azure/dn834998 . PUT (CreateOrReplace) isteklerinde gereklidir. name: Kaynak adı.

Global Parametreler

--debug

Tüm hata ayıklama günlüklerini göstermek için günlük ayrıntı düzeyini artırın.

--help -h

Bu yardım iletisini göster ve çık.

--only-show-errors

Yalnızca hataları gösterir ve uyarıları gizler.

--output -o

Çıkış biçimi.

kabul edilen değerler: json, jsonc, none, table, tsv, yaml, yamlc

varsayılan değer: json

--query

JMESPath sorgu dizesi. Daha fazla bilgi ve örnek için bkz http://jmespath.org/ .

--subscription

Aboneliğin adı veya kimliği. kullanarak az account set -s NAME_OR_IDvarsayılan aboneliği yapılandırabilirsiniz.

--verbose

Günlük ayrıntı düzeyini artırın. Tam hata ayıklama günlükleri için --debug komutunu kullanın.

az stream-analytics job delete

Akış işini silme.

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

Örnekler

Akış işini silme

az stream-analytics job delete --job-name "sj59" --resource-group "sjrg6936"

Gerekli Parametreler

--job-name --name -n

Akış işinin adı.

--resource-group -g

Kaynak grubunun adı. kullanarak varsayılan grubu az configure --defaults group=<name>yapılandırabilirsiniz.

İsteğe Bağlı Parametreler

--no-wait

Uzun süre çalışan işlemin bitmesini beklemeyin.

varsayılan değer: False

--yes -y

Onay istemde bulunmayın.

varsayılan değer: False

Global Parametreler

--debug

Tüm hata ayıklama günlüklerini göstermek için günlük ayrıntı düzeyini artırın.

--help -h

Bu yardım iletisini göster ve çık.

--only-show-errors

Yalnızca hataları gösterir ve uyarıları gizler.

--output -o

Çıkış biçimi.

kabul edilen değerler: json, jsonc, none, table, tsv, yaml, yamlc

varsayılan değer: json

--query

JMESPath sorgu dizesi. Daha fazla bilgi ve örnek için bkz http://jmespath.org/ .

--subscription

Aboneliğin adı veya kimliği. kullanarak az account set -s NAME_OR_IDvarsayılan aboneliği yapılandırabilirsiniz.

--verbose

Günlük ayrıntı düzeyini artırın. Tam hata ayıklama günlükleri için --debug komutunu kullanın.

az stream-analytics job list

Belirtilen kaynak grubundaki tüm akış işlerini listeleyin. Ve Verilen abonelikteki tüm akış işlerini listeler.

az stream-analytics job list [--expand]
                             [--resource-group]

Örnekler

Bir kaynak grubundaki tüm akış işlerini listeleyin ve $expand OData sorgu parametresini kullanmayın

az stream-analytics job list --resource-group "sjrg6936"

Bir kaynak grubundaki tüm akış işlerini listeleyin ve girişleri, çıkışları, dönüştürmeyi ve işlevleri genişletmek için $expand OData sorgu parametresini kullanın

az stream-analytics job list --expand "inputs,outputs,transformation,functions" --resource-group "sjrg3276"

Abonelikteki tüm akış işlerini listeleme ve $expand OData sorgu parametresini kullanmama

az stream-analytics job list

Abonelikteki tüm akış işlerini listeleyin ve $expand OData sorgu parametresini kullanarak girişleri, çıkışları, dönüştürmeyi ve işlevleri genişletin

az stream-analytics job list --expand "inputs,outputs,transformation,functions"

İsteğe Bağlı Parametreler

--expand

$expand OData sorgu parametresi. Bu, bu parametre olmadığında döndürülen varsayılan kümenin ötesinde, yanıta eklenecek ek akış işi özelliklerinin virgülle ayrılmış listesidir. Varsayılan küme , 'inputs', 'transformation', 'outputs' ve 'functions' dışındaki tüm akış işi özellikleridir.

--resource-group -g

Kaynak grubunun adı. kullanarak varsayılan grubu az configure --defaults group=<name>yapılandırabilirsiniz.

Global Parametreler

--debug

Tüm hata ayıklama günlüklerini göstermek için günlük ayrıntı düzeyini artırın.

--help -h

Bu yardım iletisini göster ve çık.

--only-show-errors

Yalnızca hataları gösterir ve uyarıları gizler.

--output -o

Çıkış biçimi.

kabul edilen değerler: json, jsonc, none, table, tsv, yaml, yamlc

varsayılan değer: json

--query

JMESPath sorgu dizesi. Daha fazla bilgi ve örnek için bkz http://jmespath.org/ .

--subscription

Aboneliğin adı veya kimliği. kullanarak az account set -s NAME_OR_IDvarsayılan aboneliği yapılandırabilirsiniz.

--verbose

Günlük ayrıntı düzeyini artırın. Tam hata ayıklama günlükleri için --debug komutunu kullanın.

az stream-analytics job scale

İş çalışırken akış işini ölçeklendirme.

az stream-analytics job scale --job-name
                              --resource-group
                              [--no-wait]
                              [--streaming-units]

Örnekler

Akış işini ölçeklendirme

az stream-analytics job scale --job-name "sj59" --resource-group "sjrg6936" --streaming-units 36

Gerekli Parametreler

--job-name --name -n

Akış işinin adı.

--resource-group -g

Kaynak grubunun adı. kullanarak varsayılan grubu az configure --defaults group=<name>yapılandırabilirsiniz.

İsteğe Bağlı Parametreler

--no-wait

Uzun süre çalışan işlemin bitmesini beklemeyin.

varsayılan değer: False

--streaming-units

Akış işinin ölçeklendirileceği akış birimi sayısını belirtir.

Global Parametreler

--debug

Tüm hata ayıklama günlüklerini göstermek için günlük ayrıntı düzeyini artırın.

--help -h

Bu yardım iletisini göster ve çık.

--only-show-errors

Yalnızca hataları gösterir ve uyarıları gizler.

--output -o

Çıkış biçimi.

kabul edilen değerler: json, jsonc, none, table, tsv, yaml, yamlc

varsayılan değer: json

--query

JMESPath sorgu dizesi. Daha fazla bilgi ve örnek için bkz http://jmespath.org/ .

--subscription

Aboneliğin adı veya kimliği. kullanarak az account set -s NAME_OR_IDvarsayılan aboneliği yapılandırabilirsiniz.

--verbose

Günlük ayrıntı düzeyini artırın. Tam hata ayıklama günlükleri için --debug komutunu kullanın.

az stream-analytics job show

Belirtilen akış işi hakkındaki ayrıntıları alın.

az stream-analytics job show --job-name
                             --resource-group
                             [--expand]

Örnekler

Akış işi alma ve $expand OData sorgu parametresini kullanmama

az stream-analytics job show --job-name "sj59" --resource-group "sjrg6936"

Akış işi alma ve $expand OData sorgu parametresini kullanarak girişleri, çıkışları, dönüştürmeyi ve işlevleri genişletme

az stream-analytics job show --expand "inputs,outputs,transformation,functions" --job-name "sj7804" --resource-group "sjrg3276"

Gerekli Parametreler

--job-name --name -n

Akış işinin adı.

--resource-group -g

Kaynak grubunun adı. kullanarak varsayılan grubu az configure --defaults group=<name>yapılandırabilirsiniz.

İsteğe Bağlı Parametreler

--expand

$expand OData sorgu parametresi. Bu, bu parametre olmadığında döndürülen varsayılan kümenin ötesinde, yanıta eklenecek ek akış işi özelliklerinin virgülle ayrılmış listesidir. Varsayılan küme , 'inputs', 'transformation', 'outputs' ve 'functions' dışındaki tüm akış işi özellikleridir.

Global Parametreler

--debug

Tüm hata ayıklama günlüklerini göstermek için günlük ayrıntı düzeyini artırın.

--help -h

Bu yardım iletisini göster ve çık.

--only-show-errors

Yalnızca hataları gösterir ve uyarıları gizler.

--output -o

Çıkış biçimi.

kabul edilen değerler: json, jsonc, none, table, tsv, yaml, yamlc

varsayılan değer: json

--query

JMESPath sorgu dizesi. Daha fazla bilgi ve örnek için bkz http://jmespath.org/ .

--subscription

Aboneliğin adı veya kimliği. kullanarak az account set -s NAME_OR_IDvarsayılan aboneliği yapılandırabilirsiniz.

--verbose

Günlük ayrıntı düzeyini artırın. Tam hata ayıklama günlükleri için --debug komutunu kullanın.

az stream-analytics job start

Bir akış işi başlatın. bir iş başlatıldıktan sonra giriş olaylarını işlemeye başlar ve çıkış üretir.

az stream-analytics job start --job-name
                              --resource-group
                              [--no-wait]
                              [--output-start-mode {CustomTime, JobStartTime, LastOutputEventTime}]
                              [--output-start-time]

Örnekler

CustomTime çıkış başlangıç modu ile akış işi başlatma

az stream-analytics job start --job-name "sj59" --resource-group "sjrg6936" --output-start-mode "CustomTime" --output-start-time "2012-12-12T12:12:12Z"

JobStartTime çıkış başlangıç modu ile akış işi başlatma

az stream-analytics job start --job-name "sj59" --resource-group "sjrg6936" --output-start-mode "JobStartTime"

LastOutputEventTime çıkış başlangıç modu ile akış işi başlatma

az stream-analytics job start --job-name "sj59" --resource-group "sjrg6936" --output-start-mode "LastOutputEventTime"

Gerekli Parametreler

--job-name --name -n

Akış işinin adı.

--resource-group -g

Kaynak grubunun adı. kullanarak varsayılan grubu az configure --defaults group=<name>yapılandırabilirsiniz.

İsteğe Bağlı Parametreler

--no-wait

Uzun süre çalışan işlemin bitmesini beklemeyin.

varsayılan değer: False

--output-start-mode

Değer JobStartTime, CustomTime veya LastOutputEventTime olabilir. Bu değer, iş her başlatıldığında çıkış olay akışının başlangıç noktasının mı, outputStartTime özelliğiyle belirtilen özel bir kullanıcı zaman damgasından mı yoksa son olay çıktı zamanından mı başlayacağını belirtmek için olabilir.

kabul edilen değerler: CustomTime, JobStartTime, LastOutputEventTime

--output-start-time

Değer, çıkış olay akışının başlangıç noktasını gösteren ISO-8601 biçimli bir zaman damgası veya akış işi her başlatıldığında çıkış olay akışının başlatılacağını belirtmek için null olur. outputStartMode CustomTime olarak ayarlandıysa bu özelliğin bir değeri olmalıdır.

Global Parametreler

--debug

Tüm hata ayıklama günlüklerini göstermek için günlük ayrıntı düzeyini artırın.

--help -h

Bu yardım iletisini göster ve çık.

--only-show-errors

Yalnızca hataları gösterir ve uyarıları gizler.

--output -o

Çıkış biçimi.

kabul edilen değerler: json, jsonc, none, table, tsv, yaml, yamlc

varsayılan değer: json

--query

JMESPath sorgu dizesi. Daha fazla bilgi ve örnek için bkz http://jmespath.org/ .

--subscription

Aboneliğin adı veya kimliği. kullanarak az account set -s NAME_OR_IDvarsayılan aboneliği yapılandırabilirsiniz.

--verbose

Günlük ayrıntı düzeyini artırın. Tam hata ayıklama günlükleri için --debug komutunu kullanın.

az stream-analytics job stop

Çalışan bir akış işini durdurun. Bu, çalışan bir akış işinin giriş olaylarını işlemeyi ve çıkış üretmeyi durdurmasına neden olur.

az stream-analytics job stop --job-name
                             --resource-group
                             [--no-wait]

Örnekler

Akış işini durdurma

az stream-analytics job stop --job-name "sj59" --resource-group "sjrg6936"

Gerekli Parametreler

--job-name --name -n

Akış işinin adı.

--resource-group -g

Kaynak grubunun adı. kullanarak varsayılan grubu az configure --defaults group=<name>yapılandırabilirsiniz.

İsteğe Bağlı Parametreler

--no-wait

Uzun süre çalışan işlemin bitmesini beklemeyin.

varsayılan değer: False

Global Parametreler

--debug

Tüm hata ayıklama günlüklerini göstermek için günlük ayrıntı düzeyini artırın.

--help -h

Bu yardım iletisini göster ve çık.

--only-show-errors

Yalnızca hataları gösterir ve uyarıları gizler.

--output -o

Çıkış biçimi.

kabul edilen değerler: json, jsonc, none, table, tsv, yaml, yamlc

varsayılan değer: json

--query

JMESPath sorgu dizesi. Daha fazla bilgi ve örnek için bkz http://jmespath.org/ .

--subscription

Aboneliğin adı veya kimliği. kullanarak az account set -s NAME_OR_IDvarsayılan aboneliği yapılandırabilirsiniz.

--verbose

Günlük ayrıntı düzeyini artırın. Tam hata ayıklama günlükleri için --debug komutunu kullanın.

az stream-analytics job update

Mevcut bir akış işini güncelleştirin. Bu, iş tanımının geri kalanını etkilemeden bir akış işini kısmen güncelleştirmek (bir veya iki özelliği güncelleştirmek) için kullanılabilir.

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]

Örnekler

Akış işini güncelleştirme

az stream-analytics job update --job-name "sj59" --resource-group "sjrg6936" --arrival-max-delay 13 --order-max-delay 21

Gerekli Parametreler

--job-name --name -n

Akış işinin adı.

--resource-group -g

Kaynak grubunun adı. kullanarak varsayılan grubu az configure --defaults group=<name>yapılandırabilirsiniz.

İsteğe Bağlı Parametreler

--arrival-max-delay

Geç gelen olayların dahil edilebileceği saniye cinsinden en yüksek tolerans gecikmesi. Desteklenen aralık -1 ile 1814399 arasıdır (20.23:59:59 gün) ve süresiz beklemeyi belirtmek için -1 kullanılır. Özelliği yoksa, -1 değerine sahip olduğu yorumlanır.

--compatibility-level

Akış işinin belirli çalışma zamanı davranışlarını denetler.

kabul edilen değerler: 1.0, 1.2

--content-storage-policy

Geçerli değerler JobStorageAccount ve SystemAccount değerleridir. JobStorageAccount olarak ayarlanırsa bu, kullanıcının jobStorageAccount özelliğini de belirtmesini gerektirir. .

kabul edilen değerler: JobStorageAccount, SystemAccount

--data-locale

Akış analizi işinin veri yerel ayarı. Değer, kümesinden https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspxdesteklenen bir .NET Kültürünün adı olmalıdır. Belirtilmemişse varsayılan olarak 'en-US' olur.

--functions

Akış işi için bir veya daha fazla işlevin listesi. Put isteğinde bu özellik belirtilirken her işlevin name özelliği gereklidir. Bu özellik patch işlemi aracılığıyla değiştirilemez. Tek tek dönüştürme için kullanılabilir PATCH API'sini kullanmanız gerekir. Beklenen değer: json-string/json-file/@json-file.

--id

Kümenin kaynak kimliği.

--identity

Girişler ve çıkışlarla kimlik doğrulaması yapmak için kullanılabilecek, bu işe atanan sistem tarafından atanan yönetilen kimliği açıklayın.

Kullanım: --identity tenant-id=XX principal-id=XX type=XX

tenant-id: Identity tenantId principal-id: Kimlik sorumlusu kimlik türü: Kimlik türü.

--if-match

Akış işinin ETag'i. Geçerli kayıt kümesinin üzerine her zaman yazmak için bu değeri atla. Eşzamanlı değişikliklerin yanlışlıkla üzerine yazılmasını önlemek için son görülen ETag değerini belirtin.

--inputs

Akış işi için bir veya daha fazla girişin listesi. Put isteğinde bu özellik belirtilirken her girişin name özelliği gereklidir. Bu özellik patch işlemi aracılığıyla değiştirilemez. Tek tek giriş için kullanılabilir PATCH API'sini kullanmanız gerekir. Beklenen değer: json-string/json-file/@json-file.

--job-storage-account

MSI ile bir Azure Depolama hesabıyla ilişkili özellikler.

Kullanım: --job-storage-account authentication-mode=XX account-name=XX account-key=XX

kimlik doğrulama modu: Kimlik Doğrulama Modu. hesap-adı: Azure Depolama hesabının adı. PUT (CreateOrReplace) isteklerinde gereklidir. account-key: Azure Depolama hesabının hesap anahtarı. PUT (CreateOrReplace) isteklerinde gereklidir.

--job-type

İşin türünü açıklar. Geçerli modlar ve Cloud 'Edge'.

kabul edilen değerler: Cloud, Edge

--location -l

Konum. Değerleri: az account list-locations. kullanarak az configure --defaults location=<location>varsayılan konumu yapılandırabilirsiniz.

--order-max-delay

Sıra dışı olayların sırayla geri döndürülecek şekilde ayarlanabildiği saniye cinsinden en yüksek tolerans gecikmesi.

--out-of-order-policy

Giriş olay akışında sıra dışı gelen olaylara uygulanacak ilkeyi gösterir.

kabul edilen değerler: Adjust, Drop

--output-error-policy

Çıkışa ulaşan ve hatalı biçimlendirilmiş (eksik sütun değerleri, yanlış türde veya boyuttaki sütun değerleri) nedeniyle dış depolamaya yazılamayan olaylara uygulanacak ilkeyi gösterir.

kabul edilen değerler: Drop, Stop

--output-start-mode

Bu özellik yalnızca işin oluşturma işleminden hemen sonra başlatılması istendiğinde kullanılmalıdır. Değer JobStartTime, CustomTime veya LastOutputEventTime olabilir. Bu değer, iş her başlatıldığında çıkış olay akışının başlangıç noktasının mı, outputStartTime özelliğiyle belirtilen özel bir kullanıcı zaman damgasından mı yoksa son olay çıktı zamanından mı başlayacağını belirtmek için olabilir.

kabul edilen değerler: CustomTime, JobStartTime, LastOutputEventTime

--output-start-time

Değer, çıkış olay akışının başlangıç noktasını gösteren ISO-8601 biçimli bir zaman damgası veya akış işi her başlatıldığında çıkış olay akışının başlatılacağını belirtmek için null olur. outputStartMode CustomTime olarak ayarlandıysa bu özelliğin bir değeri olmalıdır.

--outputs

Akış işi için bir veya daha fazla çıkışın listesi. Put isteğinde bu özellik belirtilirken her çıkışın name özelliği gereklidir. Bu özellik patch işlemi aracılığıyla değiştirilemez. Tek çıkış için kullanılabilir PATCH API'sini kullanmanız gerekir. Beklenen değer: json-string/json-file/@json-file.

--tags

Boşlukla ayrılmış etiketler: key[=value] [key[=value] ...]. Mevcut etiketleri temizlemek için "" kullanın.

--transformation

Sorguyu ve akış işi için kullanılacak akış birimi sayısını belirtin. Bir PUT isteğinde bu özellik belirtilirken dönüştürmenin ad özelliği gereklidir. Bu özellik patch işlemi aracılığıyla değiştirilemez. Tek tek dönüştürme için kullanılabilir PATCH API'sini kullanmanız gerekir.

Kullanım: --transformation streaming-units=XX valid-streaming-units=XX query=XX name=XX

akış birimleri: Akış işinin kullandığı akış birimi sayısını belirtir. valid-streaming-units: Bir akış işinin ölçeklenebileceği geçerli akış birimlerini belirtir. query: Akış işinde çalıştırılacak sorguyu belirtir. Stream Analytics Sorgu Dili (SAQL) hakkında daha fazla bilgiyi burada bulabilirsiniz: https://msdn.microsoft.com/library/azure/dn834998 . PUT (CreateOrReplace) isteklerinde gereklidir. name: Kaynak adı.

Global Parametreler

--debug

Tüm hata ayıklama günlüklerini göstermek için günlük ayrıntı düzeyini artırın.

--help -h

Bu yardım iletisini göster ve çık.

--only-show-errors

Yalnızca hataları gösterir ve uyarıları gizler.

--output -o

Çıkış biçimi.

kabul edilen değerler: json, jsonc, none, table, tsv, yaml, yamlc

varsayılan değer: json

--query

JMESPath sorgu dizesi. Daha fazla bilgi ve örnek için bkz http://jmespath.org/ .

--subscription

Aboneliğin adı veya kimliği. kullanarak az account set -s NAME_OR_IDvarsayılan aboneliği yapılandırabilirsiniz.

--verbose

Günlük ayrıntı düzeyini artırın. Tam hata ayıklama günlükleri için --debug komutunu kullanın.

az stream-analytics job wait

Akış analizi işinin bir koşulu karşılanıncaya kadar CLI'yi bekleme durumuna yerleştirin.

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

Örnekler

Stream-analytics işi başarıyla oluşturulana kadar CLI betiğinin sonraki satırını yürütmeyi duraklatın.

az stream-analytics job wait --expand "inputs,outputs,transformation,functions" --job-name "sj7804" --resource-group "sjrg3276" --created

Stream-analytics işi başarıyla silinene kadar CLI betiğinin sonraki satırını yürütmeyi duraklatın.

az stream-analytics job wait --expand "inputs,outputs,transformation,functions" --job-name "sj7804" --resource-group "sjrg3276" --deleted

Gerekli Parametreler

--job-name --name -n

Akış işinin adı.

--resource-group -g

Kaynak grubunun adı. kullanarak varsayılan grubu az configure --defaults group=<name>yapılandırabilirsiniz.

İsteğe Bağlı Parametreler

--created

'ProvisioningState' ile 'Succeeded' konumunda oluşturulana kadar bekleyin.

varsayılan değer: False

--custom

Koşul özel bir JMESPath sorgusunu karşılayana kadar bekleyin. Örneğin provisioningState!='InProgress', instanceView.statuses[?code=='PowerState/running'].

--deleted

Silinene kadar bekleyin.

varsayılan değer: False

--exists

Kaynak var olana kadar bekleyin.

varsayılan değer: False

--expand

$expand OData sorgu parametresi. Bu, bu parametre olmadığında döndürülen varsayılan kümenin ötesinde, yanıta eklenecek ek akış işi özelliklerinin virgülle ayrılmış listesidir. Varsayılan küme , 'inputs', 'transformation', 'outputs' ve 'functions' dışındaki tüm akış işi özellikleridir.

--interval

Saniye cinsinden yoklama aralığı.

varsayılan değer: 30

--timeout

Saniye cinsinden en fazla bekleme.

varsayılan değer: 3600

--updated

'Başarılı' konumunda provisioningState ile güncelleştirilene kadar bekleyin.

varsayılan değer: False

Global Parametreler

--debug

Tüm hata ayıklama günlüklerini göstermek için günlük ayrıntı düzeyini artırın.

--help -h

Bu yardım iletisini göster ve çık.

--only-show-errors

Yalnızca hataları gösterir ve uyarıları gizler.

--output -o

Çıkış biçimi.

kabul edilen değerler: json, jsonc, none, table, tsv, yaml, yamlc

varsayılan değer: json

--query

JMESPath sorgu dizesi. Daha fazla bilgi ve örnek için bkz http://jmespath.org/ .

--subscription

Aboneliğin adı veya kimliği. kullanarak az account set -s NAME_OR_IDvarsayılan aboneliği yapılandırabilirsiniz.

--verbose

Günlük ayrıntı düzeyini artırın. Tam hata ayıklama günlükleri için --debug komutunu kullanın.