Share via

az stream-analytics input

  • 參考

注意

此參考是 Azure CLI 串流分析延伸模組的一部分（2.15.0 版或更高版本）。 擴充功能會在您第一次執行 az stream-analytics input 命令時自動安裝。 深入了解擴充功能。

使用串流分析管理輸入。

命令

名稱 Description 類型 狀態
az stream-analytics input create

建立輸入，或取代現有串流作業下已經存在的輸入。

 副檔名 GA
az stream-analytics input delete

從串流作業刪除輸入。

 副檔名 GA
az stream-analytics input list

列出指定串流作業下的所有輸入。

 副檔名 GA
az stream-analytics input show

取得指定輸入的詳細數據。

 副檔名 GA
az stream-analytics input test

測試輸入的數據源是否可供 Azure 串流分析服務存取及使用。

 副檔名 GA
az stream-analytics input update

在現有的串流作業下更新現有的輸入。 這可以用來部分更新 （即更新一或兩個屬性） 輸入，而不會影響其餘的工作或輸入定義。

 副檔名 GA
az stream-analytics input wait

將 CLI 置於等候狀態，直到符合串流分析輸入的條件為止。

 副檔名 GA

az stream-analytics input create

建立輸入，或取代現有串流作業下已經存在的輸入。

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

範例

使用 CSV 串行化建立參考 Blob 輸入

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 串行化建立串流事件中樞輸入

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 串行化建立資料流 IoT 中樞 輸入

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 串行化建立串流 Blob 輸入

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"

必要參數

--input-name --name -n

輸入的名稱。

--job-name

串流作業的名稱。

--resource-group -g

資源群組的名稱。 您可以使用 來設定預設群組 az configure --defaults group=<name>。

選擇性參數

--if-match

輸入的 ETag。 請省略此值以一律覆寫目前的輸入。 指定最後看到的 ETag 值，以防止意外覆寫並行變更。

--if-none-match

設定為 『*』 以允許建立新的輸入，但為了避免更新現有的輸入。 其他值會導致 412 前置條件失敗的回應。

--properties

與輸入相關聯的屬性。 PUT （CreateOrReplace） 要求的必要專案。 預期值：json-string/json-file/@json-file。

全域參數
--debug

增加記錄詳細資訊，以顯示所有偵錯記錄。

--help -h

顯示此說明訊息並結束。

--only-show-errors

只顯示錯誤，隱藏警告。

--output -o

輸出格式。

接受的值: json, jsonc, none, table, tsv, yaml, yamlc
預設值: json
--query

JMESPath 查詢字串。 如需詳細資訊和範例，請參閱 http://jmespath.org/。

--subscription

訂用帳戶的名稱或標識碼。 您可以使用 來設定預設訂用 az account set -s NAME_OR_ID帳戶。

--verbose

增加記錄詳細資訊。 使用 --debug 來取得完整偵錯記錄。

az stream-analytics input delete

從串流作業刪除輸入。

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

範例

刪除輸入

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

必要參數

--input-name --name -n

輸入的名稱。

--job-name

串流作業的名稱。

--resource-group -g

資源群組的名稱。 您可以使用 來設定預設群組 az configure --defaults group=<name>。

選擇性參數

--yes -y

不提示確認。

預設值: False
全域參數
--debug

增加記錄詳細資訊，以顯示所有偵錯記錄。

--help -h

顯示此說明訊息並結束。

--only-show-errors

只顯示錯誤，隱藏警告。

--output -o

輸出格式。

接受的值: json, jsonc, none, table, tsv, yaml, yamlc
預設值: json
--query

JMESPath 查詢字串。 如需詳細資訊和範例，請參閱 http://jmespath.org/。

--subscription

訂用帳戶的名稱或標識碼。 您可以使用 來設定預設訂用 az account set -s NAME_OR_ID帳戶。

--verbose

增加記錄詳細資訊。 使用 --debug 來取得完整偵錯記錄。

az stream-analytics input list

列出指定串流作業下的所有輸入。

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

範例

列出串流作業中的所有輸入

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

列出串流作業中的所有輸入，並使用 $select OData 查詢參數包含診斷資訊

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

必要參數

--job-name

串流作業的名稱。

--resource-group -g

資源群組的名稱。 您可以使用 來設定預設群組 az configure --defaults group=<name>。

選擇性參數

--select

$select OData 查詢參數。 這是要包含在回應中的結構屬性逗號分隔清單，或 「以包含所有屬性」。根據預設，除了診斷之外，會傳回所有屬性。目前只接受 『' 做為有效值。

全域參數
--debug

增加記錄詳細資訊，以顯示所有偵錯記錄。

--help -h

顯示此說明訊息並結束。

--only-show-errors

只顯示錯誤，隱藏警告。

--output -o

輸出格式。

接受的值: json, jsonc, none, table, tsv, yaml, yamlc
預設值: json
--query

JMESPath 查詢字串。 如需詳細資訊和範例，請參閱 http://jmespath.org/。

--subscription

訂用帳戶的名稱或標識碼。 您可以使用 來設定預設訂用 az account set -s NAME_OR_ID帳戶。

--verbose

增加記錄詳細資訊。 使用 --debug 來取得完整偵錯記錄。

az stream-analytics input show

取得指定輸入的詳細數據。

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

範例

使用 CSV 串行化取得參考 Blob 輸入

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

使用 JSON 串行化取得串流事件中樞輸入

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

使用 Avro 串行化取得數據流 IoT 中樞 輸入

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

