az stream-analytics input

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 input az stream-analytics . Pelajari lebih lanjut tentang ekstensi.

Mengelola input dengan analisis aliran.

Perintah

az stream-analytics input create	Buat input atau ganti input yang sudah ada di bawah pekerjaan streaming yang ada.
az stream-analytics input delete	Menghapus input dari pekerjaan streaming.
az stream-analytics input list	Cantumkan semua input di bawah pekerjaan streaming yang ditentukan.
az stream-analytics input show	Dapatkan detail tentang input yang ditentukan.
az stream-analytics input test	Uji apakah sumber data input dapat dijangkau dan dapat digunakan oleh layanan Azure Stream Analytics.
az stream-analytics input update	Perbarui input yang ada di bawah pekerjaan streaming yang ada. Ini dapat digunakan untuk memperbarui sebagian (yaitu. memperbarui satu atau dua properti) input tanpa memengaruhi sisa definisi pekerjaan atau input.
az stream-analytics input wait	Tempatkan CLI dalam status menunggu hingga kondisi input analisis aliran terpenuhi.

az stream-analytics input create

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

az stream-analytics input create --input-name
                                 --job-name
                                 --resource-group
                                 [--if-match]
                                 [--if-none-match]
                                 [--properties]

Contoh

Membuat input blob referensi dengan serialisasi CSV

az stream-analytics input create --properties "{\"type\":\"Reference\",\"datasource\":{\"type\":\"Microsoft.Storage/Blob\",\"properties\":{\"container\":\"state\",\"dateFormat\":\"yyyy/MM/dd\",\"pathPattern\":\"{date}/{time}\",\"storageAccounts\":[{\"accountKey\":\"someAccountKey==\",\"accountName\":\"someAccountName\"}],\"timeFormat\":\"HH\"}},\"serialization\":{\"type\":\"Csv\",\"properties\":{\"encoding\":\"UTF8\",\"fieldDelimiter\":\",\"}}}" --input-name "input7225" --job-name "sj9597" --resource-group "sjrg8440"

Membuat input Stream Event Hub dengan serialisasi JSON

az stream-analytics input create --properties "{\"type\":\"Stream\",\"datasource\":{\"type\":\"Microsoft.ServiceBus/EventHub\",\"properties\":{\"consumerGroupName\":\"sdkconsumergroup\",\"eventHubName\":\"sdkeventhub\",\"serviceBusNamespace\":\"sdktest\",\"sharedAccessPolicyKey\":\"someSharedAccessPolicyKey==\",\"sharedAccessPolicyName\":\"RootManageSharedAccessKey\"}},\"serialization\":{\"type\":\"Json\",\"properties\":{\"encoding\":\"UTF8\"}}}" --input-name "input7425" --job-name "sj197" --resource-group "sjrg3139"

Membuat input IoT Hub aliran dengan serialisasi Avro

az stream-analytics input create --properties "{\"type\":\"Stream\",\"datasource\":{\"type\":\"Microsoft.Devices/IotHubs\",\"properties\":{\"consumerGroupName\":\"sdkconsumergroup\",\"endpoint\":\"messages/events\",\"iotHubNamespace\":\"iothub\",\"sharedAccessPolicyKey\":\"sharedAccessPolicyKey=\",\"sharedAccessPolicyName\":\"owner\"}},\"serialization\":{\"type\":\"Avro\"}}" --input-name "input7970" --job-name "sj9742" --resource-group "sjrg3467"

Membuat input blob aliran dengan serialisasi CSV

az stream-analytics input create --properties "{\"type\":\"Stream\",\"datasource\":{\"type\":\"Microsoft.Storage/Blob\",\"properties\":{\"container\":\"state\",\"dateFormat\":\"yyyy/MM/dd\",\"pathPattern\":\"{date}/{time}\",\"sourcePartitionCount\":16,\"storageAccounts\":[{\"accountKey\":\"someAccountKey==\",\"accountName\":\"someAccountName\"}],\"timeFormat\":\"HH\"}},\"serialization\":{\"type\":\"Csv\",\"properties\":{\"encoding\":\"UTF8\",\"fieldDelimiter\":\",\"}}}" --input-name "input8899" --job-name "sj6695" --resource-group "sjrg8161"

Parameter yang Diperlukan

--input-name --name -n

Nama input.

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

--if-match

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

--if-none-match

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

--properties

Properti yang terkait dengan input. Diperlukan pada permintaan PUT (CreateOrReplace). Nilai yang diharapkan: json-string/json-file/@json-file.

Parameter Global

--debug

Meningkatkan verbositas pengelogan untuk menampilkan semua log debug.

--help -h

Menampilkan pesan bantuan ini dan keluar.

--only-show-errors

