az stream-analytics input

Başvuru

Not

Bu başvuru, Azure CLI (sürüm 2.15.0 veya üzeri) için stream-analytics uzantısının bir parçasıdır. Uzantı, bir az stream-analytics input komutunu 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

az stream-analytics input create	Giriş oluşturun veya mevcut akış işinin altında zaten var olan bir girişin yerini alır.
az stream-analytics input delete	Akış işinden bir girişi silin.
az stream-analytics input list	Belirtilen akış işinin altındaki tüm girişleri listeleyin.
az stream-analytics input show	Belirtilen girişle ilgili ayrıntıları alın.
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 update	Mevcut akış işinin altındaki mevcut girişi güncelleştirin. Bu, kısmen güncelleştirmek için kullanılabilir (örneğin. bir veya iki özelliği güncelleştirin) kalan işi veya giriş tanımını etkilemeden girişi güncelleştirin.
az stream-analytics input wait	Akış analizi girişinin koşulu karşılanıncaya kadar CLI'yi bekleme durumuna yerleştirin.

az stream-analytics input create

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
                                 --job-name
                                 --resource-group
                                 [--if-match]
                                 [--if-none-match]
                                 [--properties]

Örnekler

CSV serileştirme 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ştirme ile akış Event 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ı. varsayılan grubu kullanarak az configure --defaults group=<name>yapılandırabilirsiniz.

İsteğe Bağlı Parametreler

--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 var olan bir 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şkili ö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.

--help -h

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

--only-show-errors

Yalnızca hataları göster, uyarıları gizle.

--output -o

Çıkış biçimi.

--query

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

--subscription

Aboneliğin adı veya kimliği. kullanarak varsayılan aboneliği az account set -s NAME_OR_IDyapı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.

az stream-analytics input delete

Akış işinden bir girişi silin.

az stream-analytics input delete --input-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ı. varsayılan grubu kullanarak az configure --defaults group=<name>yapılandırabilirsiniz.

İsteğe Bağlı Parametreler

--yes -y

Onay istemde bulunmayın.

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.

--help -h

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

--only-show-errors

Yalnızca hataları göster, uyarıları gizle.

--output -o

Çıkış biçimi.

--query

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

--subscription

Aboneliğin adı veya kimliği. kullanarak varsayılan aboneliği az account set -s NAME_OR_IDyapı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.

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ı. varsayılan grubu kullanarak az configure --defaults group=<name>yapılandırabilirsiniz.

İsteğe Bağlı Parametreler

--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 yalnızca '*' değerini geçerli bir değer olarak 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.

--help -h

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

--only-show-errors

Yalnızca hataları göster, uyarıları gizle.

--output -o

Çıkış biçimi.

--query

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

--subscription

Aboneliğin adı veya kimliği. kullanarak varsayılan aboneliği az account set -s NAME_OR_IDyapı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.

az stream-analytics input show

Belirtilen girişle ilgili ayrıntıları alın.

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

Örnekler

CSV serileştirme ile 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ış Event 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ştirme 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ı. varsayılan grubu kullanarak az configure --defaults group=<name>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.

--help -h

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

--only-show-errors

Yalnızca hataları göster, uyarıları gizle.

--output -o

Çıkış biçimi.

--query

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

--subscription

Aboneliğin adı veya kimliği. kullanarak varsayılan aboneliği az account set -s NAME_OR_IDyapı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.

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
                               --job-name
                               --resource-group
                               [--no-wait]
                               [--properties]

Örnekler

Giriş için bağlantıyı test etme

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ı. varsayılan grubu kullanarak az configure --defaults group=<name>yapılandırabilirsiniz.

İsteğe Bağlı Parametreler

--no-wait

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

--properties

Girişle ilişkili ö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.

--help -h

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

--only-show-errors

Yalnızca hataları göster, uyarıları gizle.

--output -o

Çıkış biçimi.

--query

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

--subscription

Aboneliğin adı veya kimliği. kullanarak varsayılan aboneliği az account set -s NAME_OR_IDyapı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.

az stream-analytics input update

Mevcut akış işinin altındaki mevcut girişi güncelleştirin. Bu, kısmen güncelleştirmek için kullanılabilir (örneğin. bir veya iki özelliği güncelleştirin) kalan işi veya giriş tanımını etkilemeden girişi güncelleştirin.

az stream-analytics input update --input-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ı. varsayılan grubu kullanarak az configure --defaults group=<name>yapılandırabilirsiniz.

İsteğe Bağlı Parametreler

--if-match

--properties

Girişle ilişkili ö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.

--help -h

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

--only-show-errors

Yalnızca hataları göster, uyarıları gizle.

--output -o

Çıkış biçimi.

--query

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

--subscription

Aboneliğin adı veya kimliği. kullanarak varsayılan aboneliği az account set -s NAME_OR_IDyapı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.

az stream-analytics input wait

Akış analizi girişinin koşulu karşılanıncaya kadar CLI'yi bekleme durumuna yerleştirin.

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

Örnekler

Akış analizi 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ı. varsayılan grubu kullanarak az configure --defaults group=<name>yapılandırabilirsiniz.

İsteğe Bağlı Parametreler

--created

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

--custom

Koşul özel bir JMESPath sorgusunu karşılayana kadar bekleyin. Örneğin provisioningState!='InProgress', instanceView.statuses[?code=='PowerState/running'].

--deleted

Silinene kadar bekleyin.

--exists

Kaynak var olana kadar bekleyin.

--interval

Saniye cinsinden yoklama aralığı.

varsayılan değer: 30

--timeout

Saniye cinsinden en fazla bekleme.

varsayılan değer: 3600

--updated

ProvisioningState değeri 'Başarılı' olarak güncelleştirilene kadar bekleyin.

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.

--help -h

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

--only-show-errors

Yalnızca hataları göster, uyarıları gizle.

--output -o

Çıkış biçimi.

--query

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

--subscription

Aboneliğin adı veya kimliği. kullanarak varsayılan aboneliği az account set -s NAME_OR_IDyapı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.