使用 CSV 串行化取得串流 Blob 輸入

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

必要參數

--input-name --name -n

輸入的名稱。

--job-name

串流作業的名稱。

--resource-group -g

資源群組的名稱。 您可以使用 來設定預設群組 az configure --defaults group=<name>。

全域參數
--debug

增加記錄詳細資訊，以顯示所有偵錯記錄。

--help -h

顯示此說明訊息並結束。

--only-show-errors

只顯示錯誤，隱藏警告。

--output -o

輸出格式。

接受的值: json, jsonc, none, table, tsv, yaml, yamlc
預設值: json
--query

JMESPath 查詢字串。 如需詳細資訊和範例，請參閱 http://jmespath.org/。

--subscription

訂用帳戶的名稱或標識碼。 您可以使用 來設定預設訂用 az account set -s NAME_OR_ID帳戶。

--verbose

增加記錄詳細資訊。 使用 --debug 來取得完整偵錯記錄。

az stream-analytics input test

測試輸入的數據源是否可供 Azure 串流分析服務存取及使用。

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

範例

測試輸入的連接

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

必要參數

--input-name --name -n

輸入的名稱。

--job-name

串流作業的名稱。

--resource-group -g

資源群組的名稱。 您可以使用 來設定預設群組 az configure --defaults group=<name>。

選擇性參數

--no-wait

請勿等候長時間執行的作業完成。

預設值: False
--properties

與輸入相關聯的屬性。 PUT （CreateOrReplace） 要求的必要專案。 預期值：json-string/json-file/@json-file。

全域參數
--debug

增加記錄詳細資訊，以顯示所有偵錯記錄。

--help -h

顯示此說明訊息並結束。

--only-show-errors

只顯示錯誤，隱藏警告。

--output -o

輸出格式。

接受的值: json, jsonc, none, table, tsv, yaml, yamlc
預設值: json
--query

JMESPath 查詢字串。 如需詳細資訊和範例，請參閱 http://jmespath.org/。

--subscription

訂用帳戶的名稱或標識碼。 您可以使用 來設定預設訂用 az account set -s NAME_OR_ID帳戶。

--verbose

增加記錄詳細資訊。 使用 --debug 來取得完整偵錯記錄。

az stream-analytics input update

在現有的串流作業下更新現有的輸入。 這可以用來部分更新 （即更新一或兩個屬性） 輸入，而不會影響其餘的工作或輸入定義。

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

範例

更新參考 Blob 輸入

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"

更新串流事件中樞輸入

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"

更新數據流 IoT 中樞 輸入

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"

更新串流 Blob 輸入

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"

必要參數

--input-name --name -n

輸入的名稱。

--job-name

串流作業的名稱。

--resource-group -g

資源群組的名稱。 您可以使用 來設定預設群組 az configure --defaults group=<name>。

選擇性參數

--if-match

輸入的 ETag。 請省略此值以一律覆寫目前的輸入。 指定最後看到的 ETag 值，以防止意外覆寫並行變更。

--properties

與輸入相關聯的屬性。 PUT （CreateOrReplace） 要求的必要專案。 預期值：json-string/json-file/@json-file。

全域參數
--debug

增加記錄詳細資訊，以顯示所有偵錯記錄。

--help -h

顯示此說明訊息並結束。

--only-show-errors

只顯示錯誤，隱藏警告。

--output -o

輸出格式。

接受的值: json, jsonc, none, table, tsv, yaml, yamlc
預設值: json
--query

JMESPath 查詢字串。 如需詳細資訊和範例，請參閱 http://jmespath.org/。

--subscription

訂用帳戶的名稱或標識碼。 您可以使用 來設定預設訂用 az account set -s NAME_OR_ID帳戶。

--verbose

增加記錄詳細資訊。 使用 --debug 來取得完整偵錯記錄。

az stream-analytics input wait

將 CLI 置於等候狀態，直到符合串流分析輸入的條件為止。

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

範例

暫停執行下一行 CLI 腳本，直到成功建立串流分析輸入為止。

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

必要參數

--input-name --name -n

輸入的名稱。

--job-name

串流作業的名稱。

--resource-group -g

資源群組的名稱。 您可以使用 來設定預設群組 az configure --defaults group=<name>。

選擇性參數

--created

請等候在 'Succeeded' 使用 'provisioningState' 建立。

預設值: False
--custom

等到條件符合自定義 JMESPath 查詢為止。 例如 provisioningState！='InProgress'， instanceView.statuses[？code=='PowerState/running']。

--deleted

等到刪除為止。

預設值: False
--exists

等候資源存在。

預設值: False
--interval

輪詢間隔以秒為單位。

預設值: 30
--timeout

以秒為單位的等候上限。

預設值: 3600
--updated

等到 provisioningState 更新為 'Succeeded'。

預設值: False
全域參數
--debug

增加記錄詳細資訊，以顯示所有偵錯記錄。

--help -h

顯示此說明訊息並結束。

--only-show-errors

只顯示錯誤，隱藏警告。

--output -o

輸出格式。

接受的值: json, jsonc, none, table, tsv, yaml, yamlc
預設值: json
--query

JMESPath 查詢字串。 如需詳細資訊和範例，請參閱 http://jmespath.org/。

--subscription

訂用帳戶的名稱或標識碼。 您可以使用 來設定預設訂用 az account set -s NAME_OR_ID帳戶。

--verbose

增加記錄詳細資訊。 使用 --debug 來取得完整偵錯記錄。