Hanya menampilkan kesalahan, menyembunyikan peringatan.

--output -o

Format output.

--query

String kueri JMESPath. Lihat http://jmespath.org/ untuk informasi yang lebih lengkap beserta contohnya.

--subscription

Nama atau ID langganan. Anda dapat mengonfigurasi langganan default menggunakan az account set -s NAME_OR_ID.

--verbose

Meningkatkan verbositas pengelogan. Gunakan --debug untuk log waktu lengkap.

az stream-analytics input delete

Menghapus input dari pekerjaan streaming.

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

Contoh

Menghapus input

az stream-analytics input delete --input-name "input7225" --job-name "sj9597" --resource-group "sjrg8440"

Parameter yang Diperlukan

--input-name --name -n

Nama input.

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

--yes -y

Jangan meminta konfirmasi.

Parameter Global

--debug

Meningkatkan verbositas pengelogan untuk menampilkan semua log debug.

--help -h

Menampilkan pesan bantuan ini dan keluar.

--only-show-errors

Hanya menampilkan kesalahan, menyembunyikan peringatan.

--output -o

Format output.

--query

String kueri JMESPath. Lihat http://jmespath.org/ untuk informasi yang lebih lengkap beserta contohnya.

--subscription

Nama atau ID langganan. Anda dapat mengonfigurasi langganan default menggunakan az account set -s NAME_OR_ID.

--verbose

Meningkatkan verbositas pengelogan. Gunakan --debug untuk log waktu lengkap.

az stream-analytics input list

Cantumkan semua input di bawah pekerjaan streaming yang ditentukan.

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

Contoh

Mencantumkan semua input dalam pekerjaan streaming

az stream-analytics input list --job-name "sj9597" --resource-group "sjrg8440"

Mencantumkan semua input dalam pekerjaan streaming dan menyertakan informasi diagnostik menggunakan parameter kueri $select OData

az stream-analytics input list --select "*" --job-name "sj7804" --resource-group "sjrg3276"

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.

Parameter Global

--debug

Meningkatkan verbositas pengelogan untuk menampilkan semua log debug.

--help -h

Menampilkan pesan bantuan ini dan keluar.

--only-show-errors

Hanya menampilkan kesalahan, menyembunyikan peringatan.

--output -o

Format output.

--query

String kueri JMESPath. Lihat http://jmespath.org/ untuk informasi yang lebih lengkap beserta contohnya.

--subscription

Nama atau ID langganan. Anda dapat mengonfigurasi langganan default menggunakan az account set -s NAME_OR_ID.

--verbose

Meningkatkan verbositas pengelogan. Gunakan --debug untuk log waktu lengkap.

az stream-analytics input show

Dapatkan detail tentang input yang ditentukan.

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

Contoh

Mendapatkan input blob referensi dengan serialisasi CSV

az stream-analytics input show --input-name "input7225" --job-name "sj9597" --resource-group "sjrg8440"

Mendapatkan input Stream Event Hub dengan serialisasi JSON

az stream-analytics input show --input-name "input7425" --job-name "sj197" --resource-group "sjrg3139"

Mendapatkan input IoT Hub aliran dengan serialisasi Avro

az stream-analytics input show --input-name "input7970" --job-name "sj9742" --resource-group "sjrg3467"

Mendapatkan input blob aliran dengan serialisasi CSV

az stream-analytics input show --input-name "input8899" --job-name "sj6695" --resource-group "sjrg8161"

Parameter yang Diperlukan

--input-name --name -n

Nama input.

--job-name

Nama pekerjaan streaming.

--resource-group -g

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

Parameter Global

--debug

Meningkatkan verbositas pengelogan untuk menampilkan semua log debug.

--help -h

Menampilkan pesan bantuan ini dan keluar.

--only-show-errors

Hanya menampilkan kesalahan, menyembunyikan peringatan.

--output -o

Format output.

--query

String kueri JMESPath. Lihat http://jmespath.org/ untuk informasi yang lebih lengkap beserta contohnya.

--subscription

Nama atau ID langganan. Anda dapat mengonfigurasi langganan default menggunakan az account set -s NAME_OR_ID.

--verbose

Meningkatkan verbositas pengelogan. Gunakan --debug untuk log waktu lengkap.

az stream-analytics input test

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

az stream-analytics input test --input-name
                               --job-name
                               --resource-group
                               [--no-wait]
                               [--properties]

Contoh

Menguji koneksi untuk input

az stream-analytics input test --input-name "input7225" --job-name "sj9597" --resource-group "sjrg8440"

Parameter yang Diperlukan

--input-name --name -n

Nama input.

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

--no-wait

Jangan menunggu operasi jangka panjang selesai.

--properties

