az stream-analytics output

Catatan

Referensi ini adalah bagian dari ekstensi analisis aliran untuk Azure CLI (versi 2.15.0 atau yang lebih tinggi). Ekstensi akan secara otomatis menginstal saat pertama kali Anda menjalankan perintah output az stream-analytics . Pelajari lebih lanjut tentang ekstensi.

Mengelola output dengan analisis aliran.

Perintah

az stream-analytics output create

Buat output atau ganti output yang sudah ada di bawah pekerjaan streaming yang ada.

az stream-analytics output delete

Menghapus output dari pekerjaan streaming.

az stream-analytics output list

Cantumkan semua output di bawah pekerjaan streaming yang ditentukan.

az stream-analytics output show

Dapatkan detail tentang output yang ditentukan.

az stream-analytics output test

Uji apakah sumber data output dapat dijangkau dan dapat digunakan oleh layanan Azure Stream Analytics.

az stream-analytics output update

Perbarui output yang ada di bawah pekerjaan streaming yang ada. Ini dapat digunakan untuk memperbarui sebagian (yaitu. memperbarui satu atau dua properti) output tanpa memengaruhi sisa definisi pekerjaan atau output.

az stream-analytics output wait

Tempatkan CLI dalam status menunggu hingga kondisi output analisis aliran terpenuhi.

az stream-analytics output create

Buat output atau ganti output yang sudah ada di bawah pekerjaan streaming yang ada.

az stream-analytics output create --job-name
                                  --name
                                  --resource-group
                                  [--datasource]
                                  [--if-match]
                                  [--if-none-match]
                                  [--serialization]
                                  [--size-window]
                                  [--time-window]

Contoh

Membuat output DocumentDB

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"

Membuat output Power BI

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"

Membuat output antrean Bus Layanan dengan serialisasi Avro

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"

Membuat output Topik Bus Layanan dengan serialisasi CSV

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"

Membuat output blob dengan serialisasi CSV

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"

Membuat output Azure Data Lake Store dengan serialisasi JSON

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"

Membuat output database Azure SQL

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"

Membuat output Azure Table

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"

Membuat output Event Hub dengan serialisasi JSON

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"

Parameter yang Diperlukan

--job-name

Nama pekerjaan streaming.

--name --output-name -n

Nama output.

--resource-group -g

Nama grup sumber daya. Anda dapat mengonfigurasi grup default menggunakan az configure --defaults group=<name>.

Parameter Opsional

--datasource

Menjelaskan sumber data tempat output akan ditulis. Diperlukan pada permintaan PUT (CreateOrReplace). Nilai yang diharapkan: json-string/json-file/@json-file.

--if-match

ETag output. Hilangkan nilai ini untuk selalu menimpa output saat ini. Tentukan nilai ETag yang terakhir dilihat untuk mencegah penimpaan perubahan bersamaan secara tidak sengaja.

--if-none-match

Atur ke '*' untuk memungkinkan output baru dibuat, tetapi untuk mencegah pembaruan output yang ada. Nilai lain akan menghasilkan respons 412 Pra-kondisi Gagal.

--serialization

Menjelaskan bagaimana data dari input diserialisasikan atau bagaimana data diserialisasikan saat ditulis ke output. Diperlukan pada permintaan PUT (CreateOrReplace). Nilai yang diharapkan: json-string/json-file/@json-file.

--size-window

Jendela ukuran untuk membatasi output Azure Stream Analytics.

--time-window

Jangka waktu untuk memfilter output pekerjaan Azure Stream Analytics.

az stream-analytics output delete

Menghapus output dari pekerjaan streaming.

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

Contoh

Menghapus output

az stream-analytics output delete --job-name "sj6458" --name "output1755" --resource-group "sjrg2157"

Parameter yang Diperlukan

--job-name

Nama pekerjaan streaming.

--name --output-name -n

Nama output.

--resource-group -g

Nama grup sumber daya. Anda dapat mengonfigurasi grup default menggunakan az configure --defaults group=<name>.

Parameter Opsional

--yes -y

Jangan meminta konfirmasi.

az stream-analytics output list

Cantumkan semua output di bawah pekerjaan streaming yang ditentukan.

az stream-analytics output list --job-name
                                --resource-group
                                [--select]

Contoh

