Streaming Jobs - List

Service:

Stream Analytics

API Version:

2020-03-01

Lists semua pekerjaan streaming dalam langganan tertentu.

GET https://management.azure.com/subscriptions/{subscriptionId}/providers/Microsoft.StreamAnalytics/streamingjobs?api-version=2020-03-01

With optional parameters:

GET https://management.azure.com/subscriptions/{subscriptionId}/providers/Microsoft.StreamAnalytics/streamingjobs?$expand={$expand}&api-version=2020-03-01

Parameter URI

Nama	Dalam	Diperlukan	Jenis	Deskripsi
subscriptionId	path	True	string	ID langganan target.
api-version	query	True	string	Versi API yang digunakan untuk operasi ini.
$expand	query		string	Parameter kueri $expand OData. Ini adalah daftar properti pekerjaan streaming tambahan yang dipisahkan koma untuk disertakan dalam respons, di luar set default yang dikembalikan ketika parameter ini tidak ada. Set default adalah semua properti pekerjaan streaming selain 'input', 'transformasi', 'output', dan 'functions'.

Respons

Nama	Jenis	Deskripsi
200 OK	StreamingJobListResult	Berhasil mencantumkan pekerjaan streaming di bawah langganan yang diberikan.
Other Status Codes	Error	Kesalahan.

Keamanan

azure_auth

Alur OAuth2 Azure Active Directory

Type: oauth2
Flow: implicit
Authorization URL: https://login.microsoftonline.com/common/oauth2/authorize

Scopes

Nama	Deskripsi
user_impersonation	meniru akun pengguna Anda

Contoh

List all streaming jobs in a subscription and do not use the $expand OData query parameter

List all streaming jobs in a subscription and use the $expand OData query parameter to expand inputs, outputs, transformation, and functions

List all streaming jobs in a subscription and do not use the $expand OData query parameter

Sample Request

HTTP

GET https://management.azure.com/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/providers/Microsoft.StreamAnalytics/streamingjobs?api-version=2020-03-01

