az stream-analytics input
Catatan
Referensi ini adalah bagian dari ekstensi stream-analytics untuk Azure CLI (versi 2.15.0 atau yang lebih tinggi). Ekstensi akan secara otomatis menginstal pertama kali Anda menjalankan perintah input az stream-analytics. Pelajari lebih lanjut tentang ekstensi.
Mengelola input dengan analisis aliran.
Perintah
Nama | Deskripsi | Jenis | Status |
---|---|---|---|
az stream-analytics input create |
Buat input atau ganti input yang sudah ada di bawah pekerjaan streaming yang ada. |
Ekstensi | GA |
az stream-analytics input delete |
Menghapus input dari pekerjaan streaming. |
Ekstensi | GA |
az stream-analytics input list |
Cantumkan semua input di bawah pekerjaan streaming yang ditentukan. |
Ekstensi | GA |
az stream-analytics input show |
Dapatkan detail tentang input yang ditentukan. |
Ekstensi | GA |
az stream-analytics input test |
Uji apakah sumber data input dapat dijangkau dan dapat digunakan oleh layanan Azure Stream Analytics. |
Ekstensi | GA |
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 pekerjaan atau definisi input. |
Ekstensi | GA |
az stream-analytics input wait |
Tempatkan CLI dalam status tunggu hingga kondisi input stream-analytics terpenuhi. |
Ekstensi | GA |
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
Nama input.
Nama pekerjaan streaming.
Nama grup sumber daya. Anda dapat mengonfigurasi grup default menggunakan az configure --defaults group=<name>
.
Parameter Opsional
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.
Atur ke '*' untuk mengizinkan input baru dibuat, tetapi untuk mencegah pembaruan input yang ada. Nilai lain akan menghasilkan respons 412 Pra-kondisi Gagal.
Properti yang terkait dengan input. Diperlukan pada permintaan PUT (CreateOrReplace). Nilai yang diharapkan: json-string/json-file/@json-file.
Parameter Global
Meningkatkan verbositas pengelogan untuk menampilkan semua log debug.
Menampilkan pesan bantuan ini dan keluar.
Hanya menampilkan kesalahan, menyembunyikan peringatan.
Format output.
String kueri JMESPath. Lihat http://jmespath.org/ untuk informasi selengkapnya beserta contohnya.
Nama atau ID langganan. Anda dapat mengonfigurasi langganan default menggunakan az account set -s NAME_OR_ID
.
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
Nama input.
Nama pekerjaan streaming.
Nama grup sumber daya. Anda dapat mengonfigurasi grup default menggunakan az configure --defaults group=<name>
.
Parameter Opsional
Jangan meminta konfirmasi.
Parameter Global
Meningkatkan verbositas pengelogan untuk menampilkan semua log debug.
Menampilkan pesan bantuan ini dan keluar.
Hanya menampilkan kesalahan, menyembunyikan peringatan.
Format output.
String kueri JMESPath. Lihat http://jmespath.org/ untuk informasi selengkapnya beserta contohnya.
Nama atau ID langganan. Anda dapat mengonfigurasi langganan default menggunakan az account set -s NAME_OR_ID
.
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 OData $select
az stream-analytics input list --select "*" --job-name "sj7804" --resource-group "sjrg3276"
Parameter yang Diperlukan
Nama pekerjaan streaming.
Nama grup sumber daya. Anda dapat mengonfigurasi grup default menggunakan az configure --defaults group=<name>
.
Parameter Opsional
Parameter kueri OData $select. 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
Meningkatkan verbositas pengelogan untuk menampilkan semua log debug.
Menampilkan pesan bantuan ini dan keluar.
Hanya menampilkan kesalahan, menyembunyikan peringatan.
Format output.
String kueri JMESPath. Lihat http://jmespath.org/ untuk informasi selengkapnya beserta contohnya.
Nama atau ID langganan. Anda dapat mengonfigurasi langganan default menggunakan az account set -s NAME_OR_ID
.
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
Nama input.
Nama pekerjaan streaming.
Nama grup sumber daya. Anda dapat mengonfigurasi grup default menggunakan az configure --defaults group=<name>
.
Parameter Global
Meningkatkan verbositas pengelogan untuk menampilkan semua log debug.
Menampilkan pesan bantuan ini dan keluar.
Hanya menampilkan kesalahan, menyembunyikan peringatan.
Format output.
String kueri JMESPath. Lihat http://jmespath.org/ untuk informasi selengkapnya beserta contohnya.
Nama atau ID langganan. Anda dapat mengonfigurasi langganan default menggunakan az account set -s NAME_OR_ID
.
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
Nama input.
Nama pekerjaan streaming.
Nama grup sumber daya. Anda dapat mengonfigurasi grup default menggunakan az configure --defaults group=<name>
.
Parameter Opsional
Jangan menunggu operasi jangka panjang selesai.
Properti yang terkait dengan input. Diperlukan pada permintaan PUT (CreateOrReplace). Nilai yang diharapkan: json-string/json-file/@json-file.
Parameter Global
Meningkatkan verbositas pengelogan untuk menampilkan semua log debug.
Menampilkan pesan bantuan ini dan keluar.
Hanya menampilkan kesalahan, menyembunyikan peringatan.
Format output.
String kueri JMESPath. Lihat http://jmespath.org/ untuk informasi selengkapnya beserta contohnya.
Nama atau ID langganan. Anda dapat mengonfigurasi langganan default menggunakan az account set -s NAME_OR_ID
.
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 pekerjaan atau definisi 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 Hub 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
Nama input.
Nama pekerjaan streaming.
Nama grup sumber daya. Anda dapat mengonfigurasi grup default menggunakan az configure --defaults group=<name>
.
Parameter Opsional
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.
Properti yang terkait dengan input. Diperlukan pada permintaan PUT (CreateOrReplace). Nilai yang diharapkan: json-string/json-file/@json-file.
Parameter Global
Meningkatkan verbositas pengelogan untuk menampilkan semua log debug.
Menampilkan pesan bantuan ini dan keluar.
Hanya menampilkan kesalahan, menyembunyikan peringatan.
Format output.
String kueri JMESPath. Lihat http://jmespath.org/ untuk informasi selengkapnya beserta contohnya.
Nama atau ID langganan. Anda dapat mengonfigurasi langganan default menggunakan az account set -s NAME_OR_ID
.
Meningkatkan verbositas pengelogan. Gunakan --debug untuk log waktu lengkap.
az stream-analytics input wait
Tempatkan CLI dalam status tunggu hingga kondisi input stream-analytics 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 stream-analytics berhasil dibuat.
az stream-analytics input wait --input-name "input8899" --job-name "sj6695" --resource-group "sjrg8161" --created
Parameter yang Diperlukan
Nama input.
Nama pekerjaan streaming.
Nama grup sumber daya. Anda dapat mengonfigurasi grup default menggunakan az configure --defaults group=<name>
.
Parameter Opsional
Tunggu hingga dibuat dengan 'provisioningState' di 'Berhasil'.
Tunggu hingga kondisi memenuhi kueri JMESPath kustom. Misalnya provisioningState!='InProgress', instanceView.statuses[?code=='PowerState/running'].
Tunggu hingga dihapus.
Tunggu hingga sumber daya ada.
Interval polling dalam hitungan detik.
Tunggu maksimum dalam detik.
Tunggu hingga diperbarui dengan provisioningState di 'Berhasil'.
Parameter Global
Meningkatkan verbositas pengelogan untuk menampilkan semua log debug.
Menampilkan pesan bantuan ini dan keluar.
Hanya menampilkan kesalahan, menyembunyikan peringatan.
Format output.
String kueri JMESPath. Lihat http://jmespath.org/ untuk informasi selengkapnya beserta contohnya.
Nama atau ID langganan. Anda dapat mengonfigurasi langganan default menggunakan az account set -s NAME_OR_ID
.
Meningkatkan verbositas pengelogan. Gunakan --debug untuk log waktu lengkap.