Mencantumkan semua output dalam pekerjaan streaming

az stream-analytics output list --job-name "sj6458" --resource-group "sjrg2157"

Parameter yang Diperlukan

--job-name

Nama pekerjaan streaming.

--resource-group -g

Nama grup sumber daya. Anda dapat mengonfigurasi grup default menggunakan az configure --defaults group=<name>.

Parameter Opsional

--select

Parameter kueri $select OData. Ini adalah daftar properti struktural yang dipisahkan koma untuk disertakan dalam respons, atau "*" untuk menyertakan semua properti. Secara default, semua properti dikembalikan kecuali diagnostik. Saat ini hanya menerima '*' sebagai nilai yang valid.

az stream-analytics output show

Dapatkan detail tentang output yang ditentukan.

az stream-analytics output show --job-name
                                --name
                                --resource-group

Contoh

Mendapatkan output DocumentDB

az stream-analytics output show --job-name "sj2331" --output-name "output3022" --resource-group "sjrg7983"

Mendapatkan output Power BI

az stream-analytics output show --job-name "sj2331" --output-name "output3022" --resource-group "sjrg7983"

Mendapatkan output antrean Bus Layanan dengan serialisasi Avro

az stream-analytics output show --job-name "sj5095" --output-name "output3456" --resource-group "sjrg3410"

Mendapatkan output Topik Bus Layanan dengan serialisasi CSV

az stream-analytics output show --job-name "sj7094" --output-name "output7886" --resource-group "sjrg6450"

Mendapatkan output blob dengan serialisasi CSV

az stream-analytics output show --job-name "sj900" --output-name "output1623" --resource-group "sjrg5023"

Mendapatkan output Azure Data Lake Store dengan serialisasi JSON

az stream-analytics output show --job-name "sj3310" --output-name "output5195" --resource-group "sjrg6912"

Mendapatkan output Azure Data Warehouse

az stream-analytics output show --job-name "sjName" --output-name "output958" --resource-group "sjrg"

Mendapatkan output database Azure SQL

az stream-analytics output show --job-name "sj6458" --output-name "output1755" --resource-group "sjrg2157"

Mendapatkan output Azure Table

az stream-analytics output show --job-name "sj2790" --output-name "output958" --resource-group "sjrg5176"

Mendapatkan output Event Hub dengan serialisasi JSON

az stream-analytics output show --job-name "sj3310" --output-name "output5195" --resource-group "sjrg6912"

Parameter yang Diperlukan

--job-name

Nama pekerjaan streaming.

--name --output-name -n

Nama output.

--resource-group -g

Nama grup sumber daya. Anda dapat mengonfigurasi grup default menggunakan az configure --defaults group=<name>.

az stream-analytics output test

Uji apakah sumber data output dapat dijangkau dan dapat digunakan oleh layanan Azure Stream Analytics.

az stream-analytics output test --job-name
                                --name
                                --resource-group
                                [--datasource]
                                [--no-wait]
                                [--serialization]
                                [--size-window]
                                [--time-window]

Contoh

Menguji koneksi untuk output

az stream-analytics output test --job-name "sj6458" --output-name "output1755" --resource-group "sjrg2157"

Parameter yang Diperlukan

--job-name

Nama pekerjaan streaming.

--name --output-name -n

Nama output.

--resource-group -g

Nama grup sumber daya. Anda dapat mengonfigurasi grup default menggunakan az configure --defaults group=<name>.

Parameter Opsional

--datasource

Menjelaskan sumber data tempat output akan ditulis. Diperlukan pada permintaan PUT (CreateOrReplace). Nilai yang diharapkan: json-string/json-file/@json-file.

--no-wait

Jangan menunggu operasi jangka panjang selesai.

--serialization

Menjelaskan bagaimana data dari input diserialisasikan atau bagaimana data diserialisasikan saat ditulis ke output. Diperlukan pada permintaan PUT (CreateOrReplace). Nilai yang diharapkan: json-string/json-file/@json-file.

--size-window

Jendela ukuran untuk membatasi output Azure Stream Analytics.

--time-window

Jangka waktu untuk memfilter output pekerjaan Azure Stream Analytics.

az stream-analytics output update