Go

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/StreamingJob_List_BySubscription_NoExpand.json
func ExampleStreamingJobsClient_NewListPager_listAllStreamingJobsInASubscriptionAndDoNotUseTheExpandODataQueryParameter() {
	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.NewStreamingJobsClient().NewListPager(&armstreamanalytics.StreamingJobsClientListOptions{Expand: 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.StreamingJobListResult = armstreamanalytics.StreamingJobListResult{
		// 	Value: []*armstreamanalytics.StreamingJob{
		// 		{
		// 			Name: to.Ptr("sj59"),
		// 			Type: to.Ptr("Microsoft.StreamAnalytics/streamingjobs"),
		// 			ID: to.Ptr("/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg6936/providers/Microsoft.StreamAnalytics/streamingjobs/sj59"),
		// 			Location: to.Ptr("West US"),
		// 			Tags: map[string]*string{
		// 				"key1": to.Ptr("value1"),
		// 				"key3": to.Ptr("value3"),
		// 				"randomKey": to.Ptr("randomValue"),
		// 			},
		// 			Properties: &armstreamanalytics.StreamingJobProperties{
		// 				CompatibilityLevel: to.Ptr(armstreamanalytics.CompatibilityLevelOne0),
		// 				CreatedDate: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2017-05-11T04:37:04.697Z"); return t}()),
		// 				DataLocale: to.Ptr("en-US"),
		// 				Etag: to.Ptr("3e6872bc-c9d0-45b6-91b6-da66f1773056"),
		// 				EventsLateArrivalMaxDelayInSeconds: to.Ptr[int32](13),
		// 				EventsOutOfOrderMaxDelayInSeconds: to.Ptr[int32](21),
		// 				EventsOutOfOrderPolicy: to.Ptr(armstreamanalytics.EventsOutOfOrderPolicyDrop),
		// 				JobID: to.Ptr("d53ecc3c-fcb0-485d-9caf-25e20fcb2061"),
		// 				JobState: to.Ptr("Created"),
		// 				OutputErrorPolicy: to.Ptr(armstreamanalytics.OutputErrorPolicyDrop),
		// 				ProvisioningState: to.Ptr("Succeeded"),
		// 				SKU: &armstreamanalytics.SKU{
		// 					Name: to.Ptr(armstreamanalytics.SKUNameStandard),
		// 				},
		// 			},
		// 		},
		// 		{
		// 			Name: to.Ptr("sj69"),
		// 			Type: to.Ptr("Microsoft.StreamAnalytics/streamingjobs"),
		// 			ID: to.Ptr("/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg6936/providers/Microsoft.StreamAnalytics/streamingjobs/sj69"),
		// 			Location: to.Ptr("West US"),
		// 			Tags: map[string]*string{
		// 				"key1": to.Ptr("value1"),
		// 				"key3": to.Ptr("value3"),
		// 				"randomKey": to.Ptr("randomValue"),
		// 			},
		// 			Properties: &armstreamanalytics.StreamingJobProperties{
		// 				CompatibilityLevel: to.Ptr(armstreamanalytics.CompatibilityLevelOne0),
		// 				CreatedDate: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2017-05-11T04:38:04.697Z"); return t}()),
		// 				DataLocale: to.Ptr("en-US"),
		// 				Etag: to.Ptr("99538949-a164-4e2f-a991-40303e86024f"),
		// 				EventsLateArrivalMaxDelayInSeconds: to.Ptr[int32](6),
		// 				EventsOutOfOrderMaxDelayInSeconds: to.Ptr[int32](5),
		// 				EventsOutOfOrderPolicy: to.Ptr(armstreamanalytics.EventsOutOfOrderPolicyDrop),
		// 				JobID: to.Ptr("817b36cf-a161-4a9e-86f2-eb00b3566d88"),
		// 				JobState: to.Ptr("Created"),
		// 				OutputErrorPolicy: to.Ptr(armstreamanalytics.OutputErrorPolicyDrop),
		// 				ProvisioningState: to.Ptr("Succeeded"),
		// 				SKU: &armstreamanalytics.SKU{
		// 					Name: to.Ptr(armstreamanalytics.SKUNameStandard),
		// 				},
		// 			},
		// 	}},
		// }
	}
}

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

JavaScript

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 subscription.
 *
 * @summary Lists all of the streaming jobs in the given subscription.
 * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/StreamingJob_List_BySubscription_NoExpand.json
 */
async function listAllStreamingJobsInASubscriptionAndDoNotUseTheExpandODataQueryParameter() {
  const subscriptionId = "56b5e0a9-b645-407d-99b0-c64f86013e3d";
  const credential = new DefaultAzureCredential();
  const client = new StreamAnalyticsManagementClient(credential, subscriptionId);
  const resArray = new Array();
  for await (let item of client.streamingJobs.list()) {
    resArray.push(item);
  }
  console.log(resArray);
}

listAllStreamingJobsInASubscriptionAndDoNotUseTheExpandODataQueryParameter().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

Status code:

200

{
  "value": [
    {
      "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg6936/providers/Microsoft.StreamAnalytics/streamingjobs/sj59",
      "name": "sj59",
      "type": "Microsoft.StreamAnalytics/streamingjobs",
      "location": "West US",
      "tags": {
        "key1": "value1",
        "randomKey": "randomValue",
        "key3": "value3"
      },
      "properties": {
        "sku": {
          "name": "Standard"
        },
        "jobId": "d53ecc3c-fcb0-485d-9caf-25e20fcb2061",
        "provisioningState": "Succeeded",
        "jobState": "Created",
        "eventsOutOfOrderPolicy": "Drop",
        "outputErrorPolicy": "Drop",
        "eventsOutOfOrderMaxDelayInSeconds": 21,
        "eventsLateArrivalMaxDelayInSeconds": 13,
        "dataLocale": "en-US",
        "createdDate": "2017-05-11T04:37:04.697Z",
        "compatibilityLevel": "1.0",
        "etag": "3e6872bc-c9d0-45b6-91b6-da66f1773056"
      }
    },
    {
      "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg6936/providers/Microsoft.StreamAnalytics/streamingjobs/sj69",
      "name": "sj69",
      "type": "Microsoft.StreamAnalytics/streamingjobs",
      "location": "West US",
      "tags": {
        "key1": "value1",
        "randomKey": "randomValue",
        "key3": "value3"
      },
      "properties": {
        "sku": {
          "name": "Standard"
        },
        "jobId": "817b36cf-a161-4a9e-86f2-eb00b3566d88",
        "provisioningState": "Succeeded",
        "jobState": "Created",
        "eventsOutOfOrderPolicy": "Drop",
        "outputErrorPolicy": "Drop",
        "eventsOutOfOrderMaxDelayInSeconds": 5,
        "eventsLateArrivalMaxDelayInSeconds": 6,
        "dataLocale": "en-US",
        "createdDate": "2017-05-11T04:38:04.697Z",
        "compatibilityLevel": "1.0",
        "etag": "99538949-a164-4e2f-a991-40303e86024f"
      }
    }
  ]
}

List all streaming jobs in a subscription and use the $expand OData query parameter to expand inputs, outputs, transformation, and functions

Sample Request

HTTP

GET https://management.azure.com/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/providers/Microsoft.StreamAnalytics/streamingjobs?$expand=inputs,outputs,transformation,functions&api-version=2020-03-01

Go

package armstreamanalytics_test

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
	"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/StreamingJob_List_BySubscription_Expand.json
func ExampleStreamingJobsClient_NewListPager_listAllStreamingJobsInASubscriptionAndUseTheExpandODataQueryParameterToExpandInputsOutputsTransformationAndFunctions() {
	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.NewStreamingJobsClient().NewListPager(&armstreamanalytics.StreamingJobsClientListOptions{Expand: to.Ptr("inputs,outputs,transformation,functions")})
	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.StreamingJobListResult = armstreamanalytics.StreamingJobListResult{
		// 	Value: []*armstreamanalytics.StreamingJob{
		// 		{
		// 			Name: to.Ptr("sj7804"),
		// 			Type: to.Ptr("Microsoft.StreamAnalytics/streamingjobs"),
		// 			ID: to.Ptr("/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3276/providers/Microsoft.StreamAnalytics/streamingjobs/sj7804"),
		// 			Location: to.Ptr("West US"),
		// 			Tags: map[string]*string{
		// 				"key1": to.Ptr("value1"),
		// 				"key3": to.Ptr("value3"),
		// 				"randomKey": to.Ptr("randomValue"),
		// 			},
		// 			Properties: &armstreamanalytics.StreamingJobProperties{
		// 				CompatibilityLevel: to.Ptr(armstreamanalytics.CompatibilityLevelOne0),
		// 				CreatedDate: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2017-05-11T04:37:11.540Z"); return t}()),
		// 				DataLocale: to.Ptr("en-US"),
		// 				Etag: to.Ptr("8081b2a3-dfe6-457f-8740-1a22d209bf8a"),
		// 				EventsLateArrivalMaxDelayInSeconds: to.Ptr[int32](5),
		// 				EventsOutOfOrderMaxDelayInSeconds: to.Ptr[int32](0),
		// 				EventsOutOfOrderPolicy: to.Ptr(armstreamanalytics.EventsOutOfOrderPolicyAdjust),
		// 				Functions: []*armstreamanalytics.Function{
		// 				},
		// 				Inputs: []*armstreamanalytics.Input{
		// 					{
		// 						Name: to.Ptr("inputtest"),
		// 						Type: to.Ptr("Microsoft.StreamAnalytics/streamingjobs/inputs"),
		// 						ID: to.Ptr("/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3276/providers/Microsoft.StreamAnalytics/streamingjobs/sj7804/inputs/inputtest"),
		// 						Properties: &armstreamanalytics.StreamInputProperties{
		// 							Type: to.Ptr("Stream"),
		// 							Etag: to.Ptr("ca88f8fa-605b-4c7f-8695-46f5faa60cd0"),
		// 							Serialization: &armstreamanalytics.JSONSerialization{
		// 								Type: to.Ptr(armstreamanalytics.EventSerializationTypeJSON),
		// 								Properties: &armstreamanalytics.JSONSerializationProperties{
		// 									Encoding: to.Ptr(armstreamanalytics.EncodingUTF8),
		// 								},
		// 							},
		// 							Datasource: &armstreamanalytics.BlobStreamInputDataSource{
		// 								Type: to.Ptr("Microsoft.Storage/Blob"),
		// 								Properties: &armstreamanalytics.BlobStreamInputDataSourceProperties{
		// 									Container: to.Ptr("containerName"),
		// 									PathPattern: to.Ptr(""),
		// 									StorageAccounts: []*armstreamanalytics.StorageAccount{
		// 										{
		// 											AccountName: to.Ptr("accountName"),
		// 									}},
		// 								},
		// 							},
		// 						},
		// 				}},
		// 				JobID: to.Ptr("732e4b1d-94a7-43ae-8297-3ad04f1540b9"),
		// 				JobState: to.Ptr("Created"),
		// 				OutputErrorPolicy: to.Ptr(armstreamanalytics.OutputErrorPolicyStop),
		// 				Outputs: []*armstreamanalytics.Output{
		// 					{
		// 						Name: to.Ptr("outputtest"),
		// 						Type: to.Ptr("Microsoft.StreamAnalytics/streamingjobs/outputs"),
		// 						ID: to.Ptr("/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3276/providers/Microsoft.StreamAnalytics/streamingjobs/sj7804/outputs/outputtest"),
		// 						Properties: &armstreamanalytics.OutputProperties{
		// 							Datasource: &armstreamanalytics.AzureSQLDatabaseOutputDataSource{
		// 								Type: to.Ptr("Microsoft.Sql/Server/Database"),
		// 								Properties: &armstreamanalytics.AzureSQLDatabaseOutputDataSourceProperties{
		// 									Database: to.Ptr("databaseName"),
		// 									Server: to.Ptr("serverName"),
		// 									Table: to.Ptr("tableName"),
		// 									User: to.Ptr("userName"),
		// 								},
		// 							},
		// 							Etag: to.Ptr("62097c3c-b503-41ff-a56f-196a9598ab90"),
		// 						},
		// 				}},
		// 				ProvisioningState: to.Ptr("Succeeded"),
		// 				SKU: &armstreamanalytics.SKU{
		// 					Name: to.Ptr(armstreamanalytics.SKUNameStandard),
		// 				},
		// 				Transformation: &armstreamanalytics.Transformation{
		// 					Name: to.Ptr("transformationtest"),
		// 					Type: to.Ptr("Microsoft.StreamAnalytics/streamingjobs/transformations"),
		// 					ID: to.Ptr("/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3276/providers/Microsoft.StreamAnalytics/streamingjobs/sj7804/transformations/transformationtest"),
		// 					Properties: &armstreamanalytics.TransformationProperties{
		// 						Etag: to.Ptr("91d8fcbe-60b3-49c3-9f21-9942b95602b8"),
		// 						Query: to.Ptr("Select Id, Name from inputtest"),
		// 						StreamingUnits: to.Ptr[int32](1),
		// 					},
		// 				},
		// 			},
		// 		},
		// 		{
		// 			Name: to.Ptr("sj7805"),
		// 			Type: to.Ptr("Microsoft.StreamAnalytics/streamingjobs"),
		// 			ID: to.Ptr("/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3276/providers/Microsoft.StreamAnalytics/streamingjobs/sj7805"),
		// 			Location: to.Ptr("West US"),
		// 			Tags: map[string]*string{
		// 				"key1": to.Ptr("value1"),
		// 				"key3": to.Ptr("value3"),
		// 				"randomKey": to.Ptr("randomValue"),
		// 			},
		// 			Properties: &armstreamanalytics.StreamingJobProperties{
		// 				CompatibilityLevel: to.Ptr(armstreamanalytics.CompatibilityLevelOne0),
		// 				CreatedDate: to.Ptr(func() time.Time { t, _ := time.Parse(time.RFC3339Nano, "2017-05-11T04:38:11.540Z"); return t}()),
		// 				DataLocale: to.Ptr("en-US"),
		// 				Etag: to.Ptr("5420059f-e5d7-47d4-be44-40816a4dca7e"),
		// 				EventsLateArrivalMaxDelayInSeconds: to.Ptr[int32](5),
		// 				EventsOutOfOrderMaxDelayInSeconds: to.Ptr[int32](0),
		// 				EventsOutOfOrderPolicy: to.Ptr(armstreamanalytics.EventsOutOfOrderPolicyAdjust),
		// 				Functions: []*armstreamanalytics.Function{
		// 				},
		// 				Inputs: []*armstreamanalytics.Input{
		// 					{
		// 						Name: to.Ptr("inputtest"),
		// 						Type: to.Ptr("Microsoft.StreamAnalytics/streamingjobs/inputs"),
		// 						ID: to.Ptr("/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3276/providers/Microsoft.StreamAnalytics/streamingjobs/sj7805/inputs/inputtest"),
		// 						Properties: &armstreamanalytics.StreamInputProperties{
		// 							Type: to.Ptr("Stream"),
		// 							Etag: to.Ptr("45dcf40f-88bb-4776-b5ca-7b10a607cb59"),
		// 							Serialization: &armstreamanalytics.JSONSerialization{
		// 								Type: to.Ptr(armstreamanalytics.EventSerializationTypeJSON),
		// 								Properties: &armstreamanalytics.JSONSerializationProperties{
		// 									Encoding: to.Ptr(armstreamanalytics.EncodingUTF8),
		// 								},
		// 							},
		// 							Datasource: &armstreamanalytics.BlobStreamInputDataSource{
		// 								Type: to.Ptr("Microsoft.Storage/Blob"),
		// 								Properties: &armstreamanalytics.BlobStreamInputDataSourceProperties{
		// 									Container: to.Ptr("containerName"),
		// 									PathPattern: to.Ptr(""),
		// 									StorageAccounts: []*armstreamanalytics.StorageAccount{
		// 										{
		// 											AccountName: to.Ptr("accountName"),
		// 									}},
		// 								},
		// 							},
		// 						},
		// 				}},
		// 				JobID: to.Ptr("d8f4041a-0793-433e-a38d-5499d5332113"),
		// 				JobState: to.Ptr("Created"),
		// 				OutputErrorPolicy: to.Ptr(armstreamanalytics.OutputErrorPolicyStop),
		// 				Outputs: []*armstreamanalytics.Output{
		// 					{
		// 						Name: to.Ptr("outputtest"),
		// 						Type: to.Ptr("Microsoft.StreamAnalytics/streamingjobs/outputs"),
		// 						ID: to.Ptr("/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3276/providers/Microsoft.StreamAnalytics/streamingjobs/sj7805/outputs/outputtest"),
		// 						Properties: &armstreamanalytics.OutputProperties{
		// 							Datasource: &armstreamanalytics.AzureSQLDatabaseOutputDataSource{
		// 								Type: to.Ptr("Microsoft.Sql/Server/Database"),
		// 								Properties: &armstreamanalytics.AzureSQLDatabaseOutputDataSourceProperties{
		// 									Database: to.Ptr("databaseName"),
		// 									Server: to.Ptr("serverName"),
		// 									Table: to.Ptr("tableName"),
		// 									User: to.Ptr("userName"),
		// 								},
		// 							},
		// 							Etag: to.Ptr("b09606c8-1b0d-43c9-affb-fac0e18b9481"),
		// 						},
		// 				}},
		// 				ProvisioningState: to.Ptr("Succeeded"),
		// 				SKU: &armstreamanalytics.SKU{
		// 					Name: to.Ptr(armstreamanalytics.SKUNameStandard),
		// 				},
		// 				Transformation: &armstreamanalytics.Transformation{
		// 					Name: to.Ptr("transformationtest"),
		// 					Type: to.Ptr("Microsoft.StreamAnalytics/streamingjobs/transformations"),
		// 					ID: to.Ptr("/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3276/providers/Microsoft.StreamAnalytics/streamingjobs/sj7805/transformations/transformationtest"),
		// 					Properties: &armstreamanalytics.TransformationProperties{
		// 						Etag: to.Ptr("288d95c0-204b-4c54-828f-f57aa6896b2a"),
		// 						Query: to.Ptr("Select Id, Name from inputtest"),
		// 						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

JavaScript

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 subscription.
 *
 * @summary Lists all of the streaming jobs in the given subscription.
 * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/StreamingJob_List_BySubscription_Expand.json
 */
async function listAllStreamingJobsInASubscriptionAndUseTheExpandODataQueryParameterToExpandInputsOutputsTransformationAndFunctions() {
  const subscriptionId = "56b5e0a9-b645-407d-99b0-c64f86013e3d";
  const expand = "inputs,outputs,transformation,functions";
  const options = { expand };
  const credential = new DefaultAzureCredential();
  const client = new StreamAnalyticsManagementClient(credential, subscriptionId);
  const resArray = new Array();
  for await (let item of client.streamingJobs.list(options)) {
    resArray.push(item);
  }
  console.log(resArray);
}

listAllStreamingJobsInASubscriptionAndUseTheExpandODataQueryParameterToExpandInputsOutputsTransformationAndFunctions().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

Status code:

200

{
  "value": [
    {
      "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3276/providers/Microsoft.StreamAnalytics/streamingjobs/sj7804",
      "name": "sj7804",
      "type": "Microsoft.StreamAnalytics/streamingjobs",
      "location": "West US",
      "tags": {
        "key1": "value1",
        "randomKey": "randomValue",
        "key3": "value3"
      },
      "properties": {
        "sku": {
          "name": "Standard"
        },
        "jobId": "732e4b1d-94a7-43ae-8297-3ad04f1540b9",
        "provisioningState": "Succeeded",
        "jobState": "Created",
        "eventsOutOfOrderPolicy": "Adjust",
        "outputErrorPolicy": "Stop",
        "eventsOutOfOrderMaxDelayInSeconds": 0,
        "eventsLateArrivalMaxDelayInSeconds": 5,
        "dataLocale": "en-US",
        "createdDate": "2017-05-11T04:37:11.54Z",
        "compatibilityLevel": "1.0",
        "inputs": [
          {
            "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3276/providers/Microsoft.StreamAnalytics/streamingjobs/sj7804/inputs/inputtest",
            "name": "inputtest",
            "type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
            "properties": {
              "type": "Stream",
              "datasource": {
                "type": "Microsoft.Storage/Blob",
                "properties": {
                  "storageAccounts": [
                    {
                      "accountName": "accountName"
                    }
                  ],
                  "container": "containerName",
                  "pathPattern": ""
                }
              },
              "serialization": {
                "type": "Json",
                "properties": {
                  "encoding": "UTF8"
                }
              },
              "etag": "ca88f8fa-605b-4c7f-8695-46f5faa60cd0"
            }
          }
        ],
        "transformation": {
          "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3276/providers/Microsoft.StreamAnalytics/streamingjobs/sj7804/transformations/transformationtest",
          "name": "transformationtest",
          "type": "Microsoft.StreamAnalytics/streamingjobs/transformations",
          "properties": {
            "streamingUnits": 1,
            "query": "Select Id, Name from inputtest",
            "etag": "91d8fcbe-60b3-49c3-9f21-9942b95602b8"
          }
        },
        "functions": [],
        "outputs": [
          {
            "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3276/providers/Microsoft.StreamAnalytics/streamingjobs/sj7804/outputs/outputtest",
            "name": "outputtest",
            "type": "Microsoft.StreamAnalytics/streamingjobs/outputs",
            "properties": {
              "datasource": {
                "type": "Microsoft.Sql/Server/Database",
                "properties": {
                  "server": "serverName",
                  "database": "databaseName",
                  "table": "tableName",
                  "user": "userName"
                }
              },
              "etag": "62097c3c-b503-41ff-a56f-196a9598ab90"
            }
          }
        ],
        "etag": "8081b2a3-dfe6-457f-8740-1a22d209bf8a"
      }
    },
    {
      "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3276/providers/Microsoft.StreamAnalytics/streamingjobs/sj7805",
      "name": "sj7805",
      "type": "Microsoft.StreamAnalytics/streamingjobs",
      "location": "West US",
      "tags": {
        "key1": "value1",
        "randomKey": "randomValue",
        "key3": "value3"
      },
      "properties": {
        "sku": {
          "name": "Standard"
        },
        "jobId": "d8f4041a-0793-433e-a38d-5499d5332113",
        "provisioningState": "Succeeded",
        "jobState": "Created",
        "eventsOutOfOrderPolicy": "Adjust",
        "outputErrorPolicy": "Stop",
        "eventsOutOfOrderMaxDelayInSeconds": 0,
        "eventsLateArrivalMaxDelayInSeconds": 5,
        "dataLocale": "en-US",
        "createdDate": "2017-05-11T04:38:11.54Z",
        "compatibilityLevel": "1.0",
        "inputs": [
          {
            "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3276/providers/Microsoft.StreamAnalytics/streamingjobs/sj7805/inputs/inputtest",
            "name": "inputtest",
            "type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
            "properties": {
              "type": "Stream",
              "datasource": {
                "type": "Microsoft.Storage/Blob",
                "properties": {
                  "storageAccounts": [
                    {
                      "accountName": "accountName"
                    }
                  ],
                  "container": "containerName",
                  "pathPattern": ""
                }
              },
              "serialization": {
                "type": "Json",
                "properties": {
                  "encoding": "UTF8"
                }
              },
              "etag": "45dcf40f-88bb-4776-b5ca-7b10a607cb59"
            }
          }
        ],
        "transformation": {
          "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3276/providers/Microsoft.StreamAnalytics/streamingjobs/sj7805/transformations/transformationtest",
          "name": "transformationtest",
          "type": "Microsoft.StreamAnalytics/streamingjobs/transformations",
          "properties": {
            "streamingUnits": 1,
            "query": "Select Id, Name from inputtest",
            "etag": "288d95c0-204b-4c54-828f-f57aa6896b2a"
          }
        },
        "functions": [],
        "outputs": [
          {
            "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3276/providers/Microsoft.StreamAnalytics/streamingjobs/sj7805/outputs/outputtest",
            "name": "outputtest",
            "type": "Microsoft.StreamAnalytics/streamingjobs/outputs",
            "properties": {
              "datasource": {
                "type": "Microsoft.Sql/Server/Database",
                "properties": {
                  "server": "serverName",
                  "database": "databaseName",
                  "table": "tableName",
                  "user": "userName"
                }
              },
              "etag": "b09606c8-1b0d-43c9-affb-fac0e18b9481"
            }
          }
        ],
        "etag": "5420059f-e5d7-47d4-be44-40816a4dca7e"
      }
    }
  ]
}

Definisi

Nama	Deskripsi
AggregateFunctionProperties	Properti yang terkait dengan fungsi agregat.
AuthenticationMode	Mode Autentikasi. Mode yang valid adalah ConnectionString, Msi dan 'UserToken'.
AvroSerialization	Menjelaskan bagaimana data dari input diserialisasikan atau bagaimana data diserialisasikan saat ditulis ke output dalam format Avro.
AzureDataLakeStoreOutputDataSource	Menjelaskan sumber data output Azure Data Lake Store.
AzureFunctionOutputDataSource	Menentukan metadata AzureFunctionOutputDataSource
AzureMachineLearningWebServiceFunctionBinding	Pengikatan ke layanan web Azure Machine Learning.
AzureMachineLearningWebServiceInputColumn	Menjelaskan kolom input untuk titik akhir layanan web Azure Machine Learning.
AzureMachineLearningWebServiceInputs	Input untuk titik akhir layanan web Azure Machine Learning.
AzureMachineLearningWebServiceOutputColumn	Menjelaskan kolom output untuk titik akhir layanan web Azure Machine Learning.
AzureSqlDatabaseOutputDataSource	Menjelaskan sumber data output database Azure SQL.
AzureSqlReferenceInputDataSource	Menjelaskan sumber data input referensi database Azure SQL.
AzureSynapseOutputDataSource	Menjelaskan sumber data output Azure Synapse.
AzureTableOutputDataSource	Menjelaskan sumber data output Tabel Azure.
BlobOutputDataSource	Menjelaskan sumber data output blob.
BlobReferenceInputDataSource	Menjelaskan sumber data input blob yang berisi data referensi.
BlobStreamInputDataSource	Menjelaskan sumber data input blob yang berisi data aliran.
ClusterInfo	Properti yang terkait dengan kluster Azure Stream Analytics.
CompatibilityLevel	Mengontrol perilaku runtime tertentu dari pekerjaan streaming.
Compression	Menjelaskan bagaimana data input dikompresi
CompressionType	Menunjukkan jenis kompresi yang digunakan input. Diperlukan pada permintaan PUT (CreateOrReplace).
ContentStoragePolicy	Nilai yang valid adalah JobStorageAccount dan SystemAccount. Jika diatur ke JobStorageAccount, ini mengharuskan pengguna untuk juga menentukan properti jobStorageAccount. .
CsvSerialization	Menjelaskan bagaimana data dari input diserialisasikan atau bagaimana data diserialisasikan saat ditulis ke output dalam format CSV.
DiagnosticCondition	Kondisi yang berlaku untuk sumber daya, atau untuk pekerjaan secara keseluruhan, yang menjamin perhatian pelanggan.
Diagnostics	Menjelaskan kondisi yang berlaku untuk Input, Output, atau pekerjaan secara keseluruhan, yang menjamin perhatian pelanggan.
DocumentDbOutputDataSource	Menjelaskan sumber data output DocumentDB.
Encoding	Menentukan pengodean data masuk dalam kasus input dan pengodean data keluar dalam kasus output.
Error	Representasi kesalahan umum.
EventHubOutputDataSource	Menjelaskan sumber data output Pusat Aktivitas.
EventHubStreamInputDataSource	Menjelaskan sumber data input Pusat Aktivitas yang berisi data aliran.
EventHubV2OutputDataSource	Menjelaskan sumber data output Event Hub.
EventHubV2StreamInputDataSource	Menjelaskan sumber data input Pusat Aktivitas yang berisi data aliran.
EventSerializationType	Menunjukkan jenis serialisasi yang digunakan input atau output. Diperlukan pada permintaan PUT (CreateOrReplace).
EventsOutOfOrderPolicy	Menandakan kebijakan untuk diterapkan ke peristiwa yang sampai di luar urutan dalam aliran peristiwa input.
FileReferenceInputDataSource	Menjelaskan sumber data input file yang berisi data referensi.
Function	Objek fungsi, berisi semua informasi yang terkait dengan fungsi bernama. Semua fungsi terkandung dalam pekerjaan streaming.
FunctionInput	Menjelaskan satu parameter input fungsi.
FunctionOutput	Menjelaskan output fungsi.
GatewayMessageBusOutputDataSource	Menjelaskan sumber data output Bus Pesan Gateway.
GatewayMessageBusStreamInputDataSource	Menjelaskan sumber data input blob yang berisi data aliran.
Identity	Menjelaskan bagaimana identitas diverifikasi
Input	Objek input, berisi semua informasi yang terkait dengan input bernama. Semua input terkandung di bawah pekerjaan streaming.
IoTHubStreamInputDataSource	Menjelaskan sumber data input IoT Hub yang berisi data aliran.
JavaScriptFunctionBinding	Pengikatan ke fungsi JavaScript.
JobStorageAccount	Properti yang terkait dengan akun Azure Storage dengan MSI
JobType	Menjelaskan jenis pekerjaan. Mode yang valid adalah Cloud dan 'Edge'.
JsonOutputSerializationFormat	Menentukan format JSON tempat output akan ditulis. Nilai yang saat ini didukung adalah 'lineSeparated' yang menunjukkan output akan diformat dengan memformat setiap objek JSON yang dipisahkan oleh baris baru dan 'array' yang menunjukkan output akan diformat sebagai array objek JSON.
JsonSerialization	Menjelaskan bagaimana data dari input diserialisasikan atau bagaimana data diserialisasikan saat ditulis ke output dalam format JSON.
Output	Objek output, berisi semua informasi yang terkait dengan output bernama. Semua output terkandung di bawah pekerjaan streaming.
OutputErrorPolicy	Menandakan kebijakan untuk diterapkan ke peristiwa yang mencapai output dan tidak dapat ditulis ke penyimpanan eksternal karena cacat (nilai kolom hilang, nilai kolom dengan jenis atau ukuran yang salah).
OutputStartMode	Nilainya mungkin JobStartTime, CustomTime, atau LastOutputEventTime untuk menunjukkan apakah titik awal aliran peristiwa output harus dimulai setiap kali pekerjaan dimulai, mulai dari stempel waktu pengguna kustom yang ditentukan melalui properti outputStartTime, atau mulai dari waktu output peristiwa terakhir.
ParquetSerialization	Menjelaskan bagaimana data dari input diserialisasikan atau bagaimana data diserialisasikan saat ditulis ke output dalam format Parquet.
PowerBIOutputDataSource	Menjelaskan sumber data output Power BI.
ReferenceInputProperties	Properti yang terkait dengan input yang berisi data referensi.
RefreshType	Menunjukkan jenis opsi refresh data.
ScalarFunctionProperties	Properti yang terkait dengan fungsi skalar.
ServiceBusQueueOutputDataSource	Menjelaskan sumber data output Antrean Azure Service Bus.
ServiceBusTopicOutputDataSource	Menjelaskan sumber data output Topik Bus Layanan.
Sku	Properti yang terkait dengan SKU.
SkuName	Nama SKUnya. Diperlukan pada permintaan PUT (CreateOrReplace).
StorageAccount	Properti yang terkait dengan akun Azure Storage
StreamingJob	Objek pekerjaan streaming, berisi semua informasi yang terkait dengan pekerjaan streaming bernama.
StreamingJobListResult	Objek yang berisi daftar pekerjaan streaming.
StreamInputProperties	Properti yang terkait dengan input yang berisi data aliran.
Transformation	Objek transformasi, berisi semua informasi yang terkait dengan transformasi bernama. Semua transformasi terkandung di bawah pekerjaan streaming.

AggregateFunctionProperties

Properti yang terkait dengan fungsi agregat.

Nama	Jenis	Deskripsi
etag	string	Tag entitas saat ini untuk fungsi . Ini adalah string buram. Anda dapat menggunakannya untuk mendeteksi apakah sumber daya telah berubah di antara permintaan. Anda juga dapat menggunakannya di header If-Match atau If-None-Match untuk operasi tulis untuk konkurensi optimis.
properties.binding	FunctionBinding: AzureMachineLearningWebServiceFunctionBinding JavaScriptFunctionBinding	Pengikatan fisik fungsi. Misalnya, dalam kasus layanan web Azure Machine Learning, ini menjelaskan titik akhir.
properties.inputs	FunctionInput[]	Menjelaskan satu parameter input fungsi.
properties.output	FunctionOutput	Menjelaskan output fungsi.
type	string: Aggregate	Menunjukkan jenis fungsi.

AuthenticationMode

Mode Autentikasi. Mode yang valid adalah ConnectionString, Msi dan 'UserToken'.

Nama	Jenis	Deskripsi
ConnectionString	string
Msi	string
UserToken	string

AvroSerialization

Menjelaskan bagaimana data dari input diserialisasikan atau bagaimana data diserialisasikan saat ditulis ke output dalam format Avro.

Nama	Jenis	Deskripsi
type	string: Avro	Menunjukkan jenis serialisasi yang digunakan input atau output. Diperlukan pada permintaan PUT (CreateOrReplace).

AzureDataLakeStoreOutputDataSource

Menjelaskan sumber data output Azure Data Lake Store.

Nama	Jenis	Nilai Default	Deskripsi
properties.accountName	string		Nama akun Azure Data Lake Store. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.authenticationMode	AuthenticationMode	ConnectionString	Mode Autentikasi.
properties.dateFormat	string		Format tanggal. Di mana pun {date} muncul di filePathPrefix, nilai properti ini digunakan sebagai format tanggal sebagai gantinya.
properties.filePathPrefix	string		Lokasi file tempat output harus ditulis. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.refreshToken	string		Token refresh yang dapat digunakan untuk mendapatkan token akses valid yang kemudian dapat digunakan untuk mengautentikasi dengan sumber data. Token refresh yang valid saat ini hanya dapat diperoleh melalui Portal Microsoft Azure. Disarankan untuk menempatkan nilai string dummy di sini saat membuat sumber data dan kemudian masuk ke Portal Azure untuk mengautentikasi sumber data yang akan memperbarui properti ini dengan token refresh yang valid. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.tenantId	string		Id penyewa pengguna yang digunakan untuk mendapatkan token refresh. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.timeFormat	string		Format waktu. Di mana pun {time} muncul di filePathPrefix, nilai properti ini digunakan sebagai format waktu sebagai gantinya.
properties.tokenUserDisplayName	string		Nama tampilan pengguna pengguna yang digunakan untuk mendapatkan token refresh. Gunakan properti ini untuk membantu mengingat pengguna mana yang digunakan untuk mendapatkan token refresh.
properties.tokenUserPrincipalName	string		Nama prinsipal pengguna (UPN) pengguna yang digunakan untuk mendapatkan token refresh. Gunakan properti ini untuk membantu mengingat pengguna mana yang digunakan untuk mendapatkan token refresh.
type	string: Microsoft.DataLake/Accounts		Menunjukkan jenis output sumber data yang akan ditulis. Diperlukan pada permintaan PUT (CreateOrReplace).

AzureFunctionOutputDataSource

Menentukan metadata AzureFunctionOutputDataSource

Nama	Jenis	Deskripsi
properties.apiKey	string	Jika Anda ingin menggunakan Fungsi Azure dari langganan lain, Anda bisa melakukannya dengan menyediakan kunci untuk mengakses fungsi Anda.
properties.functionAppName	string	Nama aplikasi Azure Functions Anda.
properties.functionName	string	Nama fungsi di aplikasi Azure Functions Anda.
properties.maxBatchCount	number	Properti yang memungkinkan Anda menentukan jumlah maksimum peristiwa di setiap batch yang dikirim ke Azure Functions. Nilai defaultnya adalah 100.
properties.maxBatchSize	number	Properti yang memungkinkan Anda mengatur ukuran maksimum untuk setiap batch output yang dikirim ke fungsi Azure Anda. Unit input berada di byte. Secara default, nilai ini diatur ke 262.144 byte (256 KB).
type	string: Microsoft.AzureFunction	Menunjukkan jenis output sumber data yang akan ditulis. Diperlukan pada permintaan PUT (CreateOrReplace).

AzureMachineLearningWebServiceFunctionBinding

Pengikatan ke layanan web Azure Machine Learning.

Nama	Jenis	Deskripsi
properties.apiKey	string	Kunci API yang digunakan untuk mengautentikasi dengan titik akhir Request-Response.
properties.batchSize	integer	Angka antara 1 dan 10000 yang menjelaskan jumlah baris maksimum untuk setiap permintaan eksekusi Azure ML RRS. Defaultnya adalah 1000.
properties.endpoint	string	Titik akhir eksekusi Request-Response layanan web Azure Machine Learning. Cari tahu selengkapnya di sini: https://docs.microsoft.com/en-us/azure/machine-learning/machine-learning-consume-web-services#request-response-service-rrs
properties.inputs	AzureMachineLearningWebServiceInputs	Input untuk titik akhir layanan web Azure Machine Learning.
properties.outputs	AzureMachineLearningWebServiceOutputColumn[]	Daftar output dari eksekusi titik akhir layanan web Azure Machine Learning.
type	string: Microsoft.MachineLearning/WebService	Menunjukkan jenis pengikatan fungsi.

AzureMachineLearningWebServiceInputColumn

Menjelaskan kolom input untuk titik akhir layanan web Azure Machine Learning.

Nama	Jenis	Deskripsi
dataType	string	Jenis data (didukung Azure Machine Learning) dari kolom input. Daftar jenis data Azure Machine Learning yang valid dijelaskan di https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx .
mapTo	integer	Indeks berbasis nol dari parameter fungsi tempat input ini dipetakan.
name	string	Nama kolom input.

AzureMachineLearningWebServiceInputs

Input untuk titik akhir layanan web Azure Machine Learning.

Nama	Jenis	Deskripsi
columnNames	AzureMachineLearningWebServiceInputColumn[]	Daftar kolom input untuk titik akhir layanan web Azure Machine Learning.
name	string	Nama input. Ini adalah nama yang disediakan saat menulis titik akhir.

AzureMachineLearningWebServiceOutputColumn

Menjelaskan kolom output untuk titik akhir layanan web Azure Machine Learning.

Nama	Jenis	Deskripsi
dataType	string	Jenis data (didukung Azure Machine Learning) dari kolom output. Daftar jenis data Azure Machine Learning yang valid dijelaskan di https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx .
name	string	Nama kolom output.

AzureSqlDatabaseOutputDataSource

Menjelaskan sumber data output database Azure SQL.

Nama	Jenis	Nilai Default	Deskripsi
properties.authenticationMode	AuthenticationMode	ConnectionString	Mode Autentikasi.
properties.database	string		Nama database Azure SQL. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.maxBatchCount	number		Jumlah Batch maks untuk menulis ke database Sql, nilai defaultnya adalah 10.000. Opsional pada permintaan PUT.
properties.maxWriterCount	number		Jumlah Penulis Maks, saat ini hanya 1(penulis tunggal) dan 0 (berdasarkan partisi kueri) yang tersedia. Opsional pada permintaan PUT.
properties.password	string		Kata sandi yang akan digunakan untuk menyambungkan ke database Azure SQL. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.server	string		Nama server SQL yang berisi database Azure SQL. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.table	string		Nama tabel dalam database Azure SQL. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.user	string		Nama pengguna yang akan digunakan untuk menyambungkan ke database Azure SQL. Diperlukan pada permintaan PUT (CreateOrReplace).
type	string: Microsoft.Sql/Server/Database		Menunjukkan jenis output sumber data yang akan ditulis. Diperlukan pada permintaan PUT (CreateOrReplace).

AzureSqlReferenceInputDataSource

Menjelaskan sumber data input referensi database Azure SQL.

Nama	Jenis	Deskripsi
properties.database	string	Elemen ini dikaitkan dengan elemen sumber data. Ini adalah nama database tempat output akan ditulis.
properties.deltaSnapshotQuery	string	Elemen ini dikaitkan dengan elemen sumber data. Kueri ini digunakan untuk mengambil perubahan inkremental dari database SQL. Untuk menggunakan opsi ini, sebaiknya gunakan tabel temporal di Azure SQL Database.
properties.fullSnapshotQuery	string	Elemen ini dikaitkan dengan elemen sumber data. Kueri ini digunakan untuk mengambil data dari database sql.
properties.password	string	Elemen ini dikaitkan dengan elemen sumber data. Ini adalah kata sandi yang akan digunakan untuk menyambungkan ke instans SQL Database.
properties.refreshRate	string	Elemen ini dikaitkan dengan elemen sumber data. Ini menunjukkan seberapa sering data akan diambil dari database. Ini adalah format DateTime.
properties.refreshType	RefreshType	Menunjukkan jenis opsi refresh data.
properties.server	string	Elemen ini dikaitkan dengan elemen sumber data. Ini adalah nama server yang berisi database yang akan ditulis.
properties.table	string	Elemen ini dikaitkan dengan elemen sumber data. Nama tabel dalam database Azure SQL..
properties.user	string	Elemen ini dikaitkan dengan elemen sumber data. Ini adalah nama pengguna yang akan digunakan untuk menyambungkan ke instans SQL Database.
type	string: Microsoft.Sql/Server/Database	Menunjukkan jenis sumber data input yang berisi data referensi. Diperlukan pada permintaan PUT (CreateOrReplace).

AzureSynapseOutputDataSource

Menjelaskan sumber data output Azure Synapse.

Nama	Jenis	Deskripsi
properties.database	string	Nama database Azure SQL. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.password	string	Kata sandi yang akan digunakan untuk menyambungkan ke database Azure SQL. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.server	string	Nama server SQL yang berisi database Azure SQL. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.table	string	Nama tabel dalam database Azure SQL. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.user	string	Nama pengguna yang akan digunakan untuk menyambungkan ke database Azure SQL. Diperlukan pada permintaan PUT (CreateOrReplace).
type	string: Microsoft.Sql/Server/DataWarehouse	Menunjukkan jenis output sumber data yang akan ditulis. Diperlukan pada permintaan PUT (CreateOrReplace).

AzureTableOutputDataSource

Menjelaskan sumber data output Tabel Azure.

Nama	Jenis	Deskripsi
properties.accountKey	string	Kunci akun untuk akun Azure Storage. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.accountName	string	Nama akun Azure Storage. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.batchSize	integer	Jumlah baris yang akan ditulis ke Tabel Azure pada satu waktu.
properties.columnsToRemove	string[]	Jika ditentukan, setiap item dalam array adalah nama kolom yang akan dihapus (jika ada) dari entitas peristiwa output.
properties.partitionKey	string	Elemen ini menunjukkan nama kolom dari pernyataan SELECT dalam kueri yang akan digunakan sebagai kunci partisi untuk Tabel Azure. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.rowKey	string	Elemen ini menunjukkan nama kolom dari pernyataan SELECT dalam kueri yang akan digunakan sebagai kunci baris untuk Tabel Azure. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.table	string	Nama Tabel Azure. Diperlukan pada permintaan PUT (CreateOrReplace).
type	string: Microsoft.Storage/Table	Menunjukkan jenis output sumber data yang akan ditulis. Diperlukan pada permintaan PUT (CreateOrReplace).

BlobOutputDataSource

Menjelaskan sumber data output blob.

Nama	Jenis	Nilai Default	Deskripsi
properties.authenticationMode	AuthenticationMode	ConnectionString	Mode Autentikasi.
properties.blobPathPrefix	string		Awalan jalur blob.
properties.container	string		Nama kontainer dalam akun Penyimpanan terkait. Kontainer ini berisi blob yang akan dibaca atau ditulis. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.dateFormat	string		Format tanggal. Di mana pun {date} muncul di pathPattern, nilai properti ini digunakan sebagai format tanggal sebagai gantinya.
properties.pathPattern	string		Pola jalur blob. Bukan ekspresi reguler. Ini mewakili pola terhadap nama blob mana yang akan dicocokkan untuk menentukan apakah nama tersebut harus disertakan sebagai input atau output ke pekerjaan atau tidak. Lihat https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input atau https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output untuk penjelasan dan contoh yang lebih rinci.
properties.storageAccounts	StorageAccount[]		Daftar satu atau beberapa akun Azure Storage. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.timeFormat	string		Format waktu. Di mana pun {time} muncul di pathPattern, nilai properti ini digunakan sebagai format waktu sebagai gantinya.
type	string: Microsoft.Storage/Blob		Menunjukkan jenis output sumber data yang akan ditulis. Diperlukan pada permintaan PUT (CreateOrReplace).

BlobReferenceInputDataSource

Menjelaskan sumber data input blob yang berisi data referensi.

Nama	Jenis	Nilai Default	Deskripsi
properties.authenticationMode	AuthenticationMode	ConnectionString	Mode Autentikasi.
properties.container	string		Nama kontainer dalam akun Penyimpanan terkait. Kontainer ini berisi blob yang akan dibaca atau ditulis. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.dateFormat	string		Format tanggal. Di mana pun {date} muncul di pathPattern, nilai properti ini digunakan sebagai format tanggal sebagai gantinya.
properties.pathPattern	string		Pola jalur blob. Bukan ekspresi reguler. Ini mewakili pola yang mencocokkan nama blob mana yang akan dicocokkan untuk menentukan apakah nama tersebut harus disertakan sebagai input atau output ke pekerjaan atau tidak. Lihat https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input atau https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output untuk penjelasan dan contoh yang lebih rinci.
properties.storageAccounts	StorageAccount[]		Daftar satu atau beberapa akun Azure Storage. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.timeFormat	string		Format waktu. Di mana pun {time} muncul di pathPattern, nilai properti ini digunakan sebagai format waktu sebagai gantinya.
type	string: Microsoft.Storage/Blob		Menunjukkan jenis sumber data input yang berisi data referensi. Diperlukan pada permintaan PUT (CreateOrReplace).

BlobStreamInputDataSource

Menjelaskan sumber data input blob yang berisi data aliran.

Nama	Jenis	Nilai Default	Deskripsi
properties.authenticationMode	AuthenticationMode	ConnectionString	Mode Autentikasi.
properties.container	string		Nama kontainer dalam akun Penyimpanan terkait. Kontainer ini berisi blob yang akan dibaca atau ditulis. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.dateFormat	string		Format tanggal. Di mana pun {date} muncul di pathPattern, nilai properti ini digunakan sebagai format tanggal sebagai gantinya.
properties.pathPattern	string		Pola jalur blob. Bukan ekspresi reguler. Ini mewakili pola yang mencocokkan nama blob mana yang akan dicocokkan untuk menentukan apakah nama tersebut harus disertakan sebagai input atau output ke pekerjaan atau tidak. Lihat https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input atau https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output untuk penjelasan dan contoh yang lebih rinci.
properties.sourcePartitionCount	integer		Jumlah partisi sumber data input blob. Rentang 1 - 1024.
properties.storageAccounts	StorageAccount[]		Daftar satu atau beberapa akun Azure Storage. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.timeFormat	string		Format waktu. Di mana pun {time} muncul di pathPattern, nilai properti ini digunakan sebagai format waktu sebagai gantinya.
type	string: Microsoft.Storage/Blob		Menunjukkan jenis sumber data input yang berisi data aliran. Diperlukan pada permintaan PUT (CreateOrReplace).

ClusterInfo

Properti yang terkait dengan kluster Azure Stream Analytics.

Nama	Jenis	Deskripsi
id	string	Id sumber daya kluster.

CompatibilityLevel

Mengontrol perilaku runtime tertentu dari pekerjaan streaming.

Nama	Jenis	Deskripsi
1.0	string
1.2	string

Compression

Menjelaskan bagaimana data input dikompresi

Nama	Jenis	Nilai Default	Deskripsi
type	CompressionType	None	Menunjukkan jenis kompresi yang digunakan input. Diperlukan pada permintaan PUT (CreateOrReplace).

CompressionType

Menunjukkan jenis kompresi yang digunakan input. Diperlukan pada permintaan PUT (CreateOrReplace).

Nama	Jenis	Deskripsi
Deflate	string
GZip	string
None	string

ContentStoragePolicy

Nilai yang valid adalah JobStorageAccount dan SystemAccount. Jika diatur ke JobStorageAccount, ini mengharuskan pengguna untuk juga menentukan properti jobStorageAccount. .

Nama	Jenis	Deskripsi
JobStorageAccount	string
SystemAccount	string

CsvSerialization

Menjelaskan bagaimana data dari input diserialisasikan atau bagaimana data diserialisasikan saat ditulis ke output dalam format CSV.

Nama	Jenis	Deskripsi
properties.encoding	Encoding	Menentukan pengodean data masuk dalam kasus input dan pengodean data keluar dalam kasus output. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.fieldDelimiter	string	Menentukan pemisah yang akan digunakan untuk memisahkan rekaman nilai yang dipisahkan koma (CSV). Lihat https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input atau https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output untuk daftar nilai yang didukung. Diperlukan pada permintaan PUT (CreateOrReplace).
type	string: Csv	Menunjukkan jenis serialisasi yang digunakan input atau output. Diperlukan pada permintaan PUT (CreateOrReplace).

DiagnosticCondition

Kondisi yang berlaku untuk sumber daya, atau untuk pekerjaan secara keseluruhan, yang menjamin perhatian pelanggan.

Nama	Jenis	Deskripsi
code	string	Kode diagnostik buram.
message	string	Pesan yang dapat dibaca manusia yang menjelaskan kondisi secara rinci. Dilokalkan dalam Accept-Language permintaan klien.
since	string	Tanda waktu UTC saat kondisi dimulai. Pelanggan harus dapat menemukan peristiwa yang sesuai dalam log ops sekitar waktu ini.

Diagnostics

Menjelaskan kondisi yang berlaku untuk Input, Output, atau pekerjaan secara keseluruhan, yang menjamin perhatian pelanggan.

Nama	Jenis	Deskripsi
conditions	DiagnosticCondition[]	Kumpulan nol atau lebih kondisi yang berlaku untuk sumber daya, atau untuk pekerjaan secara keseluruhan, yang menjamin perhatian pelanggan.

DocumentDbOutputDataSource

Menjelaskan sumber data output DocumentDB.

Nama	Jenis	Deskripsi
properties.accountId	string	Nama akun atau ID DocumentDB. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.accountKey	string	Kunci akun untuk akun DocumentDB. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.collectionNamePattern	string	Pola nama koleksi untuk koleksi yang akan digunakan. Format nama koleksi dapat dibangun menggunakan token {partition} opsional, di mana partisi dimulai dari 0. Lihat bagian DocumentDB untuk https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output informasi selengkapnya. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.database	string	Nama database DocumentDB. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.documentId	string	Nama bidang dalam peristiwa output yang digunakan untuk menentukan kunci utama yang didasarkan pada operasi penyisipan atau pembaruan.
properties.partitionKey	string	Nama bidang dalam peristiwa output yang digunakan untuk menentukan kunci untuk mempartisi output di seluruh koleksi. Jika 'collectionNamePattern' berisi token {partition}, properti ini harus ditentukan.
type	string: Microsoft.Storage/DocumentDB	Menunjukkan jenis output sumber data yang akan ditulis. Diperlukan pada permintaan PUT (CreateOrReplace).

Encoding

Menentukan pengodean data masuk dalam kasus input dan pengodean data keluar dalam kasus output.

Nama	Jenis	Deskripsi
UTF8	string

Error

Representasi kesalahan umum.

Nama	Jenis	Deskripsi
error	Error	Properti definisi kesalahan.

EventHubOutputDataSource

Menjelaskan sumber data output Pusat Aktivitas.

Nama	Jenis	Nilai Default	Deskripsi
authenticationMode	AuthenticationMode	ConnectionString	Mode Autentikasi.
properties.eventHubName	string		Nama Pusat Aktivitas. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.partitionKey	string		Kunci/kolom yang digunakan untuk menentukan partisi mana yang akan mengirim data peristiwa.
properties.propertyColumns	string[]		Properti yang terkait dengan output Event Hub ini.
serviceBusNamespace	string		Namespace layanan yang terkait dengan Event Hub yang diinginkan, Antrean Bus Layanan, Topik Bus Layanan, dll. Diperlukan pada permintaan PUT (CreateOrReplace).
sharedAccessPolicyKey	string		Kunci kebijakan akses bersama untuk kebijakan akses bersama yang ditentukan. Diperlukan pada permintaan PUT (CreateOrReplace).
sharedAccessPolicyName	string		Nama kebijakan akses bersama untuk Pusat Aktivitas, Antrean Bus Layanan, Topik Bus Layanan, dll. Diperlukan pada permintaan PUT (CreateOrReplace).
type	string: Microsoft.ServiceBus/EventHub		Menunjukkan jenis output sumber data yang akan ditulis. Diperlukan pada permintaan PUT (CreateOrReplace).

EventHubStreamInputDataSource

Menjelaskan sumber data input Pusat Aktivitas yang berisi data aliran.

Nama	Jenis	Nilai Default	Deskripsi
authenticationMode	AuthenticationMode	ConnectionString	Mode Autentikasi.
properties.consumerGroupName	string		Nama Grup Konsumen Pusat Aktivitas yang harus digunakan untuk membaca peristiwa dari Pusat Aktivitas. Menentukan nama grup konsumen yang berbeda untuk beberapa input memungkinkan masing-masing input tersebut menerima peristiwa yang sama dari Pusat Aktivitas. Jika tidak ditentukan, input menggunakan grup konsumen default Pusat Aktivitas.
properties.eventHubName	string		Nama Pusat Aktivitas. Diperlukan pada permintaan PUT (CreateOrReplace).
serviceBusNamespace	string		Namespace layanan yang terkait dengan Event Hub yang diinginkan, Antrean Bus Layanan, Topik Bus Layanan, dll. Diperlukan pada permintaan PUT (CreateOrReplace).
sharedAccessPolicyKey	string		Kunci kebijakan akses bersama untuk kebijakan akses bersama yang ditentukan. Diperlukan pada permintaan PUT (CreateOrReplace).
sharedAccessPolicyName	string		Nama kebijakan akses bersama untuk Pusat Aktivitas, Antrean Bus Layanan, Topik Bus Layanan, dll. Diperlukan pada permintaan PUT (CreateOrReplace).
type	string: Microsoft.ServiceBus/EventHub		Menunjukkan jenis sumber data input yang berisi data aliran. Diperlukan pada permintaan PUT (CreateOrReplace).

EventHubV2OutputDataSource

Menjelaskan sumber data output Event Hub.

Nama	Jenis	Nilai Default	Deskripsi
authenticationMode	AuthenticationMode	ConnectionString	Mode Autentikasi.
properties.eventHubName	string		Nama Pusat Aktivitas. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.partitionKey	string		Kunci/kolom yang digunakan untuk menentukan partisi mana yang akan mengirim data peristiwa.
properties.propertyColumns	string[]		Properti yang terkait dengan output Event Hub ini.
serviceBusNamespace	string		Namespace layanan yang terkait dengan Event Hub yang diinginkan, Antrean Bus Layanan, Topik Bus Layanan, dll. Diperlukan pada permintaan PUT (CreateOrReplace).
sharedAccessPolicyKey	string		Kunci kebijakan akses bersama untuk kebijakan akses bersama yang ditentukan. Diperlukan pada permintaan PUT (CreateOrReplace).
sharedAccessPolicyName	string		Nama kebijakan akses bersama untuk Pusat Aktivitas, Antrean Bus Layanan, Topik Bus Layanan, dll. Diperlukan pada permintaan PUT (CreateOrReplace).
type	string: Microsoft.EventHub/EventHub		Menunjukkan jenis output sumber data yang akan ditulis. Diperlukan pada permintaan PUT (CreateOrReplace).

EventHubV2StreamInputDataSource

Menjelaskan sumber data input Pusat Aktivitas yang berisi data aliran.

Nama	Jenis	Nilai Default	Deskripsi
authenticationMode	AuthenticationMode	ConnectionString	Mode Autentikasi.
properties.consumerGroupName	string		Nama Grup Konsumen Pusat Aktivitas yang harus digunakan untuk membaca peristiwa dari Pusat Aktivitas. Menentukan nama grup konsumen yang berbeda untuk beberapa input memungkinkan masing-masing input tersebut menerima peristiwa yang sama dari Pusat Aktivitas. Jika tidak ditentukan, input menggunakan grup konsumen default Pusat Aktivitas.
properties.eventHubName	string		Nama Pusat Aktivitas. Diperlukan pada permintaan PUT (CreateOrReplace).
serviceBusNamespace	string		Namespace layanan yang terkait dengan Event Hub yang diinginkan, Antrean Bus Layanan, Topik Bus Layanan, dll. Diperlukan pada permintaan PUT (CreateOrReplace).
sharedAccessPolicyKey	string		Kunci kebijakan akses bersama untuk kebijakan akses bersama yang ditentukan. Diperlukan pada permintaan PUT (CreateOrReplace).
sharedAccessPolicyName	string		Nama kebijakan akses bersama untuk Pusat Aktivitas, Antrean Bus Layanan, Topik Bus Layanan, dll. Diperlukan pada permintaan PUT (CreateOrReplace).
type	string: Microsoft.EventHub/EventHub		Menunjukkan jenis sumber data input yang berisi data aliran. Diperlukan pada permintaan PUT (CreateOrReplace).

EventSerializationType

Menunjukkan jenis serialisasi yang digunakan input atau output. Diperlukan pada permintaan PUT (CreateOrReplace).

Nama	Jenis	Deskripsi
Avro	string
Csv	string
Json	string
Parquet	string

EventsOutOfOrderPolicy

Menandakan kebijakan untuk diterapkan ke peristiwa yang sampai di luar urutan dalam aliran peristiwa input.

Nama	Jenis	Deskripsi
Adjust	string
Drop	string

FileReferenceInputDataSource

Menjelaskan sumber data input file yang berisi data referensi.

Nama	Jenis	Deskripsi
properties.path	string	Jalur file.
type	string: File	Menunjukkan jenis sumber data input yang berisi data referensi. Diperlukan pada permintaan PUT (CreateOrReplace).

Function

Objek fungsi, berisi semua informasi yang terkait dengan fungsi bernama. Semua fungsi terkandung dalam pekerjaan streaming.

Nama	Jenis	Deskripsi
id	string	ID sumber daya
name	string	Nama sumber daya
properties	FunctionProperties: AggregateFunctionProperties ScalarFunctionProperties	Properti yang terkait dengan fungsi.
type	string	Jenis Sumber Daya

FunctionInput

Menjelaskan satu parameter input fungsi.

Nama	Jenis	Deskripsi
dataType	string	Jenis data (didukung Azure Stream Analytics) dari parameter input fungsi. Daftar jenis data Azure Stream Analytics yang valid dijelaskan di https://msdn.microsoft.com/en-us/library/azure/dn835065.aspx
isConfigurationParameter	boolean	Bendera yang menunjukkan apakah parameter adalah parameter konfigurasi. True jika parameter input ini diharapkan menjadi konstanta. Defaultnya adalah false.

FunctionOutput

Menjelaskan output fungsi.

Nama	Jenis	Deskripsi
dataType	string	Jenis data (didukung Azure Stream Analytics) dari output fungsi. Daftar jenis data Azure Stream Analytics yang valid dijelaskan di https://msdn.microsoft.com/en-us/library/azure/dn835065.aspx

GatewayMessageBusOutputDataSource

Menjelaskan sumber data output Bus Pesan Gateway.

Nama	Jenis	Deskripsi
properties.topic	string	Nama topik Bus Layanan.
type	string: GatewayMessageBus	Menunjukkan jenis output sumber data yang akan ditulis. Diperlukan pada permintaan PUT (CreateOrReplace).

GatewayMessageBusStreamInputDataSource

Menjelaskan sumber data input blob yang berisi data aliran.

Nama	Jenis	Deskripsi
properties.topic	string	Nama topik Bus Layanan.
type	string: GatewayMessageBus	Menunjukkan jenis sumber data input yang berisi data aliran. Diperlukan pada permintaan PUT (CreateOrReplace).

Identity

Menjelaskan bagaimana identitas diverifikasi

Nama	Jenis	Deskripsi
principalId	string	ID prinsipal identitas
tenantId	string	Idpenyewa identitas
type	string	Jenis identitas

Input

Objek input, berisi semua informasi yang terkait dengan input bernama. Semua input terkandung di bawah pekerjaan streaming.

Nama	Jenis	Deskripsi
id	string	ID sumber daya
name	string	Nama sumber daya
properties	InputProperties: ReferenceInputProperties StreamInputProperties	Properti yang terkait dengan input. Diperlukan pada permintaan PUT (CreateOrReplace).
type	string	Jenis Sumber Daya

IoTHubStreamInputDataSource

Menjelaskan sumber data input IoT Hub yang berisi data aliran.

Nama	Jenis	Deskripsi
properties.consumerGroupName	string	Nama Grup Konsumen IoT Hub yang harus digunakan untuk membaca peristiwa dari IoT Hub. Jika tidak ditentukan, input menggunakan grup konsumen default Iot Hub.
properties.endpoint	string	Titik akhir IoT Hub untuk disambungkan (yaitu pesan/peristiwa, pesan/operasiMonitoringEvents, dll.).
properties.iotHubNamespace	string	Nama atau URI IoT Hub. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.sharedAccessPolicyKey	string	Kunci kebijakan akses bersama untuk kebijakan akses bersama yang ditentukan. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.sharedAccessPolicyName	string	Nama kebijakan akses bersama untuk IoT Hub. Kebijakan ini harus berisi setidaknya izin Sambungan layanan. Diperlukan pada permintaan PUT (CreateOrReplace).
type	string: Microsoft.Devices/IotHubs	Menunjukkan jenis sumber data input yang berisi data aliran. Diperlukan pada permintaan PUT (CreateOrReplace).

JavaScriptFunctionBinding

Pengikatan ke fungsi JavaScript.

Nama	Jenis	Deskripsi
properties.script	string	Kode JavaScript yang berisi definisi fungsi tunggal. Misalnya: 'function (x, y) { return x + y; }'
type	string: Microsoft.StreamAnalytics/JavascriptUdf	Menunjukkan jenis pengikatan fungsi.

JobStorageAccount

Properti yang terkait dengan akun Azure Storage dengan MSI

Nama	Jenis	Nilai Default	Deskripsi
accountKey	string		Kunci akun untuk akun Azure Storage. Diperlukan pada permintaan PUT (CreateOrReplace).
accountName	string		Nama akun Azure Storage. Diperlukan pada permintaan PUT (CreateOrReplace).
authenticationMode	AuthenticationMode	ConnectionString	Mode Autentikasi.

JobType

Menjelaskan jenis pekerjaan. Mode yang valid adalah Cloud dan 'Edge'.

Nama	Jenis	Deskripsi
Cloud	string
Edge	string

JsonOutputSerializationFormat

Menentukan format JSON tempat output akan ditulis. Nilai yang saat ini didukung adalah 'lineSeparated' yang menunjukkan output akan diformat dengan memformat setiap objek JSON yang dipisahkan oleh baris baru dan 'array' yang menunjukkan output akan diformat sebagai array objek JSON.

Nama	Jenis	Deskripsi
Array	string
LineSeparated	string

JsonSerialization

Menjelaskan bagaimana data dari input diserialisasikan atau bagaimana data diserialisasikan saat ditulis ke output dalam format JSON.

Nama	Jenis	Deskripsi
properties.encoding	Encoding	Menentukan pengodean data masuk dalam kasus input dan pengodean data keluar dalam kasus output. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.format	JsonOutputSerializationFormat	Properti ini hanya berlaku untuk serialisasi JSON output saja. Ini tidak berlaku untuk input. Properti ini menentukan format JSON tempat output akan ditulis. Nilai yang saat ini didukung adalah 'lineSeparated' yang menunjukkan output akan diformat dengan memisahkan setiap objek JSON yang dipisahkan oleh baris baru dan 'array' yang menunjukkan output akan diformat sebagai array objek JSON. Nilai defaultnya adalah 'lineSeparated' jika dibiarkan null.
type	string: Json	Menunjukkan jenis serialisasi yang digunakan input atau output. Diperlukan pada permintaan PUT (CreateOrReplace).

Output

Objek output, berisi semua informasi yang terkait dengan output bernama. Semua output terkandung di bawah pekerjaan streaming.

Nama	Jenis	Deskripsi
id	string	ID sumber daya
name	string	Nama sumber daya
properties.datasource	OutputDataSource: AzureDataLakeStoreOutputDataSource AzureFunctionOutputDataSource AzureSqlDatabaseOutputDataSource AzureSynapseOutputDataSource AzureTableOutputDataSource BlobOutputDataSource DocumentDbOutputDataSource EventHubOutputDataSource EventHubV2OutputDataSource GatewayMessageBusOutputDataSource PowerBIOutputDataSource ServiceBusQueueOutputDataSource ServiceBusTopicOutputDataSource	Menjelaskan sumber data tempat output akan ditulis. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.diagnostics	Diagnostics	Menjelaskan kondisi yang berlaku untuk Input, Output, atau pekerjaan secara keseluruhan, yang menjamin perhatian pelanggan.
properties.etag	string	Tag entitas saat ini untuk output. Ini adalah string buram. Anda dapat menggunakannya untuk mendeteksi apakah sumber daya telah berubah di antara permintaan. Anda juga dapat menggunakannya di header If-Match atau If-None-Match untuk operasi tulis untuk konkurensi optimis.
properties.serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Menjelaskan bagaimana data dari input diserialisasikan atau bagaimana data diserialisasikan saat ditulis ke output. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.sizeWindow	integer	Jendela ukuran untuk membatasi output Azure Stream Analytics.
properties.timeWindow	string	Jangka waktu untuk memfilter output pekerjaan Azure Stream Analytics.
type	string	Jenis Sumber Daya

OutputErrorPolicy

Menandakan kebijakan untuk diterapkan ke peristiwa yang mencapai output dan tidak dapat ditulis ke penyimpanan eksternal karena cacat (nilai kolom hilang, nilai kolom dengan jenis atau ukuran yang salah).

Nama	Jenis	Deskripsi
Drop	string
Stop	string

OutputStartMode

Nilainya mungkin JobStartTime, CustomTime, atau LastOutputEventTime untuk menunjukkan apakah titik awal aliran peristiwa output harus dimulai setiap kali pekerjaan dimulai, mulai dari stempel waktu pengguna kustom yang ditentukan melalui properti outputStartTime, atau mulai dari waktu output peristiwa terakhir.

Nama	Jenis	Deskripsi
CustomTime	string
JobStartTime	string
LastOutputEventTime	string

ParquetSerialization

Menjelaskan bagaimana data dari input diserialisasikan atau bagaimana data diserialisasikan saat ditulis ke output dalam format Parquet.

Nama	Jenis	Deskripsi
type	string: Parquet	Menunjukkan jenis serialisasi yang digunakan input atau output. Diperlukan pada permintaan PUT (CreateOrReplace).

PowerBIOutputDataSource

Menjelaskan sumber data output Power BI.

Nama	Jenis	Nilai Default	Deskripsi
properties.authenticationMode	AuthenticationMode	ConnectionString	Mode Autentikasi.
properties.dataset	string		Nama himpunan data Power BI. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.groupId	string		ID grup Power BI.
properties.groupName	string		Nama grup Power BI. Gunakan properti ini untuk membantu mengingat id grup Power BI tertentu yang digunakan.
properties.refreshToken	string		Token refresh yang dapat digunakan untuk mendapatkan token akses valid yang kemudian dapat digunakan untuk mengautentikasi dengan sumber data. Token refresh yang valid saat ini hanya dapat diperoleh melalui Portal Microsoft Azure. Disarankan untuk menempatkan nilai string dummy di sini saat membuat sumber data dan kemudian masuk ke Portal Azure untuk mengautentikasi sumber data yang akan memperbarui properti ini dengan token refresh yang valid. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.table	string		Nama tabel Power BI di bawah himpunan data yang ditentukan. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.tokenUserDisplayName	string		Nama tampilan pengguna pengguna yang digunakan untuk mendapatkan token refresh. Gunakan properti ini untuk membantu mengingat pengguna mana yang digunakan untuk mendapatkan token refresh.
properties.tokenUserPrincipalName	string		Nama prinsipal pengguna (UPN) pengguna yang digunakan untuk mendapatkan token refresh. Gunakan properti ini untuk membantu mengingat pengguna mana yang digunakan untuk mendapatkan token refresh.
type	string: PowerBI		Menunjukkan jenis output sumber data yang akan ditulis. Diperlukan pada permintaan PUT (CreateOrReplace).

ReferenceInputProperties

Properti yang terkait dengan input yang berisi data referensi.

Nama	Jenis	Deskripsi
compression	Compression	Menjelaskan bagaimana data input dikompresi
datasource	ReferenceInputDataSource: AzureSqlReferenceInputDataSource BlobReferenceInputDataSource FileReferenceInputDataSource	Menjelaskan sumber data input yang berisi data referensi. Diperlukan pada permintaan PUT (CreateOrReplace).
diagnostics	Diagnostics	Menjelaskan kondisi yang berlaku untuk Input, Output, atau pekerjaan secara keseluruhan, yang menjamin perhatian pelanggan.
etag	string	Tag entitas saat ini untuk input. Ini adalah string buram. Anda dapat menggunakannya untuk mendeteksi apakah sumber daya telah berubah di antara permintaan. Anda juga dapat menggunakannya di header If-Match atau If-None-Match untuk operasi tulis untuk konkurensi optimis.
partitionKey	string	partitionKey Menjelaskan kunci dalam data input yang digunakan untuk mempartisi data input
serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Menjelaskan bagaimana data dari input diserialisasikan atau bagaimana data diserialisasikan saat ditulis ke output. Diperlukan pada permintaan PUT (CreateOrReplace).
type	string: Reference	Menunjukkan apakah input adalah sumber data referensi atau data aliran. Diperlukan pada permintaan PUT (CreateOrReplace).

RefreshType

Menunjukkan jenis opsi refresh data.

Nama	Jenis	Deskripsi
RefreshPeriodicallyWithDelta	string
RefreshPeriodicallyWithFull	string
Static	string

ScalarFunctionProperties

Properti yang terkait dengan fungsi skalar.

Nama	Jenis	Deskripsi
etag	string	Tag entitas saat ini untuk fungsi . Ini adalah string buram. Anda dapat menggunakannya untuk mendeteksi apakah sumber daya telah berubah di antara permintaan. Anda juga dapat menggunakannya di header If-Match atau If-None-Match untuk operasi tulis untuk konkurensi optimis.
properties.binding	FunctionBinding: AzureMachineLearningWebServiceFunctionBinding JavaScriptFunctionBinding	Pengikatan fisik fungsi. Misalnya, dalam kasus layanan web Azure Machine Learning, ini menjelaskan titik akhir.
properties.inputs	FunctionInput[]	Menjelaskan satu parameter input fungsi.
properties.output	FunctionOutput	Menjelaskan output fungsi.
type	string: Scalar	Menunjukkan jenis fungsi.

ServiceBusQueueOutputDataSource

Menjelaskan sumber data output Antrean Azure Service Bus.

Nama	Jenis	Nilai Default	Deskripsi
properties.authenticationMode	AuthenticationMode	ConnectionString	Mode Autentikasi.
properties.propertyColumns	string[]		Array string dari nama kolom output yang akan dilampirkan ke pesan Azure Service Bus sebagai properti kustom.
properties.queueName	string		Nama Antrean Bus Layanan. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.serviceBusNamespace	string		Namespace layanan yang terkait dengan Event Hub yang diinginkan, Antrean Bus Layanan, Topik Bus Layanan, dll. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.sharedAccessPolicyKey	string		Kunci kebijakan akses bersama untuk kebijakan akses bersama yang ditentukan. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.sharedAccessPolicyName	string		Nama kebijakan akses bersama untuk Pusat Aktivitas, Antrean Bus Layanan, Topik Bus Layanan, dll. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.systemPropertyColumns	object		Properti sistem yang terkait dengan Antrean Bus Layanan. Properti sistem berikut didukung: ReplyToSessionId, ContentType, To, Subject, CorrelationId, TimeToLive, PartitionKey, SessionId, ScheduledEnqueueTime, MessageId, ReplyTo, Label, ScheduledEnqueueTimeUtc.
type	string: Microsoft.ServiceBus/Queue		Menunjukkan jenis output sumber data yang akan ditulis. Diperlukan pada permintaan PUT (CreateOrReplace).

ServiceBusTopicOutputDataSource

Menjelaskan sumber data output Topik Bus Layanan.

Nama	Jenis	Nilai Default	Deskripsi
properties.authenticationMode	AuthenticationMode	ConnectionString	Mode Autentikasi.
properties.propertyColumns	string[]		Array string dari nama kolom output yang akan dilampirkan ke pesan Azure Service Bus sebagai properti kustom.
properties.serviceBusNamespace	string		Namespace layanan yang terkait dengan Event Hub yang diinginkan, Antrean Bus Layanan, Topik Bus Layanan, dll. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.sharedAccessPolicyKey	string		Kunci kebijakan akses bersama untuk kebijakan akses bersama yang ditentukan. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.sharedAccessPolicyName	string		Nama kebijakan akses bersama untuk Pusat Aktivitas, Antrean Bus Layanan, Topik Bus Layanan, dll. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.systemPropertyColumns	object		Properti sistem yang terkait dengan Output Topik Bus Layanan. Properti sistem berikut didukung: ReplyToSessionId, ContentType, To, Subject, CorrelationId, TimeToLive, PartitionKey, SessionId, ScheduledEnqueueTime, MessageId, ReplyTo, Label, ScheduledEnqueueTimeUtc.
properties.topicName	string		Nama Topik Bus Layanan. Diperlukan pada permintaan PUT (CreateOrReplace).
type	string: Microsoft.ServiceBus/Topic		Menunjukkan jenis output sumber data yang akan ditulis. Diperlukan pada permintaan PUT (CreateOrReplace).

Sku

Properti yang terkait dengan SKU.

Nama	Jenis	Deskripsi
name	SkuName	Nama SKUnya. Diperlukan pada permintaan PUT (CreateOrReplace).

SkuName

Nama SKUnya. Diperlukan pada permintaan PUT (CreateOrReplace).

Nama	Jenis	Deskripsi
Standard	string

StorageAccount

Properti yang terkait dengan akun Azure Storage

Nama	Jenis	Deskripsi
accountKey	string	Kunci akun untuk akun Azure Storage. Diperlukan pada permintaan PUT (CreateOrReplace).
accountName	string	Nama akun Azure Storage. Diperlukan pada permintaan PUT (CreateOrReplace).

StreamingJob

Objek pekerjaan streaming, berisi semua informasi yang terkait dengan pekerjaan streaming bernama.

Nama	Jenis	Deskripsi
id	string	Id sumber daya yang sepenuhnya memenuhi syarat untuk sumber daya. Ex - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
identity	Identity	Menjelaskan identitas terkelola yang ditetapkan sistem yang ditetapkan untuk pekerjaan ini yang dapat digunakan untuk mengautentikasi dengan input dan output.
location	string	Lokasi geografis tempat sumber daya berada
name	string	Nama sumber daya.
properties.cluster	ClusterInfo	Kluster tempat pekerjaan streaming akan berjalan.
properties.compatibilityLevel	CompatibilityLevel	Mengontrol perilaku runtime tertentu dari pekerjaan streaming.
properties.contentStoragePolicy	ContentStoragePolicy	Nilai yang valid adalah JobStorageAccount dan SystemAccount. Jika diatur ke JobStorageAccount, ini mengharuskan pengguna untuk juga menentukan properti jobStorageAccount. .
properties.createdDate	string	Nilai adalah tanda waktu UTC berformat ISO-8601 yang menunjukkan kapan pekerjaan streaming dibuat.
properties.dataLocale	string	Lokal data dari pekerjaan analitik stream. Nilai harus menjadi nama .NET Culture yang didukung dari set https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspx. Tentukan default ke 'en-US' jika tidak ditentukan.
properties.etag	string	Tag entitas saat ini untuk pekerjaan streaming. Ini adalah string buram. Anda dapat menggunakannya untuk mendeteksi apakah sumber daya telah berubah di antara permintaan. Anda juga dapat menggunakannya di header If-Match atau If-None-Match untuk operasi tulis untuk konkurensi optimis.
properties.eventsLateArrivalMaxDelayInSeconds	integer	Maksimum penundaan yang dapat ditoleransi dalam hitungan detik agar peristiwa yang datang terlambat dapat disertakan. Rentang yang didukung adalah -1 hingga 1814399 (20.23:59:59 hari) dan -1 digunakan untuk menentukan tunggu tanpa batas waktu. Jika properti tidak ada, peristiwa dianggap memiliki nilai -1.
properties.eventsOutOfOrderMaxDelayInSeconds	integer	Penundaan maksimum yang dapat ditoleransi dalam hitungan detik agar peristiwa yang keluar dari urutan dapat disesuaikan kembali ke dalam urutan.
properties.eventsOutOfOrderPolicy	EventsOutOfOrderPolicy	Menandakan kebijakan untuk diterapkan ke peristiwa yang sampai di luar urutan dalam aliran peristiwa input.
properties.functions	Function[]	Daftar satu atau beberapa fungsi untuk pekerjaan streaming. Properti nama untuk setiap fungsi diperlukan saat menentukan properti ini dalam permintaan PUT. Properti ini tidak dapat diubah melalui operasi PATCH. Anda harus menggunakan API PATCH yang tersedia untuk transformasi individual.
properties.inputs	Input[]	Daftar satu atau beberapa input ke pekerjaan streaming. Properti nama untuk setiap input diperlukan saat menentukan properti ini dalam permintaan PUT. Properti ini tidak dapat diubah melalui operasi PATCH. Anda harus menggunakan API PATCH yang tersedia untuk input individual.
properties.jobId	string	GUID secara unik mengidentifikasi pekerjaan streaming. GUID ini dihasilkan setelah pembuatan pekerjaan streaming.
properties.jobState	string	Menjelaskan status pekerjaan streaming.
properties.jobStorageAccount	JobStorageAccount	Properti yang terkait dengan akun Azure Storage dengan MSI
properties.jobType	JobType	Menjelaskan jenis pekerjaan. Mode yang valid adalah Cloud dan 'Edge'.
properties.lastOutputEventTime	string	Nilai adalah tanda waktu berformat ISO-8601 yang menunjukkan waktu peristiwa output terakhir dari pekerjaan streaming atau null yang menunjukkan bahwa output belum diproduksi. Dalam kasus beberapa output atau beberapa aliran, ini menunjukkan nilai terbaru dalam set tersebut.
properties.outputErrorPolicy	OutputErrorPolicy	Menandakan kebijakan untuk diterapkan ke peristiwa yang mencapai output dan tidak dapat ditulis ke penyimpanan eksternal karena cacat (nilai kolom hilang, nilai kolom dengan jenis atau ukuran yang salah).
properties.outputStartMode	OutputStartMode	Properti ini hanya boleh digunakan ketika diinginkan bahwa pekerjaan segera dimulai setelah pembuatan. Nilainya mungkin JobStartTime, CustomTime, atau LastOutputEventTime untuk menunjukkan apakah titik awal aliran peristiwa output harus dimulai setiap kali pekerjaan dimulai, mulai dari stempel waktu pengguna kustom yang ditentukan melalui properti outputStartTime, atau mulai dari waktu output peristiwa terakhir.
properties.outputStartTime	string	Nilai adalah stempel waktu berformat ISO-8601 yang menunjukkan titik awal aliran peristiwa output, atau null untuk menunjukkan bahwa aliran peristiwa output akan dimulai setiap kali pekerjaan streaming dimulai. Properti ini harus memiliki nilai jika outputStartMode diatur ke CustomTime.
properties.outputs	Output[]	Daftar satu atau beberapa output untuk pekerjaan streaming. Properti nama untuk setiap output diperlukan saat menentukan properti ini dalam permintaan PUT. Properti ini tidak dapat diubah melalui operasi PATCH. Anda harus menggunakan API PATCH yang tersedia untuk output individual.
properties.provisioningState	string	Menjelaskan status provisi pekerjaan streaming.
properties.sku	Sku	Menjelaskan SKU pekerjaan streaming. Diperlukan pada permintaan PUT (CreateOrReplace).
properties.transformation	Transformation	Menunjukkan kueri dan jumlah unit streaming yang akan digunakan untuk pekerjaan streaming. Properti nama transformasi diperlukan saat menentukan properti ini dalam permintaan PUT. Properti ini tidak dapat diubah melalui operasi PATCH. Anda harus menggunakan API PATCH yang tersedia untuk transformasi individual.
tags	object	Tag sumber daya.
type	string	Jenis sumber daya. Ex- Microsoft.Compute/virtualMachines atau Microsoft.Storage/storageAccounts.

StreamingJobListResult

Objek yang berisi daftar pekerjaan streaming.

Nama	Jenis	Deskripsi
nextLink	string	Tautan (url) ke halaman hasil berikutnya.
value	StreamingJob[]	Daftar pekerjaan streaming. Diisi oleh operasi 'Daftar'.

StreamInputProperties

Properti yang terkait dengan input yang berisi data aliran.

Nama	Jenis	Deskripsi
compression	Compression	Menjelaskan bagaimana data input dikompresi
datasource	StreamInputDataSource: BlobStreamInputDataSource EventHubStreamInputDataSource EventHubV2StreamInputDataSource GatewayMessageBusStreamInputDataSource IoTHubStreamInputDataSource	Menjelaskan sumber data input yang berisi data aliran. Diperlukan pada permintaan PUT (CreateOrReplace).
diagnostics	Diagnostics	Menjelaskan kondisi yang berlaku untuk Input, Output, atau pekerjaan secara keseluruhan, yang menjamin perhatian pelanggan.
etag	string	Tag entitas saat ini untuk input. Ini adalah string buram. Anda dapat menggunakannya untuk mendeteksi apakah sumber daya telah berubah di antara permintaan. Anda juga dapat menggunakannya di header If-Match atau If-None-Match untuk operasi tulis untuk konkurensi optimis.
partitionKey	string	partitionKey Menjelaskan kunci dalam data input yang digunakan untuk mempartisi data input
serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	Menjelaskan bagaimana data dari input diserialisasikan atau bagaimana data diserialisasikan saat ditulis ke output. Diperlukan pada permintaan PUT (CreateOrReplace).
type	string: Stream	Menunjukkan apakah input adalah sumber data referensi atau data aliran. Diperlukan pada permintaan PUT (CreateOrReplace).

Transformation

Objek transformasi, berisi semua informasi yang terkait dengan transformasi bernama. Semua transformasi terkandung di bawah pekerjaan streaming.

Nama	Jenis	Nilai Default	Deskripsi
id	string		ID sumber daya
name	string		Nama sumber daya
properties.etag	string		Tag entitas saat ini untuk transformasi. Ini adalah string buram. Anda dapat menggunakannya untuk mendeteksi apakah sumber daya telah berubah di antara permintaan. Anda juga dapat menggunakannya di header If-Match atau If-None-Match untuk operasi tulis untuk konkurensi optimis.
properties.query	string		Menentukan kueri yang akan dijalankan dalam pekerjaan streaming. Anda dapat mempelajari selengkapnya tentang Bahasa Kueri Azure Stream Analytics (SAQL) di sini: https://msdn.microsoft.com/library/azure/dn834998 . Diperlukan pada permintaan PUT (CreateOrReplace).
properties.streamingUnits	integer	3	Menentukan jumlah unit streaming yang digunakan pekerjaan streaming.
properties.validStreamingUnits	integer[]		Menentukan unit streaming yang valid yang dapat diskalakan oleh pekerjaan streaming.
type	string		Jenis Sumber Daya