az stream-analytics input
Note
Bu başvuru, Azure CLI (sürüm 2.75.0 veya üzeri) için stream-analytics uzantısının bir parçasıdır. uzantı, az stream-analytics input komutu ilk kez çalıştırdığınızda otomatik olarak yüklenir. Uzantılar hakkında daha fazla bilgi edinin.
Akış analizi ile girişi yönetin.
Komutlar
| Name | Description | Tür | Durum |
|---|---|---|---|
| az stream-analytics input create |
Bir giriş oluşturun veya mevcut akış işinin altında zaten var olan bir girişin yerini alır. |
Extension | GA |
| az stream-analytics input delete |
Akış işinden bir girişi silin. |
Extension | GA |
| az stream-analytics input list |
Belirtilen akış işinin altındaki tüm girişleri listeleyin. |
Extension | GA |
| az stream-analytics input show |
Belirtilen girişle ilgili ayrıntıları alın. |
Extension | GA |
| az stream-analytics input test |
Bir girişin veri kaynağının Azure Stream Analytics hizmeti tarafından erişilebilir ve kullanılabilir olup olmadığını test edin. |
Extension | GA |
| az stream-analytics input update |
Mevcut bir akış işinin altındaki mevcut girişi güncelleştirin. Bu, işi veya giriş tanımını etkilemeden bir girişi kısmen güncelleştirmek (bir veya iki özelliği güncelleştirmek) için kullanılabilir. |
Extension | GA |
| az stream-analytics input wait |
Akış analizi girişinin bir koşulu karşılanıncaya kadar CLI'yi bekleme durumuna yerleştirin. |
Extension | GA |
az stream-analytics input create
Bir giriş oluşturun veya mevcut akış işinin altında zaten var olan bir girişin yerini alır.
az stream-analytics input create --input-name --name
--job-name
--resource-group
[--if-match]
[--if-none-match]
[--properties]
Örnekler
CSV serileştirmesi ile başvuru blobu girişi oluşturma
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"
JSON serileştirmesi ile akış Olay Hub'ı girişi oluşturma
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"
Avro serileştirme ile akış IoT Hub girişi oluşturma
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"
CSV serileştirmesi ile akış blobu girişi oluşturma
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"
Gerekli Parametreler
Girişin adı.
Akış işinin adı.
Kaynak grubunun adı.
az configure --defaults group=<name>kullanarak varsayılan grubu yapılandırabilirsiniz.
İsteğe Bağlı Parametreler
Aşağıdaki parametreler isteğe bağlıdır, ancak bağlama bağlı olarak komutun başarıyla yürütülmesi için bir veya daha fazla parametre gerekli olabilir.
Girişin ETag'i. Geçerli girişin ü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 girişin oluşturulmasına izin vermek, ancak mevcut girişin 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şle ilişkilendirilmiş özellikler. PUT (CreateOrReplace) isteklerinde gereklidir. Beklenen değer: json-string/json-file/@json-file.
Global Parametreler
Tüm hata ayıklama günlüklerini göstermek için günlük ayrıntı düzeyini artırın.
| Özellik | Değer |
|---|---|
| Default value: | False |
Bu yardım iletisini göster ve çık.
Yalnızca hataları gösterir ve uyarıları gizler.
| Özellik | Değer |
|---|---|
| Default value: | False |
Çıkış biçimi.
| Özellik | Değer |
|---|---|
| Default value: | json |
| Kabul edilen değerler: | json, jsonc, none, table, tsv, yaml, yamlc |
JMESPath sorgu dizesi. Daha fazla bilgi ve örnek için bkz. http://jmespath.org/.
Aboneliğin adı veya kimliği.
az account set -s NAME_OR_IDkullanarak varsayılan aboneliği yapı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.
| Özellik | Değer |
|---|---|
| Default value: | False |
az stream-analytics input delete
Akış işinden bir girişi silin.
az stream-analytics input delete --input-name --name
--job-name
--resource-group
[--yes]
Örnekler
Girişi silme
az stream-analytics input delete --input-name "input7225" --job-name "sj9597" --resource-group "sjrg8440"
Gerekli Parametreler
Girişin adı.
Akış işinin adı.
Kaynak grubunun adı.
az configure --defaults group=<name>kullanarak varsayılan grubu yapılandırabilirsiniz.
İsteğe Bağlı Parametreler
Aşağıdaki parametreler isteğe bağlıdır, ancak bağlama bağlı olarak komutun başarıyla yürütülmesi için bir veya daha fazla parametre gerekli olabilir.
Onay istemde bulunmayın.
| Özellik | Değer |
|---|---|
| Default value: | False |
Global Parametreler
Tüm hata ayıklama günlüklerini göstermek için günlük ayrıntı düzeyini artırın.
| Özellik | Değer |
|---|---|
| Default value: | False |
Bu yardım iletisini göster ve çık.
Yalnızca hataları gösterir ve uyarıları gizler.
| Özellik | Değer |
|---|---|
| Default value: | False |
Çıkış biçimi.
| Özellik | Değer |
|---|---|
| Default value: | json |
| Kabul edilen değerler: | json, jsonc, none, table, tsv, yaml, yamlc |
JMESPath sorgu dizesi. Daha fazla bilgi ve örnek için bkz. http://jmespath.org/.
Aboneliğin adı veya kimliği.
az account set -s NAME_OR_IDkullanarak varsayılan aboneliği yapı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.
| Özellik | Değer |
|---|---|
| Default value: | False |
az stream-analytics input list
Belirtilen akış işinin altındaki tüm girişleri listeleyin.
az stream-analytics input list --job-name
--resource-group
[--select]
Örnekler
Akış işinde tüm girişleri listeleme
az stream-analytics input list --job-name "sj9597" --resource-group "sjrg8440"
Akış işindeki tüm girişleri listeleme ve $select OData sorgu parametresini kullanarak tanılama bilgilerini dahil etme
az stream-analytics input list --select "*" --job-name "sj7804" --resource-group "sjrg3276"
Gerekli Parametreler
Akış işinin adı.
Kaynak grubunun adı.
az configure --defaults group=<name>kullanarak varsayılan grubu yapılandırabilirsiniz.
İsteğe Bağlı Parametreler
Aşağıdaki parametreler isteğe bağlıdır, ancak bağlama bağlı olarak komutun başarıyla yürütülmesi için bir veya daha fazla parametre gerekli olabilir.
$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 geçerli bir değer olarak yalnızca '' kabul eder.
Global Parametreler
Tüm hata ayıklama günlüklerini göstermek için günlük ayrıntı düzeyini artırın.
| Özellik | Değer |
|---|---|
| Default value: | False |
Bu yardım iletisini göster ve çık.
Yalnızca hataları gösterir ve uyarıları gizler.
| Özellik | Değer |
|---|---|
| Default value: | False |
Çıkış biçimi.
| Özellik | Değer |
|---|---|
| Default value: | json |
| Kabul edilen değerler: | json, jsonc, none, table, tsv, yaml, yamlc |
JMESPath sorgu dizesi. Daha fazla bilgi ve örnek için bkz. http://jmespath.org/.
Aboneliğin adı veya kimliği.
az account set -s NAME_OR_IDkullanarak varsayılan aboneliği yapı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.
| Özellik | Değer |
|---|---|
| Default value: | False |
az stream-analytics input show
Belirtilen girişle ilgili ayrıntıları alın.
az stream-analytics input show --input-name --name
--job-name
--resource-group
Örnekler
CSV serileştirmesi ile bir başvuru blobu girişi alma
az stream-analytics input show --input-name "input7225" --job-name "sj9597" --resource-group "sjrg8440"
JSON serileştirme ile akış Olay Hub'ı girişi alma
az stream-analytics input show --input-name "input7425" --job-name "sj197" --resource-group "sjrg3139"
Avro serileştirme ile akış IoT Hub girişi alma
az stream-analytics input show --input-name "input7970" --job-name "sj9742" --resource-group "sjrg3467"
CSV serileştirmesi ile akış blobu girişi alma
az stream-analytics input show --input-name "input8899" --job-name "sj6695" --resource-group "sjrg8161"
Gerekli Parametreler
Girişin adı.
Akış işinin adı.
Kaynak grubunun adı.
az configure --defaults group=<name>kullanarak varsayılan grubu yapılandırabilirsiniz.
Global Parametreler
Tüm hata ayıklama günlüklerini göstermek için günlük ayrıntı düzeyini artırın.
| Özellik | Değer |
|---|---|
| Default value: | False |
Bu yardım iletisini göster ve çık.
Yalnızca hataları gösterir ve uyarıları gizler.
| Özellik | Değer |
|---|---|
| Default value: | False |
Çıkış biçimi.
| Özellik | Değer |
|---|---|
| Default value: | json |
| Kabul edilen değerler: | json, jsonc, none, table, tsv, yaml, yamlc |
JMESPath sorgu dizesi. Daha fazla bilgi ve örnek için bkz. http://jmespath.org/.
Aboneliğin adı veya kimliği.
az account set -s NAME_OR_IDkullanarak varsayılan aboneliği yapı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.
| Özellik | Değer |
|---|---|
| Default value: | False |
az stream-analytics input test
Bir girişin veri kaynağının Azure Stream Analytics hizmeti tarafından erişilebilir ve kullanılabilir olup olmadığını test edin.
az stream-analytics input test --input-name --name
--job-name
--resource-group
[--no-wait]
[--properties]
Örnekler
Giriş için bağlantıyı test edin
az stream-analytics input test --input-name "input7225" --job-name "sj9597" --resource-group "sjrg8440"
Gerekli Parametreler
Girişin adı.
Akış işinin adı.
Kaynak grubunun adı.
az configure --defaults group=<name>kullanarak varsayılan grubu yapılandırabilirsiniz.
İsteğe Bağlı Parametreler
Aşağıdaki parametreler isteğe bağlıdır, ancak bağlama bağlı olarak komutun başarıyla yürütülmesi için bir veya daha fazla parametre gerekli olabilir.
Uzun süre çalışan işlemin bitmesini beklemeyin.
| Özellik | Değer |
|---|---|
| Default value: | False |
Girişle ilişkilendirilmiş özellikler. PUT (CreateOrReplace) isteklerinde gereklidir. Beklenen değer: json-string/json-file/@json-file.
Global Parametreler
Tüm hata ayıklama günlüklerini göstermek için günlük ayrıntı düzeyini artırın.
| Özellik | Değer |
|---|---|
| Default value: | False |
Bu yardım iletisini göster ve çık.
Yalnızca hataları gösterir ve uyarıları gizler.
| Özellik | Değer |
|---|---|
| Default value: | False |
Çıkış biçimi.
| Özellik | Değer |
|---|---|
| Default value: | json |
| Kabul edilen değerler: | json, jsonc, none, table, tsv, yaml, yamlc |
JMESPath sorgu dizesi. Daha fazla bilgi ve örnek için bkz. http://jmespath.org/.
Aboneliğin adı veya kimliği.
az account set -s NAME_OR_IDkullanarak varsayılan aboneliği yapı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.
| Özellik | Değer |
|---|---|
| Default value: | False |
az stream-analytics input update
Mevcut bir akış işinin altındaki mevcut girişi güncelleştirin. Bu, işi veya giriş tanımını etkilemeden bir girişi kısmen güncelleştirmek (bir veya iki özelliği güncelleştirmek) için kullanılabilir.
az stream-analytics input update --input-name --name
--job-name
--resource-group
[--if-match]
[--properties]
Örnekler
Başvuru blobu girişini güncelleştirme
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"
Akış Olay Hub'ı girişini güncelleştirme
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"
Akış IoT Hub girişini güncelleştirme
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"
Akış blobu girişini güncelleştirme
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"
Gerekli Parametreler
Girişin adı.
Akış işinin adı.
Kaynak grubunun adı.
az configure --defaults group=<name>kullanarak varsayılan grubu yapılandırabilirsiniz.
İsteğe Bağlı Parametreler
Aşağıdaki parametreler isteğe bağlıdır, ancak bağlama bağlı olarak komutun başarıyla yürütülmesi için bir veya daha fazla parametre gerekli olabilir.
Girişin ETag'i. Geçerli girişin ü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şle ilişkilendirilmiş özellikler. PUT (CreateOrReplace) isteklerinde gereklidir. Beklenen değer: json-string/json-file/@json-file.
Global Parametreler
Tüm hata ayıklama günlüklerini göstermek için günlük ayrıntı düzeyini artırın.
| Özellik | Değer |
|---|---|
| Default value: | False |
Bu yardım iletisini göster ve çık.
Yalnızca hataları gösterir ve uyarıları gizler.
| Özellik | Değer |
|---|---|
| Default value: | False |
Çıkış biçimi.
| Özellik | Değer |
|---|---|
| Default value: | json |
| Kabul edilen değerler: | json, jsonc, none, table, tsv, yaml, yamlc |
JMESPath sorgu dizesi. Daha fazla bilgi ve örnek için bkz. http://jmespath.org/.
Aboneliğin adı veya kimliği.
az account set -s NAME_OR_IDkullanarak varsayılan aboneliği yapı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.
| Özellik | Değer |
|---|---|
| Default value: | False |
az stream-analytics input wait
Akış analizi girişinin bir koşulu karşılanıncaya kadar CLI'yi bekleme durumuna yerleştirin.
az stream-analytics input wait --input-name --name
--job-name
--resource-group
[--created]
[--custom]
[--deleted]
[--exists]
[--interval]
[--timeout]
[--updated]
Örnekler
Stream-analytics girişi başarıyla oluşturulana kadar CLI betiğinin sonraki satırını yürütmeyi duraklatın.
az stream-analytics input wait --input-name "input8899" --job-name "sj6695" --resource-group "sjrg8161" --created
Gerekli Parametreler
Girişin adı.
Akış işinin adı.
Kaynak grubunun adı.
az configure --defaults group=<name>kullanarak varsayılan grubu yapılandırabilirsiniz.
İsteğe Bağlı Parametreler
Aşağıdaki parametreler isteğe bağlıdır, ancak bağlama bağlı olarak komutun başarıyla yürütülmesi için bir veya daha fazla parametre gerekli olabilir.
'ProvisioningState' ile 'Succeeded' konumunda oluşturulana kadar bekleyin.
| Özellik | Değer |
|---|---|
| Parametre grubu: | Wait Condition Arguments |
| Default value: | False |
Koşul özel bir JMESPath sorgusunu karşılayana kadar bekleyin. Örneğin provisioningState!='InProgress', instanceView.statuses[?code=='PowerState/running'].
| Özellik | Değer |
|---|---|
| Parametre grubu: | Wait Condition Arguments |
Silinene kadar bekleyin.
| Özellik | Değer |
|---|---|
| Parametre grubu: | Wait Condition Arguments |
| Default value: | False |
Kaynak var olana kadar bekleyin.
| Özellik | Değer |
|---|---|
| Parametre grubu: | Wait Condition Arguments |
| Default value: | False |
Saniye cinsinden yoklama aralığı.
| Özellik | Değer |
|---|---|
| Parametre grubu: | Wait Condition Arguments |
| Default value: | 30 |
Saniye cinsinden en fazla bekleme.
| Özellik | Değer |
|---|---|
| Parametre grubu: | Wait Condition Arguments |
| Default value: | 3600 |
'Başarılı' konumunda provisioningState ile güncelleştirilene kadar bekleyin.
| Özellik | Değer |
|---|---|
| Parametre grubu: | Wait Condition Arguments |
| Default value: | False |
Global Parametreler
Tüm hata ayıklama günlüklerini göstermek için günlük ayrıntı düzeyini artırın.
| Özellik | Değer |
|---|---|
| Default value: | False |
Bu yardım iletisini göster ve çık.
Yalnızca hataları gösterir ve uyarıları gizler.
| Özellik | Değer |
|---|---|
| Default value: | False |
Çıkış biçimi.
| Özellik | Değer |
|---|---|
| Default value: | json |
| Kabul edilen değerler: | json, jsonc, none, table, tsv, yaml, yamlc |
JMESPath sorgu dizesi. Daha fazla bilgi ve örnek için bkz. http://jmespath.org/.
Aboneliğin adı veya kimliği.
az account set -s NAME_OR_IDkullanarak varsayılan aboneliği yapı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.
| Özellik | Değer |
|---|---|
| Default value: | False |