Perbarui output yang ada di bawah pekerjaan streaming yang ada. Ini dapat digunakan untuk memperbarui sebagian (yaitu. memperbarui satu atau dua properti) output tanpa memengaruhi sisa definisi pekerjaan atau output.

az stream-analytics output update --job-name
                                  --name
                                  --resource-group
                                  [--datasource]
                                  [--if-match]
                                  [--serialization]
                                  [--size-window]
                                  [--time-window]

Contoh

Memperbarui output DocumentDB

az stream-analytics output update --job-name "sj2331" --datasource "{\"type\":\"Microsoft.Storage/DocumentDB\",\"properties\":{\"partitionKey\":\"differentPartitionKey\"}}" --output-name "output3022" --resource-group "sjrg7983"

Memperbarui output Power BI

az stream-analytics output update --job-name "sj2331" --datasource "{\"type\":\"PowerBI\",\"properties\":{\"dataset\":\"differentDataset\"}}" --output-name "output3022" --resource-group "sjrg7983"

Memperbarui output antrean Bus Layanan dengan serialisasi Avro

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"

Memperbarui output Topik Bus Layanan dengan serialisasi CSV

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"

Memperbarui output blob dengan serialisasi CSV

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"

Memperbarui output Azure Data Lake Store dengan serialisasi JSON

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"

Memperbarui output database Azure SQL

az stream-analytics output update --job-name "sj6458" --datasource "{\"type\":\"Microsoft.Sql/Server/Database\",\"properties\":{\"table\":\"differentTable\"}}" --output-name "output1755" --resource-group "sjrg2157"

Memperbarui output Tabel Azure

az stream-analytics output update --job-name "sj2790" --datasource "{\"type\":\"Microsoft.Storage/Table\",\"properties\":{\"partitionKey\":\"differentPartitionKey\"}}" --output-name "output958" --resource-group "sjrg5176"

Memperbarui output Event Hub dengan serialisasi JSON

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"

Parameter yang Diperlukan

--job-name

Nama pekerjaan streaming.

--name --output-name -n

Nama output.

--resource-group -g

Nama grup sumber daya. Anda dapat mengonfigurasi grup default menggunakan az configure --defaults group=<name>.

Parameter Opsional

--datasource

Menjelaskan sumber data tempat output akan ditulis. Diperlukan pada permintaan PUT (CreateOrReplace). Nilai yang diharapkan: json-string/json-file/@json-file.

--if-match

ETag output. Hilangkan nilai ini untuk selalu menimpa output saat ini. Tentukan nilai ETag yang terakhir dilihat untuk mencegah penimpaan perubahan bersamaan secara tidak sengaja.

--serialization

Menjelaskan bagaimana data dari input diserialisasikan atau bagaimana data diserialisasikan saat ditulis ke output. Diperlukan pada permintaan PUT (CreateOrReplace). Nilai yang diharapkan: json-string/json-file/@json-file.

--size-window

Jendela ukuran untuk membatasi output Azure Stream Analytics.

--time-window

Jangka waktu untuk memfilter output pekerjaan Azure Stream Analytics.

az stream-analytics output wait

Tempatkan CLI dalam status menunggu hingga kondisi output analisis aliran terpenuhi.

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

Contoh

Jeda menjalankan baris skrip CLI berikutnya hingga output analisis aliran berhasil dibuat.

az stream-analytics output wait --job-name "sj3310" --output-name "output5195" --resource-group "sjrg6912" --created

Parameter yang Diperlukan

--job-name

Nama pekerjaan streaming.

--name --output-name -n

Nama output.

--resource-group -g

Nama grup sumber daya. Anda dapat mengonfigurasi grup default menggunakan az configure --defaults group=<name>.

Parameter Opsional

--created

Tunggu hingga dibuat dengan 'provisioningState' di 'Berhasil'.

--custom

Tunggu hingga kondisi memenuhi kueri JMESPath kustom. Mis. provisioningState!='InProgress', instanceView.statuses[?code=='PowerState/running'].

--deleted

Tunggu hingga dihapus.

--exists

Tunggu hingga sumber daya ada.

--interval

Interval polling dalam hitungan detik.

nilai default: 30
--timeout

Waktu tunggu maksimum dalam detik.

nilai default: 3600
--updated

Tunggu hingga diperbarui dengan provisioningState di 'Berhasil'.