az stream-analytics output
注意
此參考是 Azure CLI 串流分析 延伸模組的一部分 (2.15.0 版或更高版本)。 擴充功能會在您第一次執行 az stream-analytics 輸出 命令時自動安裝。 深入了解擴充功能。
使用串流分析管理輸出。
命令
名稱 | Description | 類型 | 狀態 |
---|---|---|---|
az stream-analytics output create |
建立輸出,或取代現有串流作業下已經存在的輸出。 |
副檔名 | GA |
az stream-analytics output delete |
刪除串流作業的輸出。 |
副檔名 | GA |
az stream-analytics output list |
列出指定串流作業下的所有輸出。 |
副檔名 | GA |
az stream-analytics output show |
取得指定輸出的詳細數據。 |
副檔名 | GA |
az stream-analytics output test |
測試輸出的數據源是否可供 Azure 串流分析服務存取及使用。 |
副檔名 | GA |
az stream-analytics output update |
在現有的串流作業下更新現有的輸出。 這可以用來部分更新 (即更新一或兩個屬性) 輸出,而不會影響其餘的作業或輸出定義。 |
副檔名 | GA |
az stream-analytics output wait |
將 CLI 置於等候狀態,直到符合串流分析輸出的條件為止。 |
副檔名 | GA |
az stream-analytics output create
建立輸出,或取代現有串流作業下已經存在的輸出。
az stream-analytics output create --job-name
--name
--resource-group
[--datasource]
[--if-match]
[--if-none-match]
[--serialization]
[--size-window]
[--time-window]
範例
建立 DocumentDB 輸出
az stream-analytics output create --job-name "sj2331" --datasource "{\"type\":\"Microsoft.Storage/DocumentDB\",\"properties\":{\"accountId\":\"someAccountId\",\"accountKey\":\"accountKey==\",\"collectionNamePattern\":\"collection\",\"database\":\"db01\",\"documentId\":\"documentId\",\"partitionKey\":\"key\"}}" --output-name "output3022" --resource-group "sjrg7983"
建立 Power BI 輸出
az stream-analytics output create --job-name "sj2331" --datasource "{\"type\":\"PowerBI\",\"properties\":{\"dataset\":\"someDataset\",\"groupId\":\"ac40305e-3e8d-43ac-8161-c33799f43e95\",\"groupName\":\"MyPowerBIGroup\",\"refreshToken\":\"someRefreshToken==\",\"table\":\"someTable\",\"tokenUserDisplayName\":\"Bob Smith\",\"tokenUserPrincipalName\":\"bobsmith@contoso.com\"}}" --output-name "output3022" --resource-group "sjrg7983"
使用 Avro 串行化建立 服務匯流排 佇列輸出
az stream-analytics output create --job-name "sj5095" --datasource "{\"type\":\"Microsoft.ServiceBus/Queue\",\"properties\":{\"propertyColumns\":[\"column1\",\"column2\"],\"queueName\":\"sdkqueue\",\"serviceBusNamespace\":\"sdktest\",\"sharedAccessPolicyKey\":\"sharedAccessPolicyKey=\",\"sharedAccessPolicyName\":\"RootManageSharedAccessKey\",\"systemPropertyColumns\":{\"MessageId\":\"col3\",\"PartitionKey\":\"col4\"}}}" --serialization "{\"type\":\"Avro\"}" --output-name "output3456" --resource-group "sjrg3410"
使用 CSV 串行化建立 服務匯流排 主題輸出
az stream-analytics output create --job-name "sj7094" --datasource "{\"type\":\"Microsoft.ServiceBus/Topic\",\"properties\":{\"propertyColumns\":[\"column1\",\"column2\"],\"serviceBusNamespace\":\"sdktest\",\"sharedAccessPolicyKey\":\"sharedAccessPolicyKey=\",\"sharedAccessPolicyName\":\"RootManageSharedAccessKey\",\"topicName\":\"sdktopic\"}}" --serialization "{\"type\":\"Csv\",\"properties\":{\"encoding\":\"UTF8\",\"fieldDelimiter\":\",\"}}" --output-name "output7886" --resource-group "sjrg6450"
使用 CSV 串行化建立 Blob 輸出
az stream-analytics output create --job-name "sj900" --datasource "{\"type\":\"Microsoft.Storage/Blob\",\"properties\":{\"container\":\"state\",\"dateFormat\":\"yyyy/MM/dd\",\"pathPattern\":\"{date}/{time}\",\"storageAccounts\":[{\"accountKey\":\"accountKey==\",\"accountName\":\"someAccountName\"}],\"timeFormat\":\"HH\"}}" --serialization "{\"type\":\"Csv\",\"properties\":{\"encoding\":\"UTF8\",\"fieldDelimiter\":\",\"}}" --output-name "output1623" --resource-group "sjrg5023"
使用 JSON 串行化建立 Azure Data Lake Store 輸出
az stream-analytics output create --job-name "sj3310" --datasource "{\"type\":\"Microsoft.DataLake/Accounts\",\"properties\":{\"accountName\":\"someaccount\",\"dateFormat\":\"yyyy/MM/dd\",\"filePathPrefix\":\"{date}/{time}\",\"refreshToken\":\"someRefreshToken==\",\"tenantId\":\"cea4e98b-c798-49e7-8c40-4a2b3beb47dd\",\"timeFormat\":\"HH\",\"tokenUserDisplayName\":\"Bob Smith\",\"tokenUserPrincipalName\":\"bobsmith@contoso.com\"}}" --serialization "{\"type\":\"Json\",\"properties\":{\"format\":\"Array\",\"encoding\":\"UTF8\"}}" --output-name "output5195" --resource-group "sjrg6912"
建立 Azure SQL 資料庫輸出
az stream-analytics output create --job-name "sj6458" --datasource "{\"type\":\"Microsoft.Sql/Server/Database\",\"properties\":{\"database\":\"someDatabase\",\"password\":\"somePassword\",\"server\":\"someServer\",\"table\":\"someTable\",\"user\":\"<user>\"}}" --output-name "output1755" --resource-group "sjrg2157"
建立 Azure 資料表輸出
az stream-analytics output create --job-name "sj2790" --datasource "{\"type\":\"Microsoft.Storage/Table\",\"properties\":{\"accountKey\":\"accountKey==\",\"accountName\":\"someAccountName\",\"batchSize\":25,\"columnsToRemove\":[\"column1\",\"column2\"],\"partitionKey\":\"partitionKey\",\"rowKey\":\"rowKey\",\"table\":\"samples\"}}" --output-name "output958" --resource-group "sjrg5176"
使用 JSON 串行化建立事件中樞輸出
az stream-analytics output create --job-name "sj3310" --datasource "{\"type\":\"Microsoft.ServiceBus/EventHub\",\"properties\":{\"eventHubName\":\"sdkeventhub\",\"partitionKey\":\"partitionKey\",\"serviceBusNamespace\":\"sdktest\",\"sharedAccessPolicyKey\":\"sharedAccessPolicyKey=\",\"sharedAccessPolicyName\":\"RootManageSharedAccessKey\"}}" --serialization "{\"type\":\"Json\",\"properties\":{\"format\":\"Array\",\"encoding\":\"UTF8\"}}" --output-name "output5195" --resource-group "sjrg6912"
必要參數
串流作業的名稱。
輸出的名稱。
資源群組的名稱。 您可以使用 來設定預設群組 az configure --defaults group=<name>
。
選擇性參數
描述將寫入輸出的數據源。 PUT (CreateOrReplace) 要求的必要專案。 預期值:json-string/json-file/@json-file。
輸出的ETag。 請省略此值以一律覆寫目前的輸出。 指定最後看到的 ETag 值,以防止意外覆寫並行變更。
設定為 『*』 以允許建立新的輸出,但為了避免更新現有的輸出。 其他值會導致 412 前置條件失敗的回應。
描述如何串行化輸入中的數據,或將數據寫入輸出時如何串行化。 PUT (CreateOrReplace) 要求的必要專案。 預期值:json-string/json-file/@json-file。
要限制串流分析輸出的大小視窗。
篩選串流分析作業輸出的時間範圍。
全域參數
增加記錄詳細資訊,以顯示所有偵錯記錄。
顯示此說明訊息並結束。
只顯示錯誤,隱藏警告。
輸出格式。
JMESPath 查詢字串。 如需詳細資訊和範例,請參閱 http://jmespath.org/。
訂用帳戶的名稱或識別碼。 您可以使用 來設定預設訂用 az account set -s NAME_OR_ID
帳戶。
增加記錄詳細資訊。 使用 --debug 來取得完整偵錯記錄。
az stream-analytics output delete
刪除串流作業的輸出。
az stream-analytics output delete --job-name
--name
--resource-group
[--yes]
範例
刪除輸出
az stream-analytics output delete --job-name "sj6458" --name "output1755" --resource-group "sjrg2157"
必要參數
串流作業的名稱。
輸出的名稱。
資源群組的名稱。 您可以使用 來設定預設群組 az configure --defaults group=<name>
。
選擇性參數
不提示確認。
全域參數
增加記錄詳細資訊,以顯示所有偵錯記錄。
顯示此說明訊息並結束。
只顯示錯誤,隱藏警告。
輸出格式。
JMESPath 查詢字串。 如需詳細資訊和範例,請參閱 http://jmespath.org/。
訂用帳戶的名稱或識別碼。 您可以使用 來設定預設訂用 az account set -s NAME_OR_ID
帳戶。
增加記錄詳細資訊。 使用 --debug 來取得完整偵錯記錄。
az stream-analytics output list
列出指定串流作業下的所有輸出。
az stream-analytics output list --job-name
--resource-group
[--select]
範例
列出串流作業中的所有輸出
az stream-analytics output list --job-name "sj6458" --resource-group "sjrg2157"
必要參數
串流作業的名稱。
資源群組的名稱。 您可以使用 來設定預設群組 az configure --defaults group=<name>
。
選擇性參數
$select OData 查詢參數。 這是要包含在回應中的結構屬性逗號分隔清單,或 「以包含所有屬性」。根據預設,除了診斷之外,會傳回所有屬性。目前只接受 『' 做為有效值。
全域參數
增加記錄詳細資訊,以顯示所有偵錯記錄。
顯示此說明訊息並結束。
只顯示錯誤,隱藏警告。
輸出格式。
JMESPath 查詢字串。 如需詳細資訊和範例,請參閱 http://jmespath.org/。
訂用帳戶的名稱或識別碼。 您可以使用 來設定預設訂用 az account set -s NAME_OR_ID
帳戶。
增加記錄詳細資訊。 使用 --debug 來取得完整偵錯記錄。
az stream-analytics output show
取得指定輸出的詳細數據。
az stream-analytics output show --job-name
--name
--resource-group
範例
取得 DocumentDB 輸出
az stream-analytics output show --job-name "sj2331" --output-name "output3022" --resource-group "sjrg7983"
取得 Power BI 輸出
az stream-analytics output show --job-name "sj2331" --output-name "output3022" --resource-group "sjrg7983"
使用 Avro 串行化取得 服務匯流排 佇列輸出
az stream-analytics output show --job-name "sj5095" --output-name "output3456" --resource-group "sjrg3410"
使用 CSV 串行化取得 服務匯流排 主題輸出
az stream-analytics output show --job-name "sj7094" --output-name "output7886" --resource-group "sjrg6450"
使用 CSV 串行化取得 Blob 輸出
az stream-analytics output show --job-name "sj900" --output-name "output1623" --resource-group "sjrg5023"
使用 JSON 串行化取得 Azure Data Lake Store 輸出
az stream-analytics output show --job-name "sj3310" --output-name "output5195" --resource-group "sjrg6912"
取得 Azure 數據倉儲輸出
az stream-analytics output show --job-name "sjName" --output-name "output958" --resource-group "sjrg"
取得 Azure SQL 資料庫輸出
az stream-analytics output show --job-name "sj6458" --output-name "output1755" --resource-group "sjrg2157"
取得 Azure 資料表輸出
az stream-analytics output show --job-name "sj2790" --output-name "output958" --resource-group "sjrg5176"
使用 JSON 串行化取得事件中樞輸出
az stream-analytics output show --job-name "sj3310" --output-name "output5195" --resource-group "sjrg6912"
必要參數
串流作業的名稱。
輸出的名稱。
資源群組的名稱。 您可以使用 來設定預設群組 az configure --defaults group=<name>
。
全域參數
增加記錄詳細資訊,以顯示所有偵錯記錄。
顯示此說明訊息並結束。
只顯示錯誤,隱藏警告。
輸出格式。
JMESPath 查詢字串。 如需詳細資訊和範例,請參閱 http://jmespath.org/。
訂用帳戶的名稱或識別碼。 您可以使用 來設定預設訂用 az account set -s NAME_OR_ID
帳戶。
增加記錄詳細資訊。 使用 --debug 來取得完整偵錯記錄。
az stream-analytics output test
測試輸出的數據源是否可供 Azure 串流分析服務存取及使用。
az stream-analytics output test --job-name
--name
--resource-group
[--datasource]
[--no-wait]
[--serialization]
[--size-window]
[--time-window]
範例
測試輸出的連接
az stream-analytics output test --job-name "sj6458" --output-name "output1755" --resource-group "sjrg2157"
必要參數
串流作業的名稱。
輸出的名稱。
資源群組的名稱。 您可以使用 來設定預設群組 az configure --defaults group=<name>
。
選擇性參數
描述將寫入輸出的數據源。 PUT (CreateOrReplace) 要求的必要專案。 預期值:json-string/json-file/@json-file。
請勿等候長時間執行的作業完成。
描述如何串行化輸入中的數據,或將數據寫入輸出時如何串行化。 PUT (CreateOrReplace) 要求的必要專案。 預期值:json-string/json-file/@json-file。
要限制串流分析輸出的大小視窗。
篩選串流分析作業輸出的時間範圍。
全域參數
增加記錄詳細資訊,以顯示所有偵錯記錄。
顯示此說明訊息並結束。
只顯示錯誤,隱藏警告。
輸出格式。
JMESPath 查詢字串。 如需詳細資訊和範例,請參閱 http://jmespath.org/。
訂用帳戶的名稱或識別碼。 您可以使用 來設定預設訂用 az account set -s NAME_OR_ID
帳戶。
增加記錄詳細資訊。 使用 --debug 來取得完整偵錯記錄。
az stream-analytics output update
在現有的串流作業下更新現有的輸出。 這可以用來部分更新 (即更新一或兩個屬性) 輸出,而不會影響其餘的作業或輸出定義。
az stream-analytics output update --job-name
--name
--resource-group
[--datasource]
[--if-match]
[--serialization]
[--size-window]
[--time-window]
範例
更新 DocumentDB 輸出
az stream-analytics output update --job-name "sj2331" --datasource "{\"type\":\"Microsoft.Storage/DocumentDB\",\"properties\":{\"partitionKey\":\"differentPartitionKey\"}}" --output-name "output3022" --resource-group "sjrg7983"
更新 Power BI 輸出
az stream-analytics output update --job-name "sj2331" --datasource "{\"type\":\"PowerBI\",\"properties\":{\"dataset\":\"differentDataset\"}}" --output-name "output3022" --resource-group "sjrg7983"
使用 Avro 串行化更新 服務匯流排 佇列輸出
az stream-analytics output update --job-name "sj5095" --datasource "{\"type\":\"Microsoft.ServiceBus/Queue\",\"properties\":{\"queueName\":\"differentQueueName\"}}" --serialization "{\"type\":\"Json\",\"properties\":{\"format\":\"LineSeparated\",\"encoding\":\"UTF8\"}}" --output-name "output3456" --resource-group "sjrg3410"
使用 CSV 串行化更新 服務匯流排 主題輸出
az stream-analytics output update --job-name "sj7094" --datasource "{\"type\":\"Microsoft.ServiceBus/Topic\",\"properties\":{\"topicName\":\"differentTopicName\"}}" --serialization "{\"type\":\"Csv\",\"properties\":{\"encoding\":\"UTF8\",\"fieldDelimiter\":\"|\"}}" --output-name "output7886" --resource-group "sjrg6450"
使用 CSV 串行化更新 Blob 輸出
az stream-analytics output update --job-name "sj900" --datasource "{\"type\":\"Microsoft.Storage/Blob\",\"properties\":{\"container\":\"differentContainer\"}}" --serialization "{\"type\":\"Csv\",\"properties\":{\"encoding\":\"UTF8\",\"fieldDelimiter\":\"|\"}}" --output-name "output1623" --resource-group "sjrg5023"
使用 JSON 串行化更新 Azure Data Lake Store 輸出
az stream-analytics output update --job-name "sj3310" --datasource "{\"type\":\"Microsoft.DataLake/Accounts\",\"properties\":{\"accountName\":\"differentaccount\"}}" --serialization "{\"type\":\"Json\",\"properties\":{\"format\":\"LineSeparated\",\"encoding\":\"UTF8\"}}" --output-name "output5195" --resource-group "sjrg6912"
更新 Azure SQL 資料庫輸出
az stream-analytics output update --job-name "sj6458" --datasource "{\"type\":\"Microsoft.Sql/Server/Database\",\"properties\":{\"table\":\"differentTable\"}}" --output-name "output1755" --resource-group "sjrg2157"
更新 Azure 資料表輸出
az stream-analytics output update --job-name "sj2790" --datasource "{\"type\":\"Microsoft.Storage/Table\",\"properties\":{\"partitionKey\":\"differentPartitionKey\"}}" --output-name "output958" --resource-group "sjrg5176"
使用 JSON 串行化更新事件中樞輸出
az stream-analytics output update --job-name "sj3310" --datasource "{\"type\":\"Microsoft.ServiceBus/EventHub\",\"properties\":{\"partitionKey\":\"differentPartitionKey\"}}" --serialization "{\"type\":\"Json\",\"properties\":{\"format\":\"LineSeparated\",\"encoding\":\"UTF8\"}}" --output-name "output5195" --resource-group "sjrg6912"
必要參數
串流作業的名稱。
輸出的名稱。
資源群組的名稱。 您可以使用 來設定預設群組 az configure --defaults group=<name>
。
選擇性參數
描述將寫入輸出的數據源。 PUT (CreateOrReplace) 要求的必要專案。 預期值:json-string/json-file/@json-file。
輸出的ETag。 請省略此值以一律覆寫目前的輸出。 指定最後看到的 ETag 值,以防止意外覆寫並行變更。
描述如何串行化輸入中的數據,或將數據寫入輸出時如何串行化。 PUT (CreateOrReplace) 要求的必要專案。 預期值:json-string/json-file/@json-file。
要限制串流分析輸出的大小視窗。
篩選串流分析作業輸出的時間範圍。
全域參數
增加記錄詳細資訊,以顯示所有偵錯記錄。
顯示此說明訊息並結束。
只顯示錯誤,隱藏警告。
輸出格式。
JMESPath 查詢字串。 如需詳細資訊和範例,請參閱 http://jmespath.org/。
訂用帳戶的名稱或識別碼。 您可以使用 來設定預設訂用 az account set -s NAME_OR_ID
帳戶。
增加記錄詳細資訊。 使用 --debug 來取得完整偵錯記錄。
az stream-analytics output wait
將 CLI 置於等候狀態,直到符合串流分析輸出的條件為止。
az stream-analytics output wait --job-name
--name
--resource-group
[--created]
[--custom]
[--deleted]
[--exists]
[--interval]
[--timeout]
[--updated]
範例
暫停執行下一行 CLI 腳本,直到成功建立串流分析輸出為止。
az stream-analytics output wait --job-name "sj3310" --output-name "output5195" --resource-group "sjrg6912" --created
必要參數
串流作業的名稱。
輸出的名稱。
資源群組的名稱。 您可以使用 來設定預設群組 az configure --defaults group=<name>
。
選擇性參數
請等候在 'Succeeded' 使用 'provisioningState' 建立。
等到條件符合自訂 JMESPath 查詢為止。 例如 provisioningState!='InProgress', instanceView.statuses[?code=='PowerState/running']。
等到刪除為止。
等候資源存在。
輪詢間隔以秒為單位。
以秒為單位的等候上限。
等到 provisioningState 更新為 'Succeeded'。
全域參數
增加記錄詳細資訊,以顯示所有偵錯記錄。
顯示此說明訊息並結束。
只顯示錯誤,隱藏警告。
輸出格式。
JMESPath 查詢字串。 如需詳細資訊和範例,請參閱 http://jmespath.org/。
訂用帳戶的名稱或識別碼。 您可以使用 來設定預設訂用 az account set -s NAME_OR_ID
帳戶。
增加記錄詳細資訊。 使用 --debug 來取得完整偵錯記錄。