Properti yang terkait dengan input. Diperlukan pada permintaan PUT (CreateOrReplace). Nilai yang diharapkan: json-string/json-file/@json-file.

Parameter Global

--debug

Meningkatkan verbositas pengelogan untuk menampilkan semua log debug.

--help -h

Menampilkan pesan bantuan ini dan keluar.

--only-show-errors

Hanya menampilkan kesalahan, menyembunyikan peringatan.

--output -o

Format output.

--query

String kueri JMESPath. Lihat http://jmespath.org/ untuk informasi yang lebih lengkap beserta contohnya.

--subscription

Nama atau ID langganan. Anda dapat mengonfigurasi langganan default menggunakan az account set -s NAME_OR_ID.

--verbose

Meningkatkan verbositas pengelogan. Gunakan --debug untuk log waktu lengkap.

az stream-analytics input update

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

az stream-analytics input update --input-name
                                 --job-name
                                 --resource-group
                                 [--if-match]
                                 [--properties]

Contoh

Memperbarui input blob referensi

az stream-analytics input update --properties "{\"type\":\"Reference\",\"datasource\":{\"type\":\"Microsoft.Storage/Blob\",\"properties\":{\"container\":\"differentContainer\"}},\"serialization\":{\"type\":\"Csv\",\"properties\":{\"encoding\":\"UTF8\",\"fieldDelimiter\":\"|\"}}}" --input-name "input7225" --job-name "sj9597" --resource-group "sjrg8440"

Memperbarui input Azure Event Hubs stream

az stream-analytics input update --properties "{\"type\":\"Stream\",\"datasource\":{\"type\":\"Microsoft.ServiceBus/EventHub\",\"properties\":{\"consumerGroupName\":\"differentConsumerGroupName\"}},\"serialization\":{\"type\":\"Avro\"}}" --input-name "input7425" --job-name "sj197" --resource-group "sjrg3139"

Memperbarui input IoT Hub aliran

az stream-analytics input update --properties "{\"type\":\"Stream\",\"datasource\":{\"type\":\"Microsoft.Devices/IotHubs\",\"properties\":{\"endpoint\":\"messages/operationsMonitoringEvents\"}},\"serialization\":{\"type\":\"Csv\",\"properties\":{\"encoding\":\"UTF8\",\"fieldDelimiter\":\"|\"}}}" --input-name "input7970" --job-name "sj9742" --resource-group "sjrg3467"

Memperbarui input blob aliran

az stream-analytics input update --properties "{\"type\":\"Stream\",\"datasource\":{\"type\":\"Microsoft.Storage/Blob\",\"properties\":{\"sourcePartitionCount\":32}},\"serialization\":{\"type\":\"Csv\",\"properties\":{\"encoding\":\"UTF8\",\"fieldDelimiter\":\"|\"}}}" --input-name "input8899" --job-name "sj6695" --resource-group "sjrg8161"

Parameter yang Diperlukan

--input-name --name -n

Nama input.

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

--if-match

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

--properties

Properti yang terkait dengan input. Diperlukan pada permintaan PUT (CreateOrReplace). Nilai yang diharapkan: json-string/json-file/@json-file.

Parameter Global

--debug

Meningkatkan verbositas pengelogan untuk menampilkan semua log debug.

--help -h

Menampilkan pesan bantuan ini dan keluar.

--only-show-errors

Hanya menampilkan kesalahan, menyembunyikan peringatan.

--output -o

Format output.

--query

String kueri JMESPath. Lihat http://jmespath.org/ untuk informasi yang lebih lengkap beserta contohnya.

--subscription

Nama atau ID langganan. Anda dapat mengonfigurasi langganan default menggunakan az account set -s NAME_OR_ID.

--verbose

Meningkatkan verbositas pengelogan. Gunakan --debug untuk log waktu lengkap.

az stream-analytics input wait

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

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

Contoh

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

az stream-analytics input wait --input-name "input8899" --job-name "sj6695" --resource-group "sjrg8161" --created

Parameter yang Diperlukan

--input-name --name -n

Nama input.

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

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

Parameter Global

--debug

Meningkatkan verbositas pengelogan untuk menampilkan semua log debug.

--help -h

Menampilkan pesan bantuan ini dan keluar.

--only-show-errors

Hanya menampilkan kesalahan, menyembunyikan peringatan.

--output -o

Format output.

--query

String kueri JMESPath. Lihat http://jmespath.org/ untuk informasi yang lebih lengkap beserta contohnya.

--subscription

Nama atau ID langganan. Anda dapat mengonfigurasi langganan default menggunakan az account set -s NAME_OR_ID.

--verbose

Meningkatkan verbositas pengelogan. Gunakan --debug untuk log waktu lengkap.