az stream-analytics output
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 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
| az stream-analytics output create |
Bir çıkış oluşturun veya mevcut akış işinin altında zaten var olan bir çıkışın yerini alır. |
| az stream-analytics output delete |
Akış işinden bir çıktıyı silin. |
| az stream-analytics output list |
Belirtilen akış işinin altındaki tüm çıkışları listeleyin. |
| az stream-analytics output show |
Belirtilen çıkışla ilgili ayrıntıları alın. |
| az stream-analytics output test |
Bir çıkışı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 update |
Mevcut akış işinin altındaki mevcut çıkışı güncelleştirin. Bu, kısmen güncelleştirmek için kullanılabilir (örneğin. bir veya iki özelliği güncelleştirin) kalan işi veya çıktı tanımını etkilemeden bir çıktı. |
| az stream-analytics output wait |
Akış analizi çıkışının bir koşulu karşılanıncaya kadar CLI'yi bekleme durumuna yerleştirin. |
az stream-analytics output create
Bir çıkış oluşturun veya mevcut 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ştirme ile Service Bus Konu çı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ştirme 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ı.
Çıkışın adı.
Kaynak grubunun adı. varsayılan grubu kullanarak 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.
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şi çıkışlarını filtrelemek için zaman çerçevesi.
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, 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. varsayılan aboneliğini kullanarak az account set -s NAME_OR_IDyapı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
Çıkışı silme
az stream-analytics output delete --job-name "sj6458" --name "output1755" --resource-group "sjrg2157"
Gerekli Parametreler
Akış işinin adı.
Çıkışın adı.
Kaynak grubunun adı. varsayılan grubu kullanarak az configure --defaults group=<name>yapılandırabilirsiniz.
İsteğe Bağlı Parametreler
Onay istemde bulunmayın.
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, 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. varsayılan aboneliğini kullanarak az account set -s NAME_OR_IDyapı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ı. varsayılan grubu kullanarak 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 eklemek 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.
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, 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. varsayılan aboneliğini kullanarak az account set -s NAME_OR_IDyapı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 Konu çıktısı alma
az stream-analytics output show --job-name "sj7094" --output-name "output7886" --resource-group "sjrg6450"
CSV serileştirme 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 Data Warehouse çıkışı alma
az stream-analytics output show --job-name "sjName" --output-name "output958" --resource-group "sjrg"
Azure SQL veritabanı çıkışı alma
az stream-analytics output show --job-name "sj6458" --output-name "output1755" --resource-group "sjrg2157"
Azure Tablosu çı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ı.
Çıkışın adı.
Kaynak grubunun adı. varsayılan grubu kullanarak az configure --defaults group=<name>yapılandırabilirsiniz.
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, 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. varsayılan aboneliğini kullanarak az account set -s NAME_OR_IDyapı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 çıkışı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 etme
az stream-analytics output test --job-name "sj6458" --output-name "output1755" --resource-group "sjrg2157"
Gerekli Parametreler
Akış işinin adı.
Çıkışın adı.
Kaynak grubunun adı. varsayılan grubu kullanarak 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.
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şi çıkışlarını filtrelemek için zaman çerçevesi.
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, 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. varsayılan aboneliğini kullanarak az account set -s NAME_OR_IDyapı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 akış işinin altındaki mevcut çıkışı güncelleştirin. Bu, kısmen güncelleştirmek için kullanılabilir (örneğin. bir veya iki özelliği güncelleştirin) kalan işi veya çıktı tanımını etkilemeden bir çıktı.
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"
Avro serileştirme ile Service Bus Kuyruğu çıkışını 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"
csv serileştirme ile bir Service Bus Konu çıktısı 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ştirme ile blob çıkışını 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"
Azure Data Lake Store çıkışını JSON serileştirme ile 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ı.
Çıkışın adı.
Kaynak grubunun adı. varsayılan grubu kullanarak 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.
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.
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, 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. varsayılan aboneliğini kullanarak az account set -s NAME_OR_IDyapı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 çıkışı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 maksimum bekleme.
provisioningState değeri 'Başarılı' olarak güncelleştirilene kadar bekleyin.
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, 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. varsayılan aboneliğini kullanarak az account set -s NAME_OR_IDyapı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.