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

--job-name

Akış işinin adı.

--name --output-name -n

Çıkışın adı.

--resource-group -g

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

İsteğe Bağlı Parametreler

--datasource

Çıktının yazılacağı veri kaynağını açıklar. PUT (CreateOrReplace) isteklerinde gereklidir. Beklenen değer: json-string/json-file/@json-file.

--if-match

Çı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.

--if-none-match

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.

--serialization

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.

--size-window

Stream Analytics çıkışını kısıtlamak için boyut penceresi.

--time-window

Stream Analytics işi çıkışlarını filtrelemek için zaman çerçevesi.

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

--job-name

Akış işinin adı.

--name --output-name -n

Çıkışın adı.

--resource-group -g

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

İsteğe Bağlı Parametreler

--yes -y

Onay istemde bulunmayı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

--job-name

Akış işinin adı.

--resource-group -g

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

İsteğe Bağlı Parametreler

--select

$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.

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

--job-name

Akış işinin adı.

--name --output-name -n

Çıkışın adı.

--resource-group -g

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

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

--job-name

Akış işinin adı.

--name --output-name -n

Çıkışın adı.

--resource-group -g

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

İsteğe Bağlı Parametreler

--datasource

Çıktının yazılacağı veri kaynağını açıklar. PUT (CreateOrReplace) isteklerinde gereklidir. Beklenen değer: json-string/json-file/@json-file.

--no-wait

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

--serialization

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.

--size-window

Stream Analytics çıkışını kısıtlamak için boyut penceresi.

--time-window

Stream Analytics işi çıkışlarını filtrelemek için zaman çerçevesi.

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

--job-name

Akış işinin adı.

--name --output-name -n

Çıkışın adı.

--resource-group -g

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

İsteğe Bağlı Parametreler

--datasource

Çıktının yazılacağı veri kaynağını açıklar. PUT (CreateOrReplace) isteklerinde gereklidir. Beklenen değer: json-string/json-file/@json-file.

--if-match

Çı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.

--serialization

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.

--size-window

Stream Analytics çıkışını kısıtlamak için boyut penceresi.

--time-window

Stream Analytics iş çıkışlarını filtrelemek için zaman çerçevesi.

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

--job-name

Akış işinin adı.

--name --output-name -n

Çıktının 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.

--custom

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

--deleted

Silinene kadar bekleyin.

--exists

Kaynak var olana kadar bekleyin.

--interval

Saniye cinsinden yoklama aralığı.

varsayılan değer: 30
--timeout

Saniye cinsinden maksimum bekleme.

varsayılan değer: 3600
--updated

provisioningState değeri 'Başarılı' olarak güncelleştirilene kadar bekleyin.