Aracılığıyla paylaş


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

--input-name --name -n

Girişin adı.

--job-name

Akış işinin adı.

--resource-group -g

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.

--if-match

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.

--if-none-match

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.

--properties

Girişle ilişkilendirilmiş özellikler. PUT (CreateOrReplace) isteklerinde gereklidir. Beklenen değer: json-string/json-file/@json-file.

Global Parametreler
--debug

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

Bu yardım iletisini göster ve çık.

--only-show-errors

Yalnızca hataları gösterir ve uyarıları gizler.

Özellik Değer
Default value: False
--output -o

Çıkış biçimi.

Özellik Değer
Default value: json
Kabul edilen değerler: json, jsonc, none, table, tsv, yaml, yamlc
--query

JMESPath sorgu dizesi. Daha fazla bilgi ve örnek için bkz. http://jmespath.org/.

--subscription

Aboneliğin adı veya kimliği. az account set -s NAME_OR_IDkullanarak varsayılan aboneliği yapılandırabilirsiniz.

--verbose

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

--input-name --name -n

Girişin adı.

--job-name

Akış işinin adı.

--resource-group -g

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.

--yes -y

Onay istemde bulunmayın.

Özellik Değer
Default value: False
Global Parametreler
--debug

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

Bu yardım iletisini göster ve çık.

--only-show-errors

Yalnızca hataları gösterir ve uyarıları gizler.

Özellik Değer
Default value: False
--output -o

Çıkış biçimi.

Özellik Değer
Default value: json
Kabul edilen değerler: json, jsonc, none, table, tsv, yaml, yamlc
--query

JMESPath sorgu dizesi. Daha fazla bilgi ve örnek için bkz. http://jmespath.org/.

--subscription

Aboneliğin adı veya kimliği. az account set -s NAME_OR_IDkullanarak varsayılan aboneliği yapılandırabilirsiniz.

--verbose

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

--job-name

Akış işinin adı.

--resource-group -g

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

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

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

Bu yardım iletisini göster ve çık.

--only-show-errors

Yalnızca hataları gösterir ve uyarıları gizler.

Özellik Değer
Default value: False
--output -o

Çıkış biçimi.

Özellik Değer
Default value: json
Kabul edilen değerler: json, jsonc, none, table, tsv, yaml, yamlc
--query

JMESPath sorgu dizesi. Daha fazla bilgi ve örnek için bkz. http://jmespath.org/.

--subscription

Aboneliğin adı veya kimliği. az account set -s NAME_OR_IDkullanarak varsayılan aboneliği yapılandırabilirsiniz.

--verbose

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

--input-name --name -n

Girişin adı.

--job-name

Akış işinin adı.

--resource-group -g

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

Global Parametreler
--debug

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

Bu yardım iletisini göster ve çık.

--only-show-errors

Yalnızca hataları gösterir ve uyarıları gizler.

Özellik Değer
Default value: False
--output -o

Çıkış biçimi.

Özellik Değer
Default value: json
Kabul edilen değerler: json, jsonc, none, table, tsv, yaml, yamlc
--query

JMESPath sorgu dizesi. Daha fazla bilgi ve örnek için bkz. http://jmespath.org/.

--subscription

Aboneliğin adı veya kimliği. az account set -s NAME_OR_IDkullanarak varsayılan aboneliği yapılandırabilirsiniz.

--verbose

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

--input-name --name -n

Girişin adı.

--job-name

Akış işinin adı.

--resource-group -g

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.

--no-wait

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

Özellik Değer
Default value: False
--properties

Girişle ilişkilendirilmiş özellikler. PUT (CreateOrReplace) isteklerinde gereklidir. Beklenen değer: json-string/json-file/@json-file.

Global Parametreler
--debug

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

Bu yardım iletisini göster ve çık.

--only-show-errors

Yalnızca hataları gösterir ve uyarıları gizler.

Özellik Değer
Default value: False
--output -o

Çıkış biçimi.

Özellik Değer
Default value: json
Kabul edilen değerler: json, jsonc, none, table, tsv, yaml, yamlc
--query

JMESPath sorgu dizesi. Daha fazla bilgi ve örnek için bkz. http://jmespath.org/.

--subscription

Aboneliğin adı veya kimliği. az account set -s NAME_OR_IDkullanarak varsayılan aboneliği yapılandırabilirsiniz.

--verbose

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

--input-name --name -n

Girişin adı.

--job-name

Akış işinin adı.

--resource-group -g

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.

--if-match

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.

--properties

Girişle ilişkilendirilmiş özellikler. PUT (CreateOrReplace) isteklerinde gereklidir. Beklenen değer: json-string/json-file/@json-file.

Global Parametreler
--debug

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

Bu yardım iletisini göster ve çık.

--only-show-errors

Yalnızca hataları gösterir ve uyarıları gizler.

Özellik Değer
Default value: False
--output -o

Çıkış biçimi.

Özellik Değer
Default value: json
Kabul edilen değerler: json, jsonc, none, table, tsv, yaml, yamlc
--query

JMESPath sorgu dizesi. Daha fazla bilgi ve örnek için bkz. http://jmespath.org/.

--subscription

Aboneliğin adı veya kimliği. az account set -s NAME_OR_IDkullanarak varsayılan aboneliği yapılandırabilirsiniz.

--verbose

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

--input-name --name -n

Girişin adı.

--job-name

Akış işinin adı.

--resource-group -g

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.

--created

'ProvisioningState' ile 'Succeeded' konumunda oluşturulana kadar bekleyin.

Özellik Değer
Parametre grubu: Wait Condition Arguments
Default value: False
--custom

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

Silinene kadar bekleyin.

Özellik Değer
Parametre grubu: Wait Condition Arguments
Default value: False
--exists

Kaynak var olana kadar bekleyin.

Özellik Değer
Parametre grubu: Wait Condition Arguments
Default value: False
--interval

Saniye cinsinden yoklama aralığı.

Özellik Değer
Parametre grubu: Wait Condition Arguments
Default value: 30
--timeout

Saniye cinsinden en fazla bekleme.

Özellik Değer
Parametre grubu: Wait Condition Arguments
Default value: 3600
--updated

'Başarılı' konumunda provisioningState ile güncelleştirilene kadar bekleyin.

Özellik Değer
Parametre grubu: Wait Condition Arguments
Default value: False
Global Parametreler
--debug

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

Bu yardım iletisini göster ve çık.

--only-show-errors

Yalnızca hataları gösterir ve uyarıları gizler.

Özellik Değer
Default value: False
--output -o

Çıkış biçimi.

Özellik Değer
Default value: json
Kabul edilen değerler: json, jsonc, none, table, tsv, yaml, yamlc
--query

JMESPath sorgu dizesi. Daha fazla bilgi ve örnek için bkz. http://jmespath.org/.

--subscription

Aboneliğin adı veya kimliği. az account set -s NAME_OR_IDkullanarak varsayılan aboneliği yapılandırabilirsiniz.

--verbose

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