共用方式為


az stream-analytics input

Note

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

使用串流分析管理輸入。

命令

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

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

Extension GA
az stream-analytics input delete

從串流作業刪除輸入。

Extension GA
az stream-analytics input list

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

Extension GA
az stream-analytics input show

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

Extension GA
az stream-analytics input test

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

Extension GA
az stream-analytics input update

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

Extension GA
az stream-analytics input wait

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

Extension GA

az stream-analytics input create

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

az stream-analytics input create --input-name --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

提高日誌詳細程度以顯示所有調試日誌。

屬性
預設值: False
--help -h

顯示此說明訊息並結束。

--only-show-errors

只顯示錯誤,隱藏警告。

屬性
預設值: False
--output -o

輸出格式。

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

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

--subscription

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

--verbose

增加記錄的詳細程度。 針對完整偵錯記錄使用 --debug。

屬性
預設值: False

az stream-analytics input delete

從串流作業刪除輸入。

az stream-analytics input delete --input-name --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

提高日誌詳細程度以顯示所有調試日誌。

屬性
預設值: False
--help -h

顯示此說明訊息並結束。

--only-show-errors

只顯示錯誤,隱藏警告。

屬性
預設值: False
--output -o

輸出格式。

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

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

--subscription

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

--verbose

增加記錄的詳細程度。 針對完整偵錯記錄使用 --debug。

屬性
預設值: False

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

提高日誌詳細程度以顯示所有調試日誌。

屬性
預設值: False
--help -h

顯示此說明訊息並結束。

--only-show-errors

只顯示錯誤,隱藏警告。

屬性
預設值: False
--output -o

輸出格式。

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

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

--subscription

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

--verbose

增加記錄的詳細程度。 針對完整偵錯記錄使用 --debug。

屬性
預設值: False

az stream-analytics input show

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

az stream-analytics input show --input-name --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

提高日誌詳細程度以顯示所有調試日誌。

屬性
預設值: False
--help -h

顯示此說明訊息並結束。

--only-show-errors

只顯示錯誤,隱藏警告。

屬性
預設值: False
--output -o

輸出格式。

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

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

--subscription

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

--verbose

增加記錄的詳細程度。 針對完整偵錯記錄使用 --debug。

屬性
預設值: False

az stream-analytics input test

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

az stream-analytics input test --input-name --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

提高日誌詳細程度以顯示所有調試日誌。

屬性
預設值: False
--help -h

顯示此說明訊息並結束。

--only-show-errors

只顯示錯誤,隱藏警告。

屬性
預設值: False
--output -o

輸出格式。

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

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

--subscription

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

--verbose

增加記錄的詳細程度。 針對完整偵錯記錄使用 --debug。

屬性
預設值: False

az stream-analytics input update

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

az stream-analytics input update --input-name --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

提高日誌詳細程度以顯示所有調試日誌。

屬性
預設值: False
--help -h

顯示此說明訊息並結束。

--only-show-errors

只顯示錯誤,隱藏警告。

屬性
預設值: False
--output -o

輸出格式。

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

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

--subscription

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

--verbose

增加記錄的詳細程度。 針對完整偵錯記錄使用 --debug。

屬性
預設值: False

az stream-analytics input wait

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

az stream-analytics input wait --input-name --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' 建立。

屬性
參數群組: Wait Condition Arguments
預設值: False
--custom

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

屬性
參數群組: Wait Condition Arguments
--deleted

等到刪除為止。

屬性
參數群組: Wait Condition Arguments
預設值: False
--exists

等候資源存在。

屬性
參數群組: Wait Condition Arguments
預設值: False
--interval

輪詢間隔以秒為單位。

屬性
參數群組: Wait Condition Arguments
預設值: 30
--timeout

以秒為單位的等候上限。

屬性
參數群組: Wait Condition Arguments
預設值: 3600
--updated

等到 provisioningState 更新為 'Succeeded'。

屬性
參數群組: Wait Condition Arguments
預設值: False
全域參數
--debug

提高日誌詳細程度以顯示所有調試日誌。

屬性
預設值: False
--help -h

顯示此說明訊息並結束。

--only-show-errors

只顯示錯誤,隱藏警告。

屬性
預設值: False
--output -o

輸出格式。

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

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

--subscription

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

--verbose

增加記錄的詳細程度。 針對完整偵錯記錄使用 --debug。

屬性
預設值: False