az stream-analytics output
Dekont
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ı, az stream-analytics output komutunu ilk kez çalıştırdığınızda otomatik olarak yüklenir. Uzantılar hakkında daha fazla bilgi edinin.
Akış analizi ile çıkışı yönetin.
Komutlar
Name | Description | Tür | Durum |
---|---|---|---|
az stream-analytics output create |
Bir çıkış oluşturun veya mevcut bir akış işinin altında zaten var olan bir çıkışın yerini alır. |
Dahili | GA |
az stream-analytics output delete |
Akış işinden bir çıktıyı silin. |
Dahili | GA |
az stream-analytics output list |
Belirtilen akış işinin altındaki tüm çıkışları listeleyin. |
Dahili | GA |
az stream-analytics output show |
Belirtilen çıkışla ilgili ayrıntıları alın. |
Dahili | GA |
az stream-analytics output test |
Bir çıktının veri kaynağının Azure Stream Analytics hizmeti tarafından erişilebilir ve kullanılabilir olup olmadığını test edin. |
Dahili | GA |
az stream-analytics output update |
Mevcut bir akış işinin altındaki mevcut çıkışı güncelleştirin. Bu, işi veya çıkış tanımını etkilemeden bir çıkışı kısmen güncelleştirmek (bir veya iki özelliği güncelleştirmek) için kullanılabilir. |
Dahili | GA |
az stream-analytics output wait |
Akış analizi çıktısının bir koşulu karşılanıncaya kadar CLI'yi bekleme durumuna yerleştirin. |
Dahili | GA |
az stream-analytics output create
Bir çıkış oluşturun veya mevcut bir akış işinin altında zaten var olan bir çıkışın yerini alır.
az stream-analytics output create --job-name
--name
--resource-group
[--datasource]
[--if-match]
[--if-none-match]
[--serialization]
[--size-window]
[--time-window]
Örnekler
DocumentDB çıkışı oluşturma
az stream-analytics output create --job-name "sj2331" --datasource "{\"type\":\"Microsoft.Storage/DocumentDB\",\"properties\":{\"accountId\":\"someAccountId\",\"accountKey\":\"accountKey==\",\"collectionNamePattern\":\"collection\",\"database\":\"db01\",\"documentId\":\"documentId\",\"partitionKey\":\"key\"}}" --output-name "output3022" --resource-group "sjrg7983"
Power BI çıkışı oluşturma
az stream-analytics output create --job-name "sj2331" --datasource "{\"type\":\"PowerBI\",\"properties\":{\"dataset\":\"someDataset\",\"groupId\":\"ac40305e-3e8d-43ac-8161-c33799f43e95\",\"groupName\":\"MyPowerBIGroup\",\"refreshToken\":\"someRefreshToken==\",\"table\":\"someTable\",\"tokenUserDisplayName\":\"Bob Smith\",\"tokenUserPrincipalName\":\"bobsmith@contoso.com\"}}" --output-name "output3022" --resource-group "sjrg7983"
Avro serileştirme ile Service Bus Kuyruğu çıkışı oluşturma
az stream-analytics output create --job-name "sj5095" --datasource "{\"type\":\"Microsoft.ServiceBus/Queue\",\"properties\":{\"propertyColumns\":[\"column1\",\"column2\"],\"queueName\":\"sdkqueue\",\"serviceBusNamespace\":\"sdktest\",\"sharedAccessPolicyKey\":\"sharedAccessPolicyKey=\",\"sharedAccessPolicyName\":\"RootManageSharedAccessKey\",\"systemPropertyColumns\":{\"MessageId\":\"col3\",\"PartitionKey\":\"col4\"}}}" --serialization "{\"type\":\"Avro\"}" --output-name "output3456" --resource-group "sjrg3410"
CSV serileştirmesi ile Service Bus Konusu çıkışı oluşturma
az stream-analytics output create --job-name "sj7094" --datasource "{\"type\":\"Microsoft.ServiceBus/Topic\",\"properties\":{\"propertyColumns\":[\"column1\",\"column2\"],\"serviceBusNamespace\":\"sdktest\",\"sharedAccessPolicyKey\":\"sharedAccessPolicyKey=\",\"sharedAccessPolicyName\":\"RootManageSharedAccessKey\",\"topicName\":\"sdktopic\"}}" --serialization "{\"type\":\"Csv\",\"properties\":{\"encoding\":\"UTF8\",\"fieldDelimiter\":\",\"}}" --output-name "output7886" --resource-group "sjrg6450"
CSV serileştirmesi ile blob çıkışı oluşturma
az stream-analytics output create --job-name "sj900" --datasource "{\"type\":\"Microsoft.Storage/Blob\",\"properties\":{\"container\":\"state\",\"dateFormat\":\"yyyy/MM/dd\",\"pathPattern\":\"{date}/{time}\",\"storageAccounts\":[{\"accountKey\":\"accountKey==\",\"accountName\":\"someAccountName\"}],\"timeFormat\":\"HH\"}}" --serialization "{\"type\":\"Csv\",\"properties\":{\"encoding\":\"UTF8\",\"fieldDelimiter\":\",\"}}" --output-name "output1623" --resource-group "sjrg5023"
JSON serileştirme ile Azure Data Lake Store çıkışı oluşturma
az stream-analytics output create --job-name "sj3310" --datasource "{\"type\":\"Microsoft.DataLake/Accounts\",\"properties\":{\"accountName\":\"someaccount\",\"dateFormat\":\"yyyy/MM/dd\",\"filePathPrefix\":\"{date}/{time}\",\"refreshToken\":\"someRefreshToken==\",\"tenantId\":\"cea4e98b-c798-49e7-8c40-4a2b3beb47dd\",\"timeFormat\":\"HH\",\"tokenUserDisplayName\":\"Bob Smith\",\"tokenUserPrincipalName\":\"bobsmith@contoso.com\"}}" --serialization "{\"type\":\"Json\",\"properties\":{\"format\":\"Array\",\"encoding\":\"UTF8\"}}" --output-name "output5195" --resource-group "sjrg6912"
Azure SQL veritabanı çıkışı oluşturma
az stream-analytics output create --job-name "sj6458" --datasource "{\"type\":\"Microsoft.Sql/Server/Database\",\"properties\":{\"database\":\"someDatabase\",\"password\":\"somePassword\",\"server\":\"someServer\",\"table\":\"someTable\",\"user\":\"<user>\"}}" --output-name "output1755" --resource-group "sjrg2157"
Azure Tablo çıkışı oluşturma
az stream-analytics output create --job-name "sj2790" --datasource "{\"type\":\"Microsoft.Storage/Table\",\"properties\":{\"accountKey\":\"accountKey==\",\"accountName\":\"someAccountName\",\"batchSize\":25,\"columnsToRemove\":[\"column1\",\"column2\"],\"partitionKey\":\"partitionKey\",\"rowKey\":\"rowKey\",\"table\":\"samples\"}}" --output-name "output958" --resource-group "sjrg5176"
JSON serileştirme ile Olay Hub'ı çıkışı oluşturma
az stream-analytics output create --job-name "sj3310" --datasource "{\"type\":\"Microsoft.ServiceBus/EventHub\",\"properties\":{\"eventHubName\":\"sdkeventhub\",\"partitionKey\":\"partitionKey\",\"serviceBusNamespace\":\"sdktest\",\"sharedAccessPolicyKey\":\"sharedAccessPolicyKey=\",\"sharedAccessPolicyName\":\"RootManageSharedAccessKey\"}}" --serialization "{\"type\":\"Json\",\"properties\":{\"format\":\"Array\",\"encoding\":\"UTF8\"}}" --output-name "output5195" --resource-group "sjrg6912"
Gerekli Parametreler
Akış işinin adı.
Çıktının adı.
Kaynak grubunun adı. kullanarak varsayılan grubu az configure --defaults group=<name>
yapılandırabilirsiniz.
İsteğe Bağlı Parametreler
Çıktının yazılacağı veri kaynağını açıklar. PUT (CreateOrReplace) isteklerinde gereklidir. Beklenen değer: json-string/json-file/@json-file.
Çıkışın ETag'i. Geçerli çıkışın ü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.
Yeni bir çıkışın oluşturulmasına izin vermek, ancak var olan bir çıkışın 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.
Bir girişten alınan verilerin nasıl serileştirildiği veya çıkışa yazıldığında verilerin nasıl seri hale getirildiği açıklanır. PUT (CreateOrReplace) isteklerinde gereklidir. Beklenen değer: json-string/json-file/@json-file.
Stream Analytics çıkışını kısıtlamak için boyut penceresi.
Stream Analytics iş çıkışlarını filtrelemek için zaman çerçevesi.
Global Parametreler
Tüm hata ayıklama günlüklerini göstermek için günlük ayrıntı düzeyini artırın.
Bu yardım iletisini göster ve çık.
Yalnızca hataları gösterir ve uyarıları gizler.
Çıkış biçimi.
JMESPath sorgu dizesi. Daha fazla bilgi ve örnek için bkz http://jmespath.org/ .
Aboneliğin adı veya kimliği. kullanarak az account set -s NAME_OR_ID
varsayılan aboneliği yapılandırabilirsiniz.
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 output delete
Akış işinden bir çıktıyı silin.
az stream-analytics output delete --job-name
--name
--resource-group
[--yes]
Örnekler
Çıktıyı silme
az stream-analytics output delete --job-name "sj6458" --name "output1755" --resource-group "sjrg2157"
Gerekli Parametreler
Akış işinin adı.
Çıktının adı.
Kaynak grubunun adı. kullanarak varsayılan grubu az configure --defaults group=<name>
yapılandırabilirsiniz.
İsteğe Bağlı Parametreler
Onay istemde bulunmayın.
Global Parametreler
Tüm hata ayıklama günlüklerini göstermek için günlük ayrıntı düzeyini artırın.
Bu yardım iletisini göster ve çık.
Yalnızca hataları gösterir ve uyarıları gizler.
Çıkış biçimi.
JMESPath sorgu dizesi. Daha fazla bilgi ve örnek için bkz http://jmespath.org/ .
Aboneliğin adı veya kimliği. kullanarak az account set -s NAME_OR_ID
varsayılan aboneliği yapılandırabilirsiniz.
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 output list
Belirtilen akış işinin altındaki tüm çıkışları listeleyin.
az stream-analytics output list --job-name
--resource-group
[--select]
Örnekler
Akış işinde tüm çıkışları listeleme
az stream-analytics output list --job-name "sj6458" --resource-group "sjrg2157"
Gerekli Parametreler
Akış işinin adı.
Kaynak grubunun adı. kullanarak varsayılan grubu az configure --defaults group=<name>
yapılandırabilirsiniz.
İsteğe Bağlı Parametreler
$select OData sorgu parametresi. Bu, yanıta eklenecek yapısal özelliklerin virgülle ayrılmış bir listesidir veya tüm özellikleri dahil etmek için "". Varsayılan olarak, tanılama dışındaki tüm özellikler döndürülür. Şu anda yalnızca '' değerini geçerli bir değer olarak kabul eder.
Global Parametreler
Tüm hata ayıklama günlüklerini göstermek için günlük ayrıntı düzeyini artırın.
Bu yardım iletisini göster ve çık.
Yalnızca hataları gösterir ve uyarıları gizler.
Çıkış biçimi.
JMESPath sorgu dizesi. Daha fazla bilgi ve örnek için bkz http://jmespath.org/ .
Aboneliğin adı veya kimliği. kullanarak az account set -s NAME_OR_ID
varsayılan aboneliği yapılandırabilirsiniz.
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 output show
Belirtilen çıkışla ilgili ayrıntıları alın.
az stream-analytics output show --job-name
--name
--resource-group
Örnekler
DocumentDB çıktısı alma
az stream-analytics output show --job-name "sj2331" --output-name "output3022" --resource-group "sjrg7983"
Power BI çıkışı alma
az stream-analytics output show --job-name "sj2331" --output-name "output3022" --resource-group "sjrg7983"
Avro serileştirme ile Service Bus Kuyruğu çıkışı alma
az stream-analytics output show --job-name "sj5095" --output-name "output3456" --resource-group "sjrg3410"
CSV serileştirmesi ile Service Bus Konusu çıkışı alma
az stream-analytics output show --job-name "sj7094" --output-name "output7886" --resource-group "sjrg6450"
CSV serileştirmesi ile blob çıktısı alma
az stream-analytics output show --job-name "sj900" --output-name "output1623" --resource-group "sjrg5023"
JSON serileştirme ile Azure Data Lake Store çıkışı alma
az stream-analytics output show --job-name "sj3310" --output-name "output5195" --resource-group "sjrg6912"
Azure Veri Ambarı çıktısı alma
az stream-analytics output show --job-name "sjName" --output-name "output958" --resource-group "sjrg"
Azure SQL veritabanı çıktısı alma
az stream-analytics output show --job-name "sj6458" --output-name "output1755" --resource-group "sjrg2157"
Azure Tablo çıktısı alma
az stream-analytics output show --job-name "sj2790" --output-name "output958" --resource-group "sjrg5176"
JSON serileştirme ile Olay Hub'ı çıkışı alma
az stream-analytics output show --job-name "sj3310" --output-name "output5195" --resource-group "sjrg6912"
Gerekli Parametreler
Akış işinin adı.
Çıktının adı.
Kaynak grubunun adı. kullanarak varsayılan grubu az configure --defaults group=<name>
yapılandırabilirsiniz.
Global Parametreler
Tüm hata ayıklama günlüklerini göstermek için günlük ayrıntı düzeyini artırın.
Bu yardım iletisini göster ve çık.
Yalnızca hataları gösterir ve uyarıları gizler.
Çıkış biçimi.
JMESPath sorgu dizesi. Daha fazla bilgi ve örnek için bkz http://jmespath.org/ .
Aboneliğin adı veya kimliği. kullanarak az account set -s NAME_OR_ID
varsayılan aboneliği yapılandırabilirsiniz.
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 output test
Bir çıktının veri kaynağının Azure Stream Analytics hizmeti tarafından erişilebilir ve kullanılabilir olup olmadığını test edin.
az stream-analytics output test --job-name
--name
--resource-group
[--datasource]
[--no-wait]
[--serialization]
[--size-window]
[--time-window]
Örnekler
Çıkış için bağlantıyı test edin
az stream-analytics output test --job-name "sj6458" --output-name "output1755" --resource-group "sjrg2157"
Gerekli Parametreler
Akış işinin adı.
Çıktının adı.
Kaynak grubunun adı. kullanarak varsayılan grubu az configure --defaults group=<name>
yapılandırabilirsiniz.
İsteğe Bağlı Parametreler
Çıktının yazılacağı veri kaynağını açıklar. PUT (CreateOrReplace) isteklerinde gereklidir. Beklenen değer: json-string/json-file/@json-file.
Uzun süre çalışan işlemin bitmesini beklemeyin.
Bir girişten alınan verilerin nasıl serileştirildiği veya çıkışa yazıldığında verilerin nasıl seri hale getirildiği açıklanır. PUT (CreateOrReplace) isteklerinde gereklidir. Beklenen değer: json-string/json-file/@json-file.
Stream Analytics çıkışını kısıtlamak için boyut penceresi.
Stream Analytics iş çıkışlarını filtrelemek için zaman çerçevesi.
Global Parametreler
Tüm hata ayıklama günlüklerini göstermek için günlük ayrıntı düzeyini artırın.
Bu yardım iletisini göster ve çık.
Yalnızca hataları gösterir ve uyarıları gizler.
Çıkış biçimi.
JMESPath sorgu dizesi. Daha fazla bilgi ve örnek için bkz http://jmespath.org/ .
Aboneliğin adı veya kimliği. kullanarak az account set -s NAME_OR_ID
varsayılan aboneliği yapılandırabilirsiniz.
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 output update
Mevcut bir akış işinin altındaki mevcut çıkışı güncelleştirin. Bu, işi veya çıkış tanımını etkilemeden bir çıkışı kısmen güncelleştirmek (bir veya iki özelliği güncelleştirmek) için kullanılabilir.
az stream-analytics output update --job-name
--name
--resource-group
[--datasource]
[--if-match]
[--serialization]
[--size-window]
[--time-window]
Örnekler
DocumentDB çıkışını güncelleştirme
az stream-analytics output update --job-name "sj2331" --datasource "{\"type\":\"Microsoft.Storage/DocumentDB\",\"properties\":{\"partitionKey\":\"differentPartitionKey\"}}" --output-name "output3022" --resource-group "sjrg7983"
Power BI çıkışını güncelleştirme
az stream-analytics output update --job-name "sj2331" --datasource "{\"type\":\"PowerBI\",\"properties\":{\"dataset\":\"differentDataset\"}}" --output-name "output3022" --resource-group "sjrg7983"
Service Bus Kuyruğu çıkışını Avro serileştirme ile güncelleştirme
az stream-analytics output update --job-name "sj5095" --datasource "{\"type\":\"Microsoft.ServiceBus/Queue\",\"properties\":{\"queueName\":\"differentQueueName\"}}" --serialization "{\"type\":\"Json\",\"properties\":{\"format\":\"LineSeparated\",\"encoding\":\"UTF8\"}}" --output-name "output3456" --resource-group "sjrg3410"
Service Bus Konusu çıkışını CSV serileştirmesi ile güncelleştirme
az stream-analytics output update --job-name "sj7094" --datasource "{\"type\":\"Microsoft.ServiceBus/Topic\",\"properties\":{\"topicName\":\"differentTopicName\"}}" --serialization "{\"type\":\"Csv\",\"properties\":{\"encoding\":\"UTF8\",\"fieldDelimiter\":\"|\"}}" --output-name "output7886" --resource-group "sjrg6450"
CSV serileştirmesi ile blob çıktısı güncelleştirme
az stream-analytics output update --job-name "sj900" --datasource "{\"type\":\"Microsoft.Storage/Blob\",\"properties\":{\"container\":\"differentContainer\"}}" --serialization "{\"type\":\"Csv\",\"properties\":{\"encoding\":\"UTF8\",\"fieldDelimiter\":\"|\"}}" --output-name "output1623" --resource-group "sjrg5023"
JSON serileştirmesi ile Azure Data Lake Store çıkışını güncelleştirme
az stream-analytics output update --job-name "sj3310" --datasource "{\"type\":\"Microsoft.DataLake/Accounts\",\"properties\":{\"accountName\":\"differentaccount\"}}" --serialization "{\"type\":\"Json\",\"properties\":{\"format\":\"LineSeparated\",\"encoding\":\"UTF8\"}}" --output-name "output5195" --resource-group "sjrg6912"
Azure SQL veritabanı çıkışını güncelleştirme
az stream-analytics output update --job-name "sj6458" --datasource "{\"type\":\"Microsoft.Sql/Server/Database\",\"properties\":{\"table\":\"differentTable\"}}" --output-name "output1755" --resource-group "sjrg2157"
Azure Tablo çıkışını güncelleştirme
az stream-analytics output update --job-name "sj2790" --datasource "{\"type\":\"Microsoft.Storage/Table\",\"properties\":{\"partitionKey\":\"differentPartitionKey\"}}" --output-name "output958" --resource-group "sjrg5176"
Olay Hub'ı çıkışını JSON serileştirme ile güncelleştirme
az stream-analytics output update --job-name "sj3310" --datasource "{\"type\":\"Microsoft.ServiceBus/EventHub\",\"properties\":{\"partitionKey\":\"differentPartitionKey\"}}" --serialization "{\"type\":\"Json\",\"properties\":{\"format\":\"LineSeparated\",\"encoding\":\"UTF8\"}}" --output-name "output5195" --resource-group "sjrg6912"
Gerekli Parametreler
Akış işinin adı.
Çıktının adı.
Kaynak grubunun adı. kullanarak varsayılan grubu az configure --defaults group=<name>
yapılandırabilirsiniz.
İsteğe Bağlı Parametreler
Çıktının yazılacağı veri kaynağını açıklar. PUT (CreateOrReplace) isteklerinde gereklidir. Beklenen değer: json-string/json-file/@json-file.
Çıkışın ETag'i. Geçerli çıkışın ü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.
Bir girişten alınan verilerin nasıl serileştirildiği veya çıkışa yazıldığında verilerin nasıl seri hale getirildiği açıklanır. PUT (CreateOrReplace) isteklerinde gereklidir. Beklenen değer: json-string/json-file/@json-file.
Stream Analytics çıkışını kısıtlamak için boyut penceresi.
Stream Analytics iş çıkışlarını filtrelemek için zaman çerçevesi.
Global Parametreler
Tüm hata ayıklama günlüklerini göstermek için günlük ayrıntı düzeyini artırın.
Bu yardım iletisini göster ve çık.
Yalnızca hataları gösterir ve uyarıları gizler.
Çıkış biçimi.
JMESPath sorgu dizesi. Daha fazla bilgi ve örnek için bkz http://jmespath.org/ .
Aboneliğin adı veya kimliği. kullanarak az account set -s NAME_OR_ID
varsayılan aboneliği yapılandırabilirsiniz.
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 output wait
Akış analizi çıktısının bir koşulu karşılanıncaya kadar CLI'yi bekleme durumuna yerleştirin.
az stream-analytics output wait --job-name
--name
--resource-group
[--created]
[--custom]
[--deleted]
[--exists]
[--interval]
[--timeout]
[--updated]
Örnekler
Stream-analytics çıkışı başarıyla oluşturulana kadar CLI betiğinin sonraki satırını yürütmeyi duraklatın.
az stream-analytics output wait --job-name "sj3310" --output-name "output5195" --resource-group "sjrg6912" --created
Gerekli Parametreler
Akış işinin adı.
Çıktının adı.
Kaynak grubunun adı. kullanarak varsayılan grubu az configure --defaults group=<name>
yapılandırabilirsiniz.
İsteğe Bağlı Parametreler
'ProvisioningState' ile 'Succeeded' konumunda oluşturulana kadar bekleyin.
Koşul özel bir JMESPath sorgusunu karşılayana kadar bekleyin. Örneğin provisioningState!='InProgress', instanceView.statuses[?code=='PowerState/running'].
Silinene kadar bekleyin.
Kaynak var olana kadar bekleyin.
Saniye cinsinden yoklama aralığı.
Saniye cinsinden en fazla bekleme.
'Başarılı' konumunda provisioningState ile güncelleştirilene kadar bekleyin.
Global Parametreler
Tüm hata ayıklama günlüklerini göstermek için günlük ayrıntı düzeyini artırın.
Bu yardım iletisini göster ve çık.
Yalnızca hataları gösterir ve uyarıları gizler.
Çıkış biçimi.
JMESPath sorgu dizesi. Daha fazla bilgi ve örnek için bkz http://jmespath.org/ .
Aboneliğin adı veya kimliği. kullanarak az account set -s NAME_OR_ID
varsayılan aboneliği yapılandırabilirsiniz.
Günlük ayrıntı düzeyini artırın. Tam hata ayıklama günlükleri için --debug komutunu kullanın.