지정된 클러스터의 모든 스트리밍 작업을 Lists.
POST https://management.azure.com/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.StreamAnalytics/clusters/{clusterName}/listStreamingJobs?api-version=2020-03-01
URI 매개 변수
| Name |
In(다음 안에) |
필수 |
형식 |
Description |
|
clusterName
|
path |
True
|
string
|
클러스터의 이름입니다.
|
|
resourceGroupName
|
path |
True
|
string
|
리소스 그룹의 이름. 이름은 대소문자를 구분하지 않습니다.
Regex pattern: ^[-\w\._\(\)]+$
|
|
subscriptionId
|
path |
True
|
string
|
대상 구독의 ID입니다.
|
|
api-version
|
query |
True
|
string
|
이 작업에 사용할 API 버전입니다.
|
응답
보안
azure_auth
Azure Active Directory OAuth2 Flow
Type:
oauth2
Flow:
implicit
Authorization URL:
https://login.microsoftonline.com/common/oauth2/authorize
Scopes
| Name |
Description |
|
user_impersonation
|
사용자 계정 가장
|
예제
List all streaming jobs in cluster
Sample Request
POST https://management.azure.com/subscriptions/34adfa4f-cedf-4dc0-ba29-b6d1a69ab345/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/clusters/testcluster/listStreamingJobs?api-version=2020-03-01
import com.azure.core.util.Context;
/** Samples for Clusters ListStreamingJobs. */
public final class Main {
/*
* x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Cluster_ListStreamingJobs.json
*/
/**
* Sample code: List all streaming jobs in cluster.
*
* @param manager Entry point to StreamAnalyticsManager.
*/
public static void listAllStreamingJobsInCluster(
com.azure.resourcemanager.streamanalytics.StreamAnalyticsManager manager) {
manager.clusters().listStreamingJobs("sjrg", "testcluster", Context.NONE);
}
}
To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue
package armstreamanalytics_test
import (
"context"
"log"
"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/streamanalytics/armstreamanalytics"
)
// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/d55b8005f05b040b852c15e74a0f3e36494a15e1/specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Cluster_ListStreamingJobs.json
func ExampleClustersClient_NewListStreamingJobsPager() {
cred, err := azidentity.NewDefaultAzureCredential(nil)
if err != nil {
log.Fatalf("failed to obtain a credential: %v", err)
}
ctx := context.Background()
clientFactory, err := armstreamanalytics.NewClientFactory("<subscription-id>", cred, nil)
if err != nil {
log.Fatalf("failed to create client: %v", err)
}
pager := clientFactory.NewClustersClient().NewListStreamingJobsPager("sjrg", "testcluster", nil)
for pager.More() {
page, err := pager.NextPage(ctx)
if err != nil {
log.Fatalf("failed to advance page: %v", err)
}
for _, v := range page.Value {
// You could use page here. We use blank identifier for just demo purposes.
_ = v
}
// If the HTTP response code is 200 as defined in example definition, your page structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
// page.ClusterJobListResult = armstreamanalytics.ClusterJobListResult{
// Value: []*armstreamanalytics.ClusterJob{
// {
// ID: to.Ptr("/subscriptions/34adfa4f-cedf-4dc0-ba29-b6d1a69ab345/resourceGroups/sjrg/providers/microsoft.streamAnalytics/streamingjobs/AFilterSample"),
// JobState: to.Ptr(armstreamanalytics.JobStateRunning),
// StreamingUnits: to.Ptr[int32](6),
// },
// {
// ID: to.Ptr("/subscriptions/34adfa4f-cedf-4dc0-ba29-b6d1a69ab345/resourceGroups/sjrg/providers/microsoft.streamAnalytics/streamingjobs/AnotherFilterSample"),
// JobState: to.Ptr(armstreamanalytics.JobStateStopped),
// StreamingUnits: to.Ptr[int32](1),
// }},
// }
}
}
To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue
const { StreamAnalyticsManagementClient } = require("@azure/arm-streamanalytics");
const { DefaultAzureCredential } = require("@azure/identity");
/**
* This sample demonstrates how to Lists all of the streaming jobs in the given cluster.
*
* @summary Lists all of the streaming jobs in the given cluster.
* x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Cluster_ListStreamingJobs.json
*/
async function listAllStreamingJobsInCluster() {
const subscriptionId = "34adfa4f-cedf-4dc0-ba29-b6d1a69ab345";
const resourceGroupName = "sjrg";
const clusterName = "testcluster";
const credential = new DefaultAzureCredential();
const client = new StreamAnalyticsManagementClient(credential, subscriptionId);
const resArray = new Array();
for await (let item of client.clusters.listStreamingJobs(resourceGroupName, clusterName)) {
resArray.push(item);
}
console.log(resArray);
}
listAllStreamingJobsInCluster().catch(console.error);
To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue
Sample Response
{
"value": [
{
"id": "/subscriptions/34adfa4f-cedf-4dc0-ba29-b6d1a69ab345/resourceGroups/sjrg/providers/microsoft.streamAnalytics/streamingjobs/AFilterSample",
"streamingUnits": 6,
"jobState": "Running"
},
{
"id": "/subscriptions/34adfa4f-cedf-4dc0-ba29-b6d1a69ab345/resourceGroups/sjrg/providers/microsoft.streamAnalytics/streamingjobs/AnotherFilterSample",
"streamingUnits": 1,
"jobState": "Stopped"
}
],
"nextLink": null
}
정의
ClusterJob
스트리밍 작업입니다.
| Name |
형식 |
Description |
|
id
|
string
|
스트리밍 작업의 리소스 ID입니다.
|
|
jobState
|
JobState
|
스트리밍 작업의 현재 실행 상태입니다.
|
|
streamingUnits
|
integer
|
스트리밍 작업에서 사용되는 스트리밍 단위 수입니다.
|
ClusterJobListResult
스트리밍 작업 목록입니다. 목록 작업으로 채워집니다.
| Name |
형식 |
Description |
|
nextLink
|
string
|
스트리밍 작업의 다음 집합을 가져올 URL입니다.
|
|
value
|
ClusterJob[]
|
스트리밍 작업 목록입니다.
|
Error
일반적인 오류 표현입니다.
| Name |
형식 |
Description |
|
error
|
Error
|
오류 정의 속성입니다.
|
JobState
스트리밍 작업의 현재 실행 상태입니다.
| Name |
형식 |
Description |
|
Created
|
string
|
작업은 현재 만든 상태입니다.
|
|
Degraded
|
string
|
작업은 현재 Degraded 상태입니다.
|
|
Deleting
|
string
|
작업이 현재 삭제 중 상태입니다.
|
|
Failed
|
string
|
작업이 현재 실패 상태입니다.
|
|
Restarting
|
string
|
작업이 현재 다시 시작 상태입니다.
|
|
Running
|
string
|
작업이 현재 실행 중 상태입니다.
|
|
Scaling
|
string
|
작업은 현재 크기 조정 상태입니다.
|
|
Starting
|
string
|
작업이 현재 시작 상태입니다.
|
|
Stopped
|
string
|
작업이 현재 중지됨 상태입니다.
|
|
Stopping
|
string
|
작업이 현재 중지 상태입니다.
|