Streaming Jobs - Create Or Replace

참조

서비스:: Stream Analytics

API 버전:: 2020-03-01

스트리밍 작업을 만들거나 기존 스트리밍 작업을 대체합니다.

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

URI 매개 변수

Name	In(다음 안에)	필수	형식	Description
jobName	path	True	string	스트리밍 작업의 이름입니다.
resourceGroupName	path	True	string	리소스 그룹의 이름. 이름은 대소문자를 구분하지 않습니다. regex 패턴: `^[-\w\._]+$`
subscriptionId	path	True	string	대상 구독의 ID입니다.
api-version	query	True	string	이 작업에 사용할 API 버전입니다.

요청 헤더

Name	필수	형식	Description
If-Match		string	스트리밍 작업의 ETag입니다. 현재 레코드 집합을 항상 덮어쓰려면 이 값을 생략합니다. 실수로 동시 변경 내용을 덮어쓰지 않도록 마지막으로 본 ETag 값을 지정합니다.
If-None-Match		string	새 스트리밍 작업을 만들 수 있지만 기존 레코드 집합을 업데이트하지 않도록 하려면 '*'로 설정합니다. 다른 값으로 인해 412 사전 조건 실패 응답이 발생합니다.

요청 본문

Name	형식	Description
identity	Identity	입력 및 출력으로 인증하는 데 사용할 수 있는 이 작업에 할당된 시스템 할당 관리 ID에 대해 설명합니다.
location	string	리소스가 있는 지리적 위치
properties.cluster	ClusterInfo	스트리밍 작업이 실행될 클러스터입니다.
properties.compatibilityLevel	CompatibilityLevel	스트리밍 작업의 특정 런타임 동작을 제어합니다.
properties.contentStoragePolicy	ContentStoragePolicy	유효한 값은 JobStorageAccount 및 SystemAccount입니다. JobStorageAccount로 설정하면 사용자가 jobStorageAccount 속성도 지정해야 합니다. .
properties.dataLocale	string	Stream analytics 작업의 데이터 로캘입니다. 값은 집합 https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspx에서 지원되는 .NET Culture의 이름이어야 합니다. 지정하지 않을 경우 'en-US'으로 기본 설정됩니다.
properties.eventsLateArrivalMaxDelayInSeconds	integer	늦게 도착하는 이벤트를 포함하는 최대 허용 지연 시간(초)입니다. 지원되는 범위는-1에서 1814399(20.23:59:59일)이고,-1은 무기한 대기를 지정하는 데 사용됩니다. 속성이 없으면 값이-1인 것으로 해석됩니다.
properties.eventsOutOfOrderMaxDelayInSeconds	integer	순서가 잘못된 이벤트를 다시 순서대로 조정할 수 있는 최대 허용 지연 시간(초)입니다.
properties.eventsOutOfOrderPolicy	EventsOutOfOrderPolicy	입력 이벤트 스트림에 잘못된 순서로 도착하는 이벤트에 적용할 정책을 나타냅니다.
properties.functions	Function[]	스트리밍 작업에 대한 하나 이상의 함수 목록입니다. PUT 요청에서 이 속성을 지정할 때 각 함수의 name 속성이 필요합니다. 이 속성은 PATCH 작업을 통해 수정할 수 없습니다. 개별 변환에 사용할 수 있는 PATCH API를 사용해야 합니다.
properties.inputs	Input[]	스트리밍 작업에 대한 하나 이상의 입력 목록입니다. PUT 요청에서 이 속성을 지정할 때 각 입력에 대한 name 속성이 필요합니다. 이 속성은 PATCH 작업을 통해 수정할 수 없습니다. 개별 입력에 사용할 수 있는 PATCH API를 사용해야 합니다.
properties.jobStorageAccount	JobStorageAccount	MSI와 Azure Storage 계정과 연결된 속성
properties.jobType	JobType	작업의 형식을 설명합니다. 유효한 모드는 및 'Edge'입니다 `Cloud` .
properties.outputErrorPolicy	OutputErrorPolicy	형식이 잘못되었기 때문에 출력에 도착하고 외부 스토리지에 쓸 수 없는 이벤트에 적용할 정책을 나타냅니다(누락된 열 값, 잘못된 형식 또는 크기의 열 값).
properties.outputStartMode	OutputStartMode	이 속성은 작업을 만들 때 즉시 시작하려는 경우에만 활용해야 합니다. 값은 JobStartTime, CustomTime 또는 LastOutputEventTime일 수 있습니다. 이 값은 작업이 시작될 때마다 출력 이벤트 스트림의 시작점이 시작될지, outputStartTime 속성을 통해 지정된 사용자 지정 타임스탬프에서 시작해야 하는지 또는 마지막 이벤트 출력 시간부터 시작해야 하는지를 나타냅니다.
properties.outputStartTime	string	값은 출력 이벤트 스트림의 시작 시점을 나타내는 ISO-8601 형식의 타임스탬프 또는 스트리밍 작업이 시작될 때마다 이벤트 출력 스트림이 시작됨을 나타내는 null일 수 있습니다. outputStartMode가 CustomTime으로 설정된 경우 이 속성에는 값이 있어야 합니다.
properties.outputs	Output[]	스트리밍 작업에 대한 하나 이상의 출력 목록입니다. PUT 요청에서 이 속성을 지정할 때 각 출력에 대한 name 속성이 필요합니다. 이 속성은 PATCH 작업을 통해 수정할 수 없습니다. 개별 출력에 사용할 수 있는 PATCH API를 사용해야 합니다.
properties.sku	Sku	스트리밍 작업의 SKU에 대해 설명합니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.transformation	Transformation	스트리밍 작업에 사용할 쿼리 및 스트리밍 단위 수를 나타냅니다. PUT 요청에서 이 속성을 지정할 때 변환의 name 속성이 필요합니다. 이 속성은 PATCH 작업을 통해 수정할 수 없습니다. 개별 변환에 사용할 수 있는 PATCH API를 사용해야 합니다.
tags	object	리소스 태그.

응답

Name	형식	Description
200 OK	StreamingJob	스트리밍 작업이 성공적으로 만들어지거나 대체되었습니다. 헤더 ETag: string
201 Created	StreamingJob	스트리밍 작업이 성공적으로 만들어지거나 대체되었습니다. 헤더 ETag: string
Other Status Codes	Error	오류.

Name

형식

Description

200 OK

StreamingJob

스트리밍 작업이 성공적으로 만들어지거나 대체되었습니다.

헤더

ETag: string

201 Created

StreamingJob

스트리밍 작업이 성공적으로 만들어지거나 대체되었습니다.

헤더

ETag: string

Other Status Codes

Error

오류.

보안

azure_auth

Azure Active Directory OAuth2 Flow

형식: oauth2
Flow: implicit
권한 부여 URL: https://login.microsoftonline.com/common/oauth2/authorize

범위

Name	Description
user_impersonation	사용자 계정 가장

예제

Create a complete streaming job (a streaming job with a transformation, at least 1 input and at least 1 output)

Create a streaming job shell (a streaming job with no inputs, outputs, transformation, or functions)

Create a complete streaming job (a streaming job with a transformation, at least 1 input and at least 1 output)

샘플 요청

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

{
  "properties": {
    "sku": {
      "name": "Standard"
    },
    "eventsOutOfOrderPolicy": "Drop",
    "outputErrorPolicy": "Drop",
    "eventsOutOfOrderMaxDelayInSeconds": 0,
    "eventsLateArrivalMaxDelayInSeconds": 5,
    "dataLocale": "en-US",
    "compatibilityLevel": "1.0",
    "inputs": [
      {
        "properties": {
          "type": "Stream",
          "datasource": {
            "type": "Microsoft.Storage/Blob",
            "properties": {
              "storageAccounts": [
                {
                  "accountName": "yourAccountName",
                  "accountKey": "yourAccountKey=="
                }
              ],
              "container": "containerName",
              "pathPattern": ""
            }
          },
          "serialization": {
            "type": "Json",
            "properties": {
              "encoding": "UTF8"
            }
          }
        },
        "name": "inputtest"
      }
    ],
    "transformation": {
      "properties": {
        "streamingUnits": 1,
        "query": "Select Id, Name from inputtest"
      },
      "name": "transformationtest"
    },
    "outputs": [
      {
        "properties": {
          "datasource": {
            "type": "Microsoft.Sql/Server/Database",
            "properties": {
              "server": "serverName",
              "database": "databaseName",
              "user": "<user>",
              "password": "userPassword",
              "table": "tableName"
            }
          }
        },
        "name": "outputtest"
      }
    ],
    "functions": []
  },
  "location": "West US",
  "tags": {
    "key1": "value1",
    "randomKey": "randomValue",
    "key3": "value3"
  }
}

import com.azure.resourcemanager.streamanalytics.fluent.models.InputInner;
import com.azure.resourcemanager.streamanalytics.fluent.models.OutputInner;
import com.azure.resourcemanager.streamanalytics.fluent.models.TransformationInner;
import com.azure.resourcemanager.streamanalytics.models.AzureSqlDatabaseOutputDataSource;
import com.azure.resourcemanager.streamanalytics.models.BlobStreamInputDataSource;
import com.azure.resourcemanager.streamanalytics.models.CompatibilityLevel;
import com.azure.resourcemanager.streamanalytics.models.Encoding;
import com.azure.resourcemanager.streamanalytics.models.EventsOutOfOrderPolicy;
import com.azure.resourcemanager.streamanalytics.models.JsonSerialization;
import com.azure.resourcemanager.streamanalytics.models.OutputErrorPolicy;
import com.azure.resourcemanager.streamanalytics.models.Sku;
import com.azure.resourcemanager.streamanalytics.models.SkuName;
import com.azure.resourcemanager.streamanalytics.models.StorageAccount;
import com.azure.resourcemanager.streamanalytics.models.StreamInputProperties;
import java.util.Arrays;
import java.util.HashMap;
import java.util.Map;

/** Samples for StreamingJobs CreateOrReplace. */
public final class Main {
    /*
     * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/StreamingJob_Create_CompleteJob.json
     */
    /**
     * Sample code: Create a complete streaming job (a streaming job with a transformation, at least 1 input and at
     * least 1 output).
     *
     * @param manager Entry point to StreamAnalyticsManager.
     */
    public static void createACompleteStreamingJobAStreamingJobWithATransformationAtLeast1InputAndAtLeast1Output(
        com.azure.resourcemanager.streamanalytics.StreamAnalyticsManager manager) {
        manager
            .streamingJobs()
            .define("sj7804")
            .withRegion("West US")
            .withExistingResourceGroup("sjrg3276")
            .withTags(mapOf("key1", "value1", "key3", "value3", "randomKey", "randomValue"))
            .withSku(new Sku().withName(SkuName.STANDARD))
            .withEventsOutOfOrderPolicy(EventsOutOfOrderPolicy.DROP)
            .withOutputErrorPolicy(OutputErrorPolicy.DROP)
            .withEventsOutOfOrderMaxDelayInSeconds(0)
            .withEventsLateArrivalMaxDelayInSeconds(5)
            .withDataLocale("en-US")
            .withCompatibilityLevel(CompatibilityLevel.ONE_ZERO)
            .withInputs(
                Arrays
                    .asList(
                        new InputInner()
                            .withProperties(
                                new StreamInputProperties()
                                    .withSerialization(new JsonSerialization().withEncoding(Encoding.UTF8))
                                    .withDatasource(
                                        new BlobStreamInputDataSource()
                                            .withStorageAccounts(
                                                Arrays
                                                    .asList(
                                                        new StorageAccount()
                                                            .withAccountName("yourAccountName")
                                                            .withAccountKey("yourAccountKey==")))
                                            .withContainer("containerName")
                                            .withPathPattern("")))
                            .withName("inputtest")))
            .withTransformation(
                new TransformationInner()
                    .withName("transformationtest")
                    .withStreamingUnits(1)
                    .withQuery("Select Id, Name from inputtest"))
            .withOutputs(
                Arrays
                    .asList(
                        new OutputInner()
                            .withName("outputtest")
                            .withDatasource(new AzureSqlDatabaseOutputDataSource())))
            .withFunctions(Arrays.asList())
            .create();
    }

    @SuppressWarnings("unchecked")
    private static <T> Map<String, T> mapOf(Object... inputs) {
        Map<String, T> map = new HashMap<>();
        for (int i = 0; i < inputs.length; i += 2) {
            String key = (String) inputs[i];
            T value = (T) inputs[i + 1];
            map.put(key, value);
        }
        return map;
    }
}

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/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_Create_CompleteJob.json
func ExampleStreamingJobsClient_BeginCreateOrReplace_createACompleteStreamingJobAStreamingJobWithATransformationAtLeast1InputAndAtLeast1Output() {
	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)
	}
	poller, err := clientFactory.NewStreamingJobsClient().BeginCreateOrReplace(ctx, "sjrg3276", "sj7804", armstreamanalytics.StreamingJob{
		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),
			DataLocale:                         to.Ptr("en-US"),
			EventsLateArrivalMaxDelayInSeconds: to.Ptr[int32](5),
			EventsOutOfOrderMaxDelayInSeconds:  to.Ptr[int32](0),
			EventsOutOfOrderPolicy:             to.Ptr(armstreamanalytics.EventsOutOfOrderPolicyDrop),
			Functions:                          []*armstreamanalytics.Function{},
			Inputs: []*armstreamanalytics.Input{
				{
					Name: to.Ptr("inputtest"),
					Properties: &armstreamanalytics.StreamInputProperties{
						Type: to.Ptr("Stream"),
						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{
									{
										AccountKey:  to.Ptr("yourAccountKey=="),
										AccountName: to.Ptr("yourAccountName"),
									}},
							},
						},
					},
				}},
			OutputErrorPolicy: to.Ptr(armstreamanalytics.OutputErrorPolicyDrop),
			Outputs: []*armstreamanalytics.Output{
				{
					Name: to.Ptr("outputtest"),
					Properties: &armstreamanalytics.OutputProperties{
						Datasource: &armstreamanalytics.AzureSQLDatabaseOutputDataSource{
							Type: to.Ptr("Microsoft.Sql/Server/Database"),
							Properties: &armstreamanalytics.AzureSQLDatabaseOutputDataSourceProperties{
								Database: to.Ptr("databaseName"),
								Password: to.Ptr("userPassword"),
								Server:   to.Ptr("serverName"),
								Table:    to.Ptr("tableName"),
								User:     to.Ptr("<user>"),
							},
						},
					},
				}},
			SKU: &armstreamanalytics.SKU{
				Name: to.Ptr(armstreamanalytics.SKUNameStandard),
			},
			Transformation: &armstreamanalytics.Transformation{
				Name: to.Ptr("transformationtest"),
				Properties: &armstreamanalytics.TransformationProperties{
					Query:          to.Ptr("Select Id, Name from inputtest"),
					StreamingUnits: to.Ptr[int32](1),
				},
			},
		},
	}, &armstreamanalytics.StreamingJobsClientBeginCreateOrReplaceOptions{IfMatch: nil,
		IfNoneMatch: nil,
	})
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
	res, err := poller.PollUntilDone(ctx, nil)
	if err != nil {
		log.Fatalf("failed to pull the result: %v", err)
	}
	// You could use response here. We use blank identifier for just demo purposes.
	_ = res
	// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
	// res.StreamingJob = 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"),
	// 		EventsLateArrivalMaxDelayInSeconds: to.Ptr[int32](5),
	// 		EventsOutOfOrderMaxDelayInSeconds: to.Ptr[int32](0),
	// 		EventsOutOfOrderPolicy: to.Ptr(armstreamanalytics.EventsOutOfOrderPolicyDrop),
	// 		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.OutputErrorPolicyDrop),
	// 		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),
	// 			},
	// 		},
	// 	},
	// }
}

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 Creates a streaming job or replaces an already existing streaming job.
 *
 * @summary Creates a streaming job or replaces an already existing streaming job.
 * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/StreamingJob_Create_CompleteJob.json
 */
async function createACompleteStreamingJobAStreamingJobWithATransformationAtLeast1InputAndAtLeast1Output() {
  const subscriptionId = "56b5e0a9-b645-407d-99b0-c64f86013e3d";
  const resourceGroupName = "sjrg3276";
  const jobName = "sj7804";
  const streamingJob = {
    compatibilityLevel: "1.0",
    dataLocale: "en-US",
    eventsLateArrivalMaxDelayInSeconds: 5,
    eventsOutOfOrderMaxDelayInSeconds: 0,
    eventsOutOfOrderPolicy: "Drop",
    functions: [],
    inputs: [
      {
        name: "inputtest",
        properties: {
          type: "Stream",
          datasource: {
            type: "Microsoft.Storage/Blob",
            container: "containerName",
            pathPattern: "",
            storageAccounts: [{ accountKey: "yourAccountKey==", accountName: "yourAccountName" }],
          },
          serialization: { type: "Json", encoding: "UTF8" },
        },
      },
    ],
    location: "West US",
    outputErrorPolicy: "Drop",
    outputs: [
      {
        name: "outputtest",
        datasource: {
          type: "Microsoft.Sql/Server/Database",
          database: "databaseName",
          password: "userPassword",
          server: "serverName",
          table: "tableName",
          user: "<user>",
        },
      },
    ],
    sku: { name: "Standard" },
    tags: { key1: "value1", key3: "value3", randomKey: "randomValue" },
    transformation: {
      name: "transformationtest",
      query: "Select Id, Name from inputtest",
      streamingUnits: 1,
    },
  };
  const credential = new DefaultAzureCredential();
  const client = new StreamAnalyticsManagementClient(credential, subscriptionId);
  const result = await client.streamingJobs.beginCreateOrReplaceAndWait(
    resourceGroupName,
    jobName,
    streamingJob
  );
  console.log(result);
}

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

샘플 응답

상태 코드:: 201

ETag: 87551cc5-1290-4d08-afcd-cdaa92e5ade0

{
  "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": "Drop",
    "outputErrorPolicy": "Drop",
    "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"
        }
      }
    ]
  }
}

상태 코드:: 200

ETag: 87551cc5-1290-4d08-afcd-cdaa92e5ade0

{
  "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": "Drop",
    "outputErrorPolicy": "Drop",
    "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"
        }
      }
    ]
  }
}

Create a streaming job shell (a streaming job with no inputs, outputs, transformation, or functions)

샘플 요청

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

{
  "properties": {
    "sku": {
      "name": "Standard"
    },
    "eventsOutOfOrderPolicy": "Drop",
    "outputErrorPolicy": "Drop",
    "eventsOutOfOrderMaxDelayInSeconds": 5,
    "eventsLateArrivalMaxDelayInSeconds": 16,
    "dataLocale": "en-US",
    "compatibilityLevel": "1.0",
    "inputs": [],
    "outputs": [],
    "functions": []
  },
  "location": "West US",
  "tags": {
    "key1": "value1",
    "randomKey": "randomValue",
    "key3": "value3"
  }
}

import com.azure.resourcemanager.streamanalytics.models.CompatibilityLevel;
import com.azure.resourcemanager.streamanalytics.models.EventsOutOfOrderPolicy;
import com.azure.resourcemanager.streamanalytics.models.OutputErrorPolicy;
import com.azure.resourcemanager.streamanalytics.models.Sku;
import com.azure.resourcemanager.streamanalytics.models.SkuName;
import java.util.Arrays;
import java.util.HashMap;
import java.util.Map;

/** Samples for StreamingJobs CreateOrReplace. */
public final class Main {
    /*
     * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/StreamingJob_Create_JobShell.json
     */
    /**
     * Sample code: Create a streaming job shell (a streaming job with no inputs, outputs, transformation, or
     * functions).
     *
     * @param manager Entry point to StreamAnalyticsManager.
     */
    public static void createAStreamingJobShellAStreamingJobWithNoInputsOutputsTransformationOrFunctions(
        com.azure.resourcemanager.streamanalytics.StreamAnalyticsManager manager) {
        manager
            .streamingJobs()
            .define("sj59")
            .withRegion("West US")
            .withExistingResourceGroup("sjrg6936")
            .withTags(mapOf("key1", "value1", "key3", "value3", "randomKey", "randomValue"))
            .withSku(new Sku().withName(SkuName.STANDARD))
            .withEventsOutOfOrderPolicy(EventsOutOfOrderPolicy.DROP)
            .withOutputErrorPolicy(OutputErrorPolicy.DROP)
            .withEventsOutOfOrderMaxDelayInSeconds(5)
            .withEventsLateArrivalMaxDelayInSeconds(16)
            .withDataLocale("en-US")
            .withCompatibilityLevel(CompatibilityLevel.ONE_ZERO)
            .withInputs(Arrays.asList())
            .withOutputs(Arrays.asList())
            .withFunctions(Arrays.asList())
            .create();
    }

    @SuppressWarnings("unchecked")
    private static <T> Map<String, T> mapOf(Object... inputs) {
        Map<String, T> map = new HashMap<>();
        for (int i = 0; i < inputs.length; i += 2) {
            String key = (String) inputs[i];
            T value = (T) inputs[i + 1];
            map.put(key, value);
        }
        return map;
    }
}

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/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_Create_JobShell.json
func ExampleStreamingJobsClient_BeginCreateOrReplace_createAStreamingJobShellAStreamingJobWithNoInputsOutputsTransformationOrFunctions() {
	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)
	}
	poller, err := clientFactory.NewStreamingJobsClient().BeginCreateOrReplace(ctx, "sjrg6936", "sj59", armstreamanalytics.StreamingJob{
		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),
			DataLocale:                         to.Ptr("en-US"),
			EventsLateArrivalMaxDelayInSeconds: to.Ptr[int32](16),
			EventsOutOfOrderMaxDelayInSeconds:  to.Ptr[int32](5),
			EventsOutOfOrderPolicy:             to.Ptr(armstreamanalytics.EventsOutOfOrderPolicyDrop),
			Functions:                          []*armstreamanalytics.Function{},
			Inputs:                             []*armstreamanalytics.Input{},
			OutputErrorPolicy:                  to.Ptr(armstreamanalytics.OutputErrorPolicyDrop),
			Outputs:                            []*armstreamanalytics.Output{},
			SKU: &armstreamanalytics.SKU{
				Name: to.Ptr(armstreamanalytics.SKUNameStandard),
			},
		},
	}, &armstreamanalytics.StreamingJobsClientBeginCreateOrReplaceOptions{IfMatch: nil,
		IfNoneMatch: nil,
	})
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
	res, err := poller.PollUntilDone(ctx, nil)
	if err != nil {
		log.Fatalf("failed to pull the result: %v", err)
	}
	// You could use response here. We use blank identifier for just demo purposes.
	_ = res
	// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
	// res.StreamingJob = 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"),
	// 		EventsLateArrivalMaxDelayInSeconds: to.Ptr[int32](16),
	// 		EventsOutOfOrderMaxDelayInSeconds: to.Ptr[int32](5),
	// 		EventsOutOfOrderPolicy: to.Ptr(armstreamanalytics.EventsOutOfOrderPolicyDrop),
	// 		Functions: []*armstreamanalytics.Function{
	// 		},
	// 		Inputs: []*armstreamanalytics.Input{
	// 		},
	// 		JobID: to.Ptr("d53ecc3c-fcb0-485d-9caf-25e20fcb2061"),
	// 		JobState: to.Ptr("Created"),
	// 		OutputErrorPolicy: to.Ptr(armstreamanalytics.OutputErrorPolicyDrop),
	// 		Outputs: []*armstreamanalytics.Output{
	// 		},
	// 		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

const { StreamAnalyticsManagementClient } = require("@azure/arm-streamanalytics");
const { DefaultAzureCredential } = require("@azure/identity");

/**
 * This sample demonstrates how to Creates a streaming job or replaces an already existing streaming job.
 *
 * @summary Creates a streaming job or replaces an already existing streaming job.
 * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/StreamingJob_Create_JobShell.json
 */
async function createAStreamingJobShellAStreamingJobWithNoInputsOutputsTransformationOrFunctions() {
  const subscriptionId = "56b5e0a9-b645-407d-99b0-c64f86013e3d";
  const resourceGroupName = "sjrg6936";
  const jobName = "sj59";
  const streamingJob = {
    compatibilityLevel: "1.0",
    dataLocale: "en-US",
    eventsLateArrivalMaxDelayInSeconds: 16,
    eventsOutOfOrderMaxDelayInSeconds: 5,
    eventsOutOfOrderPolicy: "Drop",
    functions: [],
    inputs: [],
    location: "West US",
    outputErrorPolicy: "Drop",
    outputs: [],
    sku: { name: "Standard" },
    tags: { key1: "value1", key3: "value3", randomKey: "randomValue" },
  };
  const credential = new DefaultAzureCredential();
  const client = new StreamAnalyticsManagementClient(credential, subscriptionId);
  const result = await client.streamingJobs.beginCreateOrReplaceAndWait(
    resourceGroupName,
    jobName,
    streamingJob
  );
  console.log(result);
}

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

샘플 응답

상태 코드:: 201

ETag: 3e6872bc-c9d0-45b6-91b6-da66f1773056

{
  "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": 5,
    "eventsLateArrivalMaxDelayInSeconds": 16,
    "dataLocale": "en-US",
    "createdDate": "2017-05-11T04:37:04.697Z",
    "compatibilityLevel": "1.0",
    "inputs": [],
    "functions": [],
    "outputs": []
  }
}

상태 코드:: 200

ETag: 3e6872bc-c9d0-45b6-91b6-da66f1773056

{
  "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": 5,
    "eventsLateArrivalMaxDelayInSeconds": 16,
    "dataLocale": "en-US",
    "createdDate": "2017-05-11T04:37:04.697Z",
    "compatibilityLevel": "1.0",
    "inputs": [],
    "functions": [],
    "outputs": []
  }
}

정의

Name	Description
AggregateFunctionProperties	집계 함수와 연결된 속성입니다.
AuthenticationMode	인증 모드. 유효한 모드는 , `Msi` 및 'UserToken'입니다`ConnectionString`.
AvroSerialization	입력의 데이터를 직렬화하는 방법 또는 Avro 형식으로 출력에 쓸 때 데이터가 직렬화되는 방법을 설명합니다.
AzureDataLakeStoreOutputDataSource	Azure Data Lake Store 출력 데이터 원본에 대해 설명합니다.
AzureFunctionOutputDataSource	AzureFunctionOutputDataSource의 메타데이터를 정의합니다.
AzureMachineLearningWebServiceFunctionBinding	Azure Machine Learning 웹 서비스에 대한 바인딩입니다.
AzureMachineLearningWebServiceInputColumn	Azure Machine Learning 웹 서비스 엔드포인트에 대한 입력 열을 설명합니다.
AzureMachineLearningWebServiceInputs	Azure Machine Learning 웹 서비스 엔드포인트에 대한 입력입니다.
AzureMachineLearningWebServiceOutputColumn	Azure Machine Learning 웹 서비스 엔드포인트에 대한 출력 열을 설명합니다.
AzureSqlDatabaseOutputDataSource	Azure SQL 데이터베이스 출력 데이터 원본에 대해 설명합니다.
AzureSqlReferenceInputDataSource	Azure SQL 데이터베이스 참조 입력 데이터 원본에 대해 설명합니다.
AzureSynapseOutputDataSource	Azure Synapse 출력 데이터 원본에 대해 설명합니다.
AzureTableOutputDataSource	Azure Table 출력 데이터 원본에 대해 설명합니다.
BlobOutputDataSource	Blob 출력 데이터 원본에 대해 설명합니다.
BlobReferenceInputDataSource	참조 데이터가 포함된 Blob 입력 데이터 원본에 대해 설명합니다.
BlobStreamInputDataSource	스트림 데이터를 포함하는 Blob 입력 데이터 원본에 대해 설명합니다.
ClusterInfo	Stream Analytics 클러스터와 연결된 속성입니다.
CompatibilityLevel	스트리밍 작업의 특정 런타임 동작을 제어합니다.
Compression	입력 데이터가 압축되는 방법을 설명합니다.
CompressionType	입력에서 사용하는 압축 유형을 나타냅니다. PUT(CreateOrReplace) 요청에 필요합니다.
ContentStoragePolicy	유효한 값은 JobStorageAccount 및 SystemAccount입니다. JobStorageAccount로 설정하면 사용자가 jobStorageAccount 속성도 지정해야 합니다. .
CsvSerialization	입력의 데이터를 직렬화하는 방법 또는 CSV 형식으로 출력에 쓸 때 데이터가 serialize되는 방법을 설명합니다.
DiagnosticCondition	리소스 또는 전체 작업에 적용할 수 있는 조건으로 고객의 주의를 끌 수 있습니다.
Diagnostics	고객의 주의를 끄는 입력, 출력 또는 전체 작업에 적용되는 조건에 대해 설명합니다.
DocumentDbOutputDataSource	DocumentDB 출력 데이터 원본에 대해 설명합니다.
Encoding	입력의 경우 들어오는 데이터의 인코딩 및 출력의 경우 나가는 데이터의 인코딩을 지정합니다.
Error	일반적인 오류 표현입니다.
EventHubOutputDataSource	이벤트 허브 출력 데이터 원본에 대해 설명합니다.
EventHubStreamInputDataSource	스트림 데이터를 포함하는 이벤트 허브 입력 데이터 원본에 대해 설명합니다.
EventHubV2OutputDataSource	이벤트 허브 출력 데이터 원본에 대해 설명합니다.
EventHubV2StreamInputDataSource	스트림 데이터를 포함하는 이벤트 허브 입력 데이터 원본에 대해 설명합니다.
EventSerializationType	입력 또는 출력에서 사용하는 serialization 유형을 나타냅니다. PUT(CreateOrReplace) 요청에 필요합니다.
EventsOutOfOrderPolicy	입력 이벤트 스트림에 잘못된 순서로 도착하는 이벤트에 적용할 정책을 나타냅니다.
FileReferenceInputDataSource	참조 데이터가 포함된 파일 입력 데이터 원본에 대해 설명합니다.
Function	명명된 함수와 연결된 모든 정보를 포함하는 함수 개체입니다. 모든 함수는 스트리밍 작업 아래에 포함됩니다.
FunctionInput	함수의 한 입력 매개 변수에 대해 설명합니다.
FunctionOutput	함수의 출력을 설명합니다.
GatewayMessageBusOutputDataSource	게이트웨이 Message Bus 출력 데이터 원본에 대해 설명합니다.
GatewayMessageBusStreamInputDataSource	스트림 데이터를 포함하는 Blob 입력 데이터 원본에 대해 설명합니다.
Identity	ID를 확인하는 방법을 설명합니다.
Input	명명된 입력과 연결된 모든 정보를 포함하는 입력 개체입니다. 모든 입력은 스트리밍 작업 아래에 포함됩니다.
IoTHubStreamInputDataSource	스트림 데이터를 포함하는 IoT Hub 입력 데이터 원본에 대해 설명합니다.
JavaScriptFunctionBinding	JavaScript 함수에 대한 바인딩입니다.
JobStorageAccount	MSI와 Azure Storage 계정과 연결된 속성
JobType	작업의 형식을 설명합니다. 유효한 모드는 및 'Edge'입니다 `Cloud` .
JsonOutputSerializationFormat	출력이 작성될 JSON의 형식을 지정합니다. 현재 지원되는 값은 각 JSON 개체를 새 줄로 구분하고 출력이 JSON 개체의 배열로 형식이 지정됨을 나타내는 'array'를 사용하여 출력의 형식을 지정함을 나타내는 'lineSeparated'입니다.
JsonSerialization	입력의 데이터를 직렬화하는 방법 또는 JSON 형식으로 출력에 쓸 때 데이터가 serialize되는 방법을 설명합니다.
Output	명명된 출력과 연결된 모든 정보를 포함하는 출력 개체입니다. 모든 출력은 스트리밍 작업 아래에 포함됩니다.
OutputErrorPolicy	형식이 잘못되었기 때문에 출력에 도착하고 외부 스토리지에 쓸 수 없는 이벤트에 적용할 정책을 나타냅니다(누락된 열 값, 잘못된 형식 또는 크기의 열 값).
OutputStartMode	값은 JobStartTime, CustomTime 또는 LastOutputEventTime일 수 있습니다. 이 값은 작업이 시작될 때마다 출력 이벤트 스트림의 시작점이 시작될지, outputStartTime 속성을 통해 지정된 사용자 지정 타임스탬프에서 시작해야 하는지 또는 마지막 이벤트 출력 시간부터 시작해야 하는지를 나타냅니다.
ParquetSerialization	입력의 데이터를 직렬화하는 방법 또는 Parquet 형식으로 출력에 쓸 때 데이터가 serialize되는 방법을 설명합니다.
PowerBIOutputDataSource	Power BI 출력 데이터 원본에 대해 설명합니다.
ReferenceInputProperties	참조 데이터를 포함하는 입력과 연결된 속성입니다.
RefreshType	데이터 새로 고침 옵션의 형식을 나타냅니다.
ScalarFunctionProperties	스칼라 함수와 연결된 속성입니다.
ServiceBusQueueOutputDataSource	Service Bus 큐 출력 데이터 원본에 대해 설명합니다.
ServiceBusTopicOutputDataSource	Service Bus 토픽 출력 데이터 원본에 대해 설명합니다.
Sku	SKU와 연결된 속성입니다.
SkuName	SKU의 이름입니다. PUT(CreateOrReplace) 요청에 필요합니다.
StorageAccount	Azure Storage 계정과 연결된 속성
StreamingJob	명명된 스트리밍 작업과 연결된 모든 정보를 포함하는 스트리밍 작업 개체입니다.
StreamInputProperties	스트림 데이터를 포함하는 입력과 연결된 속성입니다.
Transformation	명명된 변환과 관련된 모든 정보를 포함하는 변환 개체입니다. 모든 변환은 스트리밍 작업 아래에 포함됩니다.

AggregateFunctionProperties

집계 함수와 연결된 속성입니다.

Name	형식	Description
etag	string	함수의 현재 엔터티 태그입니다. 불투명 문자열입니다. 이를 사용하여 요청 간에 리소스가 변경되었는지 여부를 검색할 수 있습니다. 낙관적 동시성을 위한 쓰기 작업에 If-Match 또는 If-None-Match 헤더에서 사용할 수도 있습니다.
properties.binding	FunctionBinding: AzureMachineLearningWebServiceFunctionBinding JavaScriptFunctionBinding	함수의 물리적 바인딩입니다. 예를 들어 Azure Machine Learning 웹 서비스의 경우 엔드포인트에 대해 설명합니다.
properties.inputs	FunctionInput[]	함수의 한 입력 매개 변수에 대해 설명합니다.
properties.output	FunctionOutput	함수의 출력을 설명합니다.
type	string: Aggregate	함수의 형식을 나타냅니다.

AuthenticationMode

인증 모드. 유효한 모드는 , Msi 및 'UserToken'입니다ConnectionString.

Name	형식	Description
ConnectionString	string
Msi	string
UserToken	string

AvroSerialization

입력의 데이터를 직렬화하는 방법 또는 Avro 형식으로 출력에 쓸 때 데이터가 직렬화되는 방법을 설명합니다.

Name	형식	Description
type	string: Avro	입력 또는 출력에서 사용하는 serialization 유형을 나타냅니다. PUT(CreateOrReplace) 요청에 필요합니다.

AzureDataLakeStoreOutputDataSource

Azure Data Lake Store 출력 데이터 원본에 대해 설명합니다.

Name	형식	Default value	Description
properties.accountName	string		Azure Data Lake Store 계정의 이름입니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.authenticationMode	AuthenticationMode	ConnectionString	인증 모드.
properties.dateFormat	string		날짜 형식입니다. filePathPrefix에 {date}가 표시되는 위치마다 이 속성의 값이 대신 날짜 형식으로 사용됩니다.
properties.filePathPrefix	string		출력을 쓸 파일의 위치입니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.refreshToken	string		데이터 원본으로 인증하는 데 사용할 수 있는 유효한 액세스 토큰을 가져오는 데 사용할 수 있는 새로 고침 토큰입니다. 유효한 새로 고침 토큰은 현재 Azure Portal을 통해서만 얻을 수 있습니다. 데이터 원본을 만든 다음 Azure Portal로 이동하여 이 속성을 유효한 새로 고침 토큰으로 업데이트할 데이터 원본을 인증할 때 더미 문자열 값을 여기에 배치하는 것이 좋습니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.tenantId	string		새로 고침 토큰을 가져오는 데 사용되는 사용자의 테넌트 ID입니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.timeFormat	string		시간 형식입니다. {time}이 filePathPrefix에 나타날 때마다 이 속성의 값은 대신 시간 형식으로 사용됩니다.
properties.tokenUserDisplayName	string		새로 고침 토큰을 가져오는 데 사용된 사용자의 사용자 표시 이름입니다. 새로 고침 토큰을 가져오는 데 사용된 사용자를 기억하려면 이 속성을 사용합니다.
properties.tokenUserPrincipalName	string		새로 고침 토큰을 가져오는 데 사용된 사용자의 UPN(사용자 계정 이름)입니다. 새로 고침 토큰을 가져오는 데 사용된 사용자를 기억하려면 이 속성을 사용합니다.
type	string: Microsoft.DataLake/Accounts		기록될 데이터 원본 출력의 형식을 나타냅니다. PUT(CreateOrReplace) 요청에 필요합니다.

AzureFunctionOutputDataSource

AzureFunctionOutputDataSource의 메타데이터를 정의합니다.

Name	형식	Description
properties.apiKey	string	다른 구독에서 Azure 함수를 사용하려는 경우 이 작업은 함수에 액세스하기 위한 키를 제공하여 수행할 수 있습니다.
properties.functionAppName	string	Azure Functions 앱의 이름입니다.
properties.functionName	string	Azure Functions 앱의 함수 이름입니다.
properties.maxBatchCount	number	Azure Functions로 보내는 각 일괄 처리의 최대 이벤트 수를 지정할 수 있는 속성입니다. 기본값은 100입니다.
properties.maxBatchSize	number	Azure 함수로 보내는 각 출력 일괄 처리의 최대 크기를 설정할 수 있는 속성입니다. 입력 단위는 바이트입니다. 이 값은 기본적으로 262,144바이트(256KB)입니다.
type	string: Microsoft.AzureFunction	기록될 데이터 원본 출력의 형식을 나타냅니다. PUT(CreateOrReplace) 요청에 필요합니다.

AzureMachineLearningWebServiceFunctionBinding

Azure Machine Learning 웹 서비스에 대한 바인딩입니다.

Name	형식	Description
properties.apiKey	string	Request-Response 엔드포인트로 인증하는 데 사용되는 API 키입니다.
properties.batchSize	integer	모든 Azure ML RRS 실행 요청에 대한 최대 행 수를 설명하는 1에서 10000 사이의 숫자입니다. 기본값은 1000입니다.
properties.endpoint	string	Request-Response Azure Machine Learning 웹 서비스의 엔드포인트를 실행합니다. 자세한 내용은 여기를 참조하세요. https://docs.microsoft.com/en-us/azure/machine-learning/machine-learning-consume-web-services#request-response-service-rrs
properties.inputs	AzureMachineLearningWebServiceInputs	Azure Machine Learning 웹 서비스 엔드포인트에 대한 입력입니다.
properties.outputs	AzureMachineLearningWebServiceOutputColumn[]	Azure Machine Learning 웹 서비스 엔드포인트 실행의 출력 목록입니다.
type	string: Microsoft.MachineLearning/WebService	함수 바인딩 형식을 나타냅니다.

AzureMachineLearningWebServiceInputColumn

Azure Machine Learning 웹 서비스 엔드포인트에 대한 입력 열을 설명합니다.

Name	형식	Description
dataType	string	입력 열의 (Azure Machine Learning 지원) 데이터 형식입니다. 유효한 Azure Machine Learning 데이터 형식 목록은 에 https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx 설명되어 있습니다.
mapTo	integer	이 입력이 매핑하는 함수 매개 변수의 인덱스(0부터 시작)입니다.
name	string	입력 열의 이름입니다.

AzureMachineLearningWebServiceInputs

Azure Machine Learning 웹 서비스 엔드포인트에 대한 입력입니다.

Name	형식	Description
columnNames	AzureMachineLearningWebServiceInputColumn[]	Azure Machine Learning 웹 서비스 엔드포인트에 대한 입력 열 목록입니다.
name	string	입력의 이름입니다. 엔드포인트를 작성하는 동안 제공되는 이름입니다.

AzureMachineLearningWebServiceOutputColumn

Azure Machine Learning 웹 서비스 엔드포인트에 대한 출력 열을 설명합니다.

Name	형식	Description
dataType	string	출력 열의 (Azure Machine Learning 지원) 데이터 형식입니다. 유효한 Azure Machine Learning 데이터 형식 목록은 에 https://msdn.microsoft.com/en-us/library/azure/dn905923.aspx 설명되어 있습니다.
name	string	출력 열의 이름입니다.

AzureSqlDatabaseOutputDataSource

Azure SQL 데이터베이스 출력 데이터 원본에 대해 설명합니다.

Name	형식	Default value	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	인증 모드.
properties.database	string		Azure SQL 데이터베이스의 이름입니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.maxBatchCount	number		Sql 데이터베이스에 쓰기에 대한 최대 일괄 처리 수이며 기본값은 10,000입니다. PUT 요청에서 선택 사항입니다.
properties.maxWriterCount	number		현재 최대 기록기 수는 1(단일 기록기) 및 0(쿼리 파티션 기준)만 사용할 수 있습니다. PUT 요청에서 선택 사항입니다.
properties.password	string		Azure SQL 데이터베이스에 연결하는 데 사용할 암호입니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.server	string		Azure SQL 데이터베이스를 포함하는 SQL 서버의 이름입니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.table	string		Azure SQL 데이터베이스에 있는 테이블의 이름입니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.user	string		Azure SQL 데이터베이스에 연결하는 데 사용할 사용자 이름입니다. PUT(CreateOrReplace) 요청에 필요합니다.
type	string: Microsoft.Sql/Server/Database		기록될 데이터 원본 출력의 형식을 나타냅니다. PUT(CreateOrReplace) 요청에 필요합니다.

AzureSqlReferenceInputDataSource

Azure SQL 데이터베이스 참조 입력 데이터 원본에 대해 설명합니다.

Name	형식	Description
properties.database	string	이 요소는 datasource 요소와 연결되며, 출력을 쓸 데이터베이스의 이름입니다.
properties.deltaSnapshotQuery	string	이 요소는 datasource 요소와 연결되며, 이 쿼리는 SQL 데이터베이스에서 증분 변경 내용을 가져오는 데 사용됩니다. 이 옵션을 사용하려면 Azure SQL Database에서 임시 테이블을 사용하는 것이 좋습니다.
properties.fullSnapshotQuery	string	이 요소는 datasource 요소와 연결되며, 이 쿼리는 sql Database에서 데이터를 가져오는 데 사용됩니다.
properties.password	string	이 요소는 datasource 요소와 연결되며, SQL 데이터베이스 인스턴스에 연결하는 데 사용할 암호입니다.
properties.refreshRate	string	이 요소는 datasource 요소와 연결되며, 이는 데이터베이스에서 데이터를 가져오는 빈도를 나타냅니다. DateTime 형식입니다.
properties.refreshType	RefreshType	데이터 새로 고침 옵션의 형식을 나타냅니다.
properties.server	string	이 요소는 datasource 요소와 연결되며, 기록할 데이터베이스가 포함된 서버의 이름입니다.
properties.table	string	이 요소는 datasource 요소와 연결되며, Azure SQL 데이터베이스에 있는 테이블의 이름입니다.
properties.user	string	이 요소는 datasource 요소와 연결되며, SQL 데이터베이스 인스턴스에 연결하는 데 사용할 사용자 이름입니다.
type	string: Microsoft.Sql/Server/Database	참조 데이터를 포함하는 입력 데이터 원본의 형식을 나타냅니다. PUT(CreateOrReplace) 요청에 필요합니다.

AzureSynapseOutputDataSource

Azure Synapse 출력 데이터 원본에 대해 설명합니다.

Name	형식	Description
properties.database	string	Azure SQL 데이터베이스의 이름입니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.password	string	Azure SQL 데이터베이스에 연결하는 데 사용할 암호입니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.server	string	Azure SQL 데이터베이스를 포함하는 SQL 서버의 이름입니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.table	string	Azure SQL 데이터베이스에 있는 테이블의 이름입니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.user	string	Azure SQL 데이터베이스에 연결하는 데 사용할 사용자 이름입니다. PUT(CreateOrReplace) 요청에 필요합니다.
type	string: Microsoft.Sql/Server/DataWarehouse	기록될 데이터 원본 출력의 형식을 나타냅니다. PUT(CreateOrReplace) 요청에 필요합니다.

AzureTableOutputDataSource

Azure Table 출력 데이터 원본에 대해 설명합니다.

Name	형식	Description
properties.accountKey	string	Azure Storage 계정의 계정 키입니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.accountName	string	Azure Storage 계정의 이름입니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.batchSize	integer	Azure Table에 한 번에 쓸 행 수입니다.
properties.columnsToRemove	string[]	지정한 경우 배열의 각 항목은 출력 이벤트 엔터티에서 제거할 열(있는 경우)의 이름입니다.
properties.partitionKey	string	이 요소는 쿼리의 SELECT 문에서 Azure Table의 파티션 키로 사용할 열의 이름을 나타냅니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.rowKey	string	이 요소는 Azure Table의 행 키로 사용할 쿼리의 SELECT 문에 있는 열의 이름을 나타냅니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.table	string	Azure 테이블의 이름입니다. PUT(CreateOrReplace) 요청에 필요합니다.
type	string: Microsoft.Storage/Table	기록될 데이터 원본 출력의 형식을 나타냅니다. PUT(CreateOrReplace) 요청에 필요합니다.

BlobOutputDataSource

Blob 출력 데이터 원본에 대해 설명합니다.

Name	형식	Default value	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	인증 모드.
properties.blobPathPrefix	string		Blob 경로 접두사입니다.
properties.container	string		연결된 Storage 계정 내의 컨테이너 이름입니다. 이 컨테이너에는 읽거나 쓸 Blob이 포함되어 있습니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.dateFormat	string		날짜 형식입니다. pathPattern에 {date}가 표시되면 이 속성의 값이 대신 날짜 형식으로 사용됩니다.
properties.pathPattern	string		Blob 경로 패턴입니다. 정규식이 아닙니다. Blob 이름이 작업에 대한 입력 또는 출력으로 포함되어야 하는지 여부를 결정하기 위해 일치하는 패턴을 나타냅니다. 자세한 설명 및 예제는 또는 https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output 을 참조하세요https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input.
properties.storageAccounts	StorageAccount[]		하나 이상의 Azure Storage 계정 목록입니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.timeFormat	string		시간 형식입니다. {time}이 pathPattern에 표시되면 이 속성의 값이 시간 형식으로 대신 사용됩니다.
type	string: Microsoft.Storage/Blob		기록될 데이터 원본 출력의 형식을 나타냅니다. PUT(CreateOrReplace) 요청에 필요합니다.

BlobReferenceInputDataSource

참조 데이터가 포함된 Blob 입력 데이터 원본에 대해 설명합니다.

Name	형식	Default value	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	인증 모드.
properties.container	string		연결된 Storage 계정 내의 컨테이너 이름입니다. 이 컨테이너에는 읽거나 쓸 Blob이 포함됩니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.dateFormat	string		날짜 형식입니다. pathPattern에 {date}가 표시되면 이 속성의 값이 대신 날짜 형식으로 사용됩니다.
properties.pathPattern	string		Blob 경로 패턴입니다. 정규식이 아닙니다. Blob 이름이 일치하여 작업에 대한 입력 또는 출력으로 포함해야 하는지 여부를 결정하는 패턴을 나타냅니다. 자세한 설명 및 예제는 또는 https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output 를 참조하세요https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input.
properties.storageAccounts	StorageAccount[]		하나 이상의 Azure Storage 계정 목록입니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.timeFormat	string		시간 형식입니다. {time}이 pathPattern에 표시되면 이 속성의 값이 시간 형식으로 대신 사용됩니다.
type	string: Microsoft.Storage/Blob		참조 데이터를 포함하는 입력 데이터 원본의 형식을 나타냅니다. PUT(CreateOrReplace) 요청에 필요합니다.

BlobStreamInputDataSource

스트림 데이터를 포함하는 Blob 입력 데이터 원본에 대해 설명합니다.

Name	형식	Default value	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	인증 모드.
properties.container	string		연결된 Storage 계정 내의 컨테이너 이름입니다. 이 컨테이너에는 읽거나 쓸 Blob이 포함됩니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.dateFormat	string		날짜 형식입니다. pathPattern에 {date}가 표시되는 위치마다 이 속성의 값이 대신 날짜 형식으로 사용됩니다.
properties.pathPattern	string		Blob 경로 패턴입니다. 정규식이 아닙니다. Blob 이름이 일치하여 작업에 대한 입력 또는 출력으로 포함해야 하는지 여부를 결정하는 패턴을 나타냅니다. 자세한 설명 및 예제는 또는 https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output 를 참조하세요https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input.
properties.sourcePartitionCount	integer		Blob 입력 데이터 원본의 파티션 수입니다. 범위 1 - 1024.
properties.storageAccounts	StorageAccount[]		하나 이상의 Azure Storage 계정 목록입니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.timeFormat	string		시간 형식입니다. {time}이 pathPattern에 표시되는 위치마다 이 속성의 값이 시간 형식으로 대신 사용됩니다.
type	string: Microsoft.Storage/Blob		스트림 데이터를 포함하는 입력 데이터 원본의 형식을 나타냅니다. PUT(CreateOrReplace) 요청에 필요합니다.

ClusterInfo

Stream Analytics 클러스터와 연결된 속성입니다.

Name	형식	Description
id	string	클러스터의 리소스 ID입니다.

CompatibilityLevel

스트리밍 작업의 특정 런타임 동작을 제어합니다.

Name	형식	Description
1.0	string
1.2	string

Compression

입력 데이터가 압축되는 방법을 설명합니다.

Name	형식	Default value	Description
type	CompressionType	None	입력에서 사용하는 압축 유형을 나타냅니다. PUT(CreateOrReplace) 요청에 필요합니다.

CompressionType

입력에서 사용하는 압축 유형을 나타냅니다. PUT(CreateOrReplace) 요청에 필요합니다.

Name	형식	Description
Deflate	string
GZip	string
None	string

ContentStoragePolicy

유효한 값은 JobStorageAccount 및 SystemAccount입니다. JobStorageAccount로 설정하면 사용자가 jobStorageAccount 속성도 지정해야 합니다. .

Name	형식	Description
JobStorageAccount	string
SystemAccount	string

CsvSerialization

입력의 데이터를 직렬화하는 방법 또는 CSV 형식으로 출력에 쓸 때 데이터가 serialize되는 방법을 설명합니다.

Name	형식	Description
properties.encoding	Encoding	입력의 경우 들어오는 데이터의 인코딩 및 출력의 경우 나가는 데이터의 인코딩을 지정합니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.fieldDelimiter	string	CSV(쉼표로 구분된 값) 레코드를 구분하는 데 사용할 구분 기호를 지정합니다. 지원되는 값 목록은 또는 https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output 을 참조 https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input 하세요. PUT(CreateOrReplace) 요청에 필요합니다.
type	string: Csv	입력 또는 출력에서 사용하는 serialization 유형을 나타냅니다. PUT(CreateOrReplace) 요청에 필요합니다.

DiagnosticCondition

리소스 또는 전체 작업에 적용할 수 있는 조건으로 고객의 주의를 끌 수 있습니다.

Name	형식	Description
code	string	불투명 진단 코드입니다.
message	string	조건을 자세히 설명하는 사람이 읽을 수 있는 메시지입니다. 클라이언트 요청의 Accept-Language 지역화됩니다.
since	string	조건이 시작된 시점의 UTC 타임스탬프입니다. 고객은 이 시간 경에 ops 로그에서 해당 이벤트를 찾을 수 있어야 합니다.

Diagnostics

고객의 주의를 끄는 입력, 출력 또는 전체 작업에 적용되는 조건에 대해 설명합니다.

Name	형식	Description
conditions	DiagnosticCondition[]	고객의 주의를 끌 수 있는 리소스 또는 전체 작업에 적용할 수 있는 0개 이상의 조건 컬렉션입니다.

DocumentDbOutputDataSource

DocumentDB 출력 데이터 원본에 대해 설명합니다.

Name	형식	Description
properties.accountId	string	DocumentDB 계정 이름 또는 ID입니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.accountKey	string	DocumentDB 계정의 계정 키입니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.collectionNamePattern	string	사용할 컬렉션에 대한 컬렉션 이름 패턴입니다. 컬렉션 이름 형식은 선택적 {partition} 토큰을 사용하여 구성할 수 있으며 파티션은 0부터 시작합니다. 자세한 내용은 의 https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output DocumentDB 섹션을 참조하세요. PUT(CreateOrReplace) 요청에 필요합니다.
properties.database	string	DocumentDB 데이터베이스의 이름입니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.documentId	string	삽입 또는 업데이트 작업이 기반으로 하는 기본 키를 지정하는 데 사용되는 출력 이벤트의 필드 이름입니다.
properties.partitionKey	string	컬렉션에서 출력 분할을 위한 키를 지정하는 데 사용되는 출력 이벤트의 필드 이름입니다. 'collectionNamePattern'에 {partition} 토큰이 포함된 경우 이 속성을 지정해야 합니다.
type	string: Microsoft.Storage/DocumentDB	기록될 데이터 원본 출력의 형식을 나타냅니다. PUT(CreateOrReplace) 요청에 필요합니다.

Encoding

입력의 경우 들어오는 데이터의 인코딩 및 출력의 경우 나가는 데이터의 인코딩을 지정합니다.

Name	형식	Description
UTF8	string

Error

일반적인 오류 표현입니다.

Name	형식	Description
error	Error	오류 정의 속성입니다.

EventHubOutputDataSource

이벤트 허브 출력 데이터 원본에 대해 설명합니다.

Name	형식	Default value	Description
authenticationMode	AuthenticationMode	ConnectionString	인증 모드.
properties.eventHubName	string		이벤트 허브의 이름입니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.partitionKey	string		이벤트 데이터를 보낼 파티션을 결정하는 데 사용되는 키/열입니다.
properties.propertyColumns	string[]		이 이벤트 허브 출력과 연결된 속성입니다.
serviceBusNamespace	string		원하는 이벤트 허브, Service Bus 큐, Service Bus 토픽 등과 연결된 네임스페이스입니다. PUT(CreateOrReplace) 요청에 필요합니다.
sharedAccessPolicyKey	string		지정된 공유 액세스 정책에 대한 공유 액세스 정책 키입니다. PUT(CreateOrReplace) 요청에 필요합니다.
sharedAccessPolicyName	string		이벤트 허브, Service Bus 큐, Service Bus 토픽 등에 대한 공유 액세스 정책 이름입니다. PUT(CreateOrReplace) 요청에 필요합니다.
type	string: Microsoft.ServiceBus/EventHub		기록될 데이터 원본 출력의 형식을 나타냅니다. PUT(CreateOrReplace) 요청에 필요합니다.

EventHubStreamInputDataSource

스트림 데이터를 포함하는 이벤트 허브 입력 데이터 원본에 대해 설명합니다.

Name	형식	Default value	Description
authenticationMode	AuthenticationMode	ConnectionString	인증 모드.
properties.consumerGroupName	string		이벤트 허브에서 이벤트를 읽는 데 사용해야 하는 이벤트 허브 소비자 그룹의 이름입니다. 여러 입력에 대해 고유한 소비자 그룹 이름을 지정하면 각 입력이 이벤트 허브에서 동일한 이벤트를 수신할 수 있습니다. 지정하지 않으면 입력은 이벤트 허브의 기본 소비자 그룹을 사용합니다.
properties.eventHubName	string		이벤트 허브의 이름입니다. PUT(CreateOrReplace) 요청에 필요합니다.
serviceBusNamespace	string		원하는 이벤트 허브, Service Bus 큐, Service Bus 토픽 등과 연결된 네임스페이스입니다. PUT(CreateOrReplace) 요청에 필요합니다.
sharedAccessPolicyKey	string		지정된 공유 액세스 정책에 대한 공유 액세스 정책 키입니다. PUT(CreateOrReplace) 요청에 필요합니다.
sharedAccessPolicyName	string		이벤트 허브, Service Bus 큐, Service Bus 토픽 등에 대한 공유 액세스 정책 이름입니다. PUT(CreateOrReplace) 요청에 필요합니다.
type	string: Microsoft.ServiceBus/EventHub		스트림 데이터를 포함하는 입력 데이터 원본의 형식을 나타냅니다. PUT(CreateOrReplace) 요청에 필요합니다.

EventHubV2OutputDataSource

이벤트 허브 출력 데이터 원본에 대해 설명합니다.

Name	형식	Default value	Description
authenticationMode	AuthenticationMode	ConnectionString	인증 모드.
properties.eventHubName	string		이벤트 허브의 이름입니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.partitionKey	string		이벤트 데이터를 보낼 파티션을 결정하는 데 사용되는 키/열입니다.
properties.propertyColumns	string[]		이 이벤트 허브 출력과 연결된 속성입니다.
serviceBusNamespace	string		원하는 이벤트 허브, Service Bus 큐, Service Bus 토픽 등과 연결된 네임스페이스입니다. PUT(CreateOrReplace) 요청에 필요합니다.
sharedAccessPolicyKey	string		지정된 공유 액세스 정책에 대한 공유 액세스 정책 키입니다. PUT(CreateOrReplace) 요청에 필요합니다.
sharedAccessPolicyName	string		이벤트 허브, Service Bus 큐, Service Bus 토픽 등에 대한 공유 액세스 정책 이름입니다. PUT(CreateOrReplace) 요청에 필요합니다.
type	string: Microsoft.EventHub/EventHub		기록될 데이터 원본 출력의 형식을 나타냅니다. PUT(CreateOrReplace) 요청에 필요합니다.

EventHubV2StreamInputDataSource

스트림 데이터를 포함하는 이벤트 허브 입력 데이터 원본에 대해 설명합니다.

Name	형식	Default value	Description
authenticationMode	AuthenticationMode	ConnectionString	인증 모드.
properties.consumerGroupName	string		이벤트 허브에서 이벤트를 읽는 데 사용해야 하는 이벤트 허브 소비자 그룹의 이름입니다. 여러 입력에 대해 고유한 소비자 그룹 이름을 지정하면 각 입력이 이벤트 허브에서 동일한 이벤트를 수신할 수 있습니다. 지정하지 않으면 입력은 이벤트 허브의 기본 소비자 그룹을 사용합니다.
properties.eventHubName	string		이벤트 허브의 이름입니다. PUT(CreateOrReplace) 요청에 필요합니다.
serviceBusNamespace	string		원하는 이벤트 허브, Service Bus 큐, Service Bus 토픽 등과 연결된 네임스페이스입니다. PUT(CreateOrReplace) 요청에 필요합니다.
sharedAccessPolicyKey	string		지정된 공유 액세스 정책에 대한 공유 액세스 정책 키입니다. PUT(CreateOrReplace) 요청에 필요합니다.
sharedAccessPolicyName	string		이벤트 허브, Service Bus 큐, Service Bus 토픽 등에 대한 공유 액세스 정책 이름입니다. PUT(CreateOrReplace) 요청에 필요합니다.
type	string: Microsoft.EventHub/EventHub		스트림 데이터를 포함하는 입력 데이터 원본의 형식을 나타냅니다. PUT(CreateOrReplace) 요청에 필요합니다.

EventSerializationType

입력 또는 출력에서 사용하는 serialization 유형을 나타냅니다. PUT(CreateOrReplace) 요청에 필요합니다.

Name	형식	Description
Avro	string
Csv	string
Json	string
Parquet	string

EventsOutOfOrderPolicy

입력 이벤트 스트림에 잘못된 순서로 도착하는 이벤트에 적용할 정책을 나타냅니다.

Name	형식	Description
Adjust	string
Drop	string

FileReferenceInputDataSource

참조 데이터가 포함된 파일 입력 데이터 원본에 대해 설명합니다.

Name	형식	Description
properties.path	string	파일의 경로입니다.
type	string: File	참조 데이터를 포함하는 입력 데이터 원본의 형식을 나타냅니다. PUT(CreateOrReplace) 요청에 필요합니다.

Function

명명된 함수와 연결된 모든 정보를 포함하는 함수 개체입니다. 모든 함수는 스트리밍 작업 아래에 포함됩니다.

Name	형식	Description
id	string	리소스 ID
name	string	리소스 이름
properties	FunctionProperties: AggregateFunctionProperties ScalarFunctionProperties	함수와 연결된 속성입니다.
type	string	리소스 유형

FunctionInput

함수의 한 입력 매개 변수에 대해 설명합니다.

Name	형식	Description
dataType	string	함수 입력 매개 변수의 (Azure Stream Analytics 지원) 데이터 형식입니다. 유효한 Azure Stream Analytics 데이터 형식 목록은 다음에서 설명합니다. https://msdn.microsoft.com/en-us/library/azure/dn835065.aspx
isConfigurationParameter	boolean	매개 변수가 구성 매개 변수인지 여부를 나타내는 플래그입니다. True이면 이 입력 매개 변수가 상수여야 합니다. 기본값은 false입니다.

FunctionOutput

함수의 출력을 설명합니다.

Name	형식	Description
dataType	string	함수 출력의 (Azure Stream Analytics 지원) 데이터 형식입니다. 유효한 Azure Stream Analytics 데이터 형식 목록은 다음에서 설명합니다. https://msdn.microsoft.com/en-us/library/azure/dn835065.aspx

GatewayMessageBusOutputDataSource

게이트웨이 Message Bus 출력 데이터 원본에 대해 설명합니다.

Name	형식	Description
properties.topic	string	Service Bus 토픽의 이름입니다.
type	string: GatewayMessageBus	기록될 데이터 원본 출력의 형식을 나타냅니다. PUT(CreateOrReplace) 요청에 필요합니다.

GatewayMessageBusStreamInputDataSource

스트림 데이터를 포함하는 Blob 입력 데이터 원본에 대해 설명합니다.

Name	형식	Description
properties.topic	string	Service Bus 토픽의 이름입니다.
type	string: GatewayMessageBus	스트림 데이터를 포함하는 입력 데이터 원본의 형식을 나타냅니다. PUT(CreateOrReplace) 요청에 필요합니다.

Identity

ID를 확인하는 방법을 설명합니다.

Name	형식	Description
principalId	string	ID 보안 주체 ID
tenantId	string	id tenantId
type	string	ID 유형

Input

명명된 입력과 연결된 모든 정보를 포함하는 입력 개체입니다. 모든 입력은 스트리밍 작업 아래에 포함됩니다.

Name	형식	Description
id	string	리소스 ID
name	string	리소스 이름
properties	InputProperties: ReferenceInputProperties StreamInputProperties	입력과 연결된 속성입니다. PUT(CreateOrReplace) 요청에 필요합니다.
type	string	리소스 유형

IoTHubStreamInputDataSource

스트림 데이터를 포함하는 IoT Hub 입력 데이터 원본에 대해 설명합니다.

Name	형식	Description
properties.consumerGroupName	string	IoT Hub 이벤트를 읽는 데 사용해야 하는 IoT Hub 소비자 그룹의 이름입니다. 지정하지 않으면 입력에서 Iot Hub의 기본 소비자 그룹을 사용합니다.
properties.endpoint	string	연결할 IoT Hub 엔드포인트입니다(예: 메시지/이벤트, 메시지/작업모니터링Events 등).
properties.iotHubNamespace	string	IoT Hub 이름 또는 URI입니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.sharedAccessPolicyKey	string	지정된 공유 액세스 정책에 대한 공유 액세스 정책 키입니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.sharedAccessPolicyName	string	IoT Hub 대한 공유 액세스 정책 이름입니다. 이 정책에는 적어도 서비스 연결 권한이 포함되어야 합니다. PUT(CreateOrReplace) 요청에 필요합니다.
type	string: Microsoft.Devices/IotHubs	스트림 데이터를 포함하는 입력 데이터 원본의 형식을 나타냅니다. PUT(CreateOrReplace) 요청에 필요합니다.

JavaScriptFunctionBinding

JavaScript 함수에 대한 바인딩입니다.

Name	형식	Description
properties.script	string	단일 함수 정의를 포함하는 JavaScript 코드입니다. 예: 'function (x, y) { return x + y; }'
type	string: Microsoft.StreamAnalytics/JavascriptUdf	함수 바인딩 형식을 나타냅니다.

JobStorageAccount

MSI와 Azure Storage 계정과 연결된 속성

Name	형식	Default value	Description
accountKey	string		Azure Storage 계정의 계정 키입니다. PUT(CreateOrReplace) 요청에 필요합니다.
accountName	string		Azure Storage 계정의 이름입니다. PUT(CreateOrReplace) 요청에 필요합니다.
authenticationMode	AuthenticationMode	ConnectionString	인증 모드.

JobType

작업의 형식을 설명합니다. 유효한 모드는 및 'Edge'입니다 Cloud .

Name	형식	Description
Cloud	string
Edge	string

JsonOutputSerializationFormat

출력이 작성될 JSON의 형식을 지정합니다. 현재 지원되는 값은 각 JSON 개체를 새 줄로 구분하고 출력이 JSON 개체의 배열로 형식이 지정됨을 나타내는 'array'를 사용하여 출력의 형식을 지정함을 나타내는 'lineSeparated'입니다.

Name	형식	Description
Array	string
LineSeparated	string

JsonSerialization

입력의 데이터를 직렬화하는 방법 또는 JSON 형식으로 출력에 쓸 때 데이터가 serialize되는 방법을 설명합니다.

Name	형식	Description
properties.encoding	Encoding	입력의 경우 들어오는 데이터의 인코딩 및 출력의 경우 나가는 데이터의 인코딩을 지정합니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.format	JsonOutputSerializationFormat	이 속성은 출력의 JSON serialization에만 적용됩니다. 입력에는 적용되지 않습니다. 이 속성은 출력이 기록될 JSON의 형식을 지정합니다. 현재 지원되는 값은 각 JSON 개체를 새 줄로 구분하고 출력이 JSON 개체의 배열로 형식이 지정됨을 나타내는 'array'로 구분하여 출력의 형식을 지정함을 나타내는 'lineSeparated'입니다. 기본값은 null을 남기면 'lineSeparated'입니다.
type	string: Json	입력 또는 출력에서 사용하는 serialization 유형을 나타냅니다. PUT(CreateOrReplace) 요청에 필요합니다.

Output

명명된 출력과 연결된 모든 정보를 포함하는 출력 개체입니다. 모든 출력은 스트리밍 작업 아래에 포함됩니다.

Name	형식	Description
id	string	리소스 ID
name	string	리소스 이름
properties.datasource	OutputDataSource: AzureDataLakeStoreOutputDataSource AzureFunctionOutputDataSource AzureSqlDatabaseOutputDataSource AzureSynapseOutputDataSource AzureTableOutputDataSource BlobOutputDataSource DocumentDbOutputDataSource EventHubOutputDataSource EventHubV2OutputDataSource GatewayMessageBusOutputDataSource PowerBIOutputDataSource ServiceBusQueueOutputDataSource ServiceBusTopicOutputDataSource	출력이 기록될 데이터 원본에 대해 설명합니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.diagnostics	Diagnostics	고객의 주의를 끄는 입력, 출력 또는 전체 작업에 적용되는 조건에 대해 설명합니다.
properties.etag	string	출력에 대한 현재 엔터티 태그입니다. 불투명 문자열입니다. 이를 사용하여 요청 간에 리소스가 변경되었는지 여부를 검색할 수 있습니다. 낙관적 동시성을 위한 쓰기 작업에 If-Match 또는 If-None-Match 헤더에서 사용할 수도 있습니다.
properties.serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	입력의 데이터를 직렬화하는 방법 또는 출력에 쓸 때 데이터가 직렬화되는 방법을 설명합니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.sizeWindow	integer	Stream Analytics 출력을 제한할 크기 창입니다.
properties.timeWindow	string	Stream Analytics 작업 출력을 필터링하기 위한 시간 프레임입니다.
type	string	리소스 유형

OutputErrorPolicy

형식이 잘못되었기 때문에 출력에 도착하고 외부 스토리지에 쓸 수 없는 이벤트에 적용할 정책을 나타냅니다(누락된 열 값, 잘못된 형식 또는 크기의 열 값).

Name	형식	Description
Drop	string
Stop	string

OutputStartMode

값은 JobStartTime, CustomTime 또는 LastOutputEventTime일 수 있습니다. 이 값은 작업이 시작될 때마다 출력 이벤트 스트림의 시작점이 시작될지, outputStartTime 속성을 통해 지정된 사용자 지정 타임스탬프에서 시작해야 하는지 또는 마지막 이벤트 출력 시간부터 시작해야 하는지를 나타냅니다.

Name	형식	Description
CustomTime	string
JobStartTime	string
LastOutputEventTime	string

ParquetSerialization

입력의 데이터를 직렬화하는 방법 또는 Parquet 형식으로 출력에 쓸 때 데이터가 serialize되는 방법을 설명합니다.

Name	형식	Description
type	string: Parquet	입력 또는 출력에서 사용하는 serialization 유형을 나타냅니다. PUT(CreateOrReplace) 요청에 필요합니다.

PowerBIOutputDataSource

Power BI 출력 데이터 원본에 대해 설명합니다.

Name	형식	Default value	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	인증 모드.
properties.dataset	string		Power BI 데이터 세트의 이름입니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.groupId	string		Power BI 그룹의 ID입니다.
properties.groupName	string		Power BI 그룹의 이름입니다. 사용 된 특정 Power BI 그룹 ID를 기억 하려면이 속성을 사용 합니다.
properties.refreshToken	string		데이터 원본으로 인증하는 데 사용할 수 있는 유효한 액세스 토큰을 가져오는 데 사용할 수 있는 새로 고침 토큰입니다. 유효한 새로 고침 토큰은 현재 Azure Portal을 통해서만 얻을 수 있습니다. 데이터 원본을 만든 다음 Azure Portal로 이동하여 이 속성을 유효한 새로 고침 토큰으로 업데이트할 데이터 원본을 인증할 때 더미 문자열 값을 여기에 배치하는 것이 좋습니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.table	string		지정된 데이터 세트 아래의 Power BI 테이블 이름입니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.tokenUserDisplayName	string		새로 고침 토큰을 가져오는 데 사용된 사용자의 사용자 표시 이름입니다. 새로 고침 토큰을 가져오는 데 사용된 사용자를 기억하려면 이 속성을 사용합니다.
properties.tokenUserPrincipalName	string		새로 고침 토큰을 가져오는 데 사용된 사용자의 UPN(사용자 계정 이름)입니다. 새로 고침 토큰을 가져오는 데 사용된 사용자를 기억하려면 이 속성을 사용합니다.
type	string: PowerBI		기록될 데이터 원본 출력의 형식을 나타냅니다. PUT(CreateOrReplace) 요청에 필요합니다.

ReferenceInputProperties

참조 데이터를 포함하는 입력과 연결된 속성입니다.

Name	형식	Description
compression	Compression	입력 데이터가 압축되는 방법을 설명합니다.
datasource	ReferenceInputDataSource: AzureSqlReferenceInputDataSource BlobReferenceInputDataSource FileReferenceInputDataSource	참조 데이터가 포함된 입력 데이터 원본에 대해 설명합니다. PUT(CreateOrReplace) 요청에 필요합니다.
diagnostics	Diagnostics	고객의 주의를 끄는 입력, 출력 또는 전체 작업에 적용되는 조건에 대해 설명합니다.
etag	string	입력에 대한 현재 엔터티 태그입니다. 불투명 문자열입니다. 이를 사용하여 요청 간에 리소스가 변경되었는지 여부를 검색할 수 있습니다. 낙관적 동시성을 위한 쓰기 작업에 If-Match 또는 If-None-Match 헤더에서 사용할 수도 있습니다.
partitionKey	string	partitionKey 입력 데이터를 분할하는 데 사용되는 입력 데이터의 키를 설명합니다.
serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	입력의 데이터를 직렬화하는 방법 또는 출력에 쓸 때 데이터가 직렬화되는 방법을 설명합니다. PUT(CreateOrReplace) 요청에 필요합니다.
type	string: Reference	입력이 참조 데이터 또는 스트림 데이터의 원본인지 여부를 나타냅니다. PUT(CreateOrReplace) 요청에 필요합니다.

RefreshType

데이터 새로 고침 옵션의 형식을 나타냅니다.

Name	형식	Description
RefreshPeriodicallyWithDelta	string
RefreshPeriodicallyWithFull	string
Static	string

ScalarFunctionProperties

스칼라 함수와 연결된 속성입니다.

Name	형식	Description
etag	string	함수의 현재 엔터티 태그입니다. 불투명 문자열입니다. 이를 사용하여 요청 간에 리소스가 변경되었는지 여부를 검색할 수 있습니다. 낙관적 동시성을 위한 쓰기 작업에 If-Match 또는 If-None-Match 헤더에서 사용할 수도 있습니다.
properties.binding	FunctionBinding: AzureMachineLearningWebServiceFunctionBinding JavaScriptFunctionBinding	함수의 물리적 바인딩입니다. 예를 들어 Azure Machine Learning 웹 서비스의 경우 엔드포인트에 대해 설명합니다.
properties.inputs	FunctionInput[]	함수의 한 입력 매개 변수에 대해 설명합니다.
properties.output	FunctionOutput	함수의 출력을 설명합니다.
type	string: Scalar	함수의 형식을 나타냅니다.

ServiceBusQueueOutputDataSource

Service Bus 큐 출력 데이터 원본에 대해 설명합니다.

Name	형식	Default value	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	인증 모드.
properties.propertyColumns	string[]		Service Bus 메시지에 사용자 지정 속성으로 연결할 출력 열 이름의 문자열 배열입니다.
properties.queueName	string		Service Bus 큐 이름 PUT(CreateOrReplace) 요청에 필요합니다.
properties.serviceBusNamespace	string		원하는 이벤트 허브, Service Bus 큐, Service Bus 토픽 등과 연결된 네임스페이스입니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.sharedAccessPolicyKey	string		지정된 공유 액세스 정책에 대한 공유 액세스 정책 키입니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.sharedAccessPolicyName	string		이벤트 허브, Service Bus 큐, Service Bus 토픽 등에 대한 공유 액세스 정책 이름입니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.systemPropertyColumns	object		Service Bus 큐와 연결된 시스템 속성입니다. 지원되는 시스템 속성은 ReplyToSessionId, ContentType, To, Subject, CorrelationId, TimeToLive, PartitionKey, SessionId, ScheduledEnqueueTime, MessageId, ReplyTo, Label, ScheduledEnqueueTimeUtc입니다.
type	string: Microsoft.ServiceBus/Queue		기록될 데이터 원본 출력의 형식을 나타냅니다. PUT(CreateOrReplace) 요청에 필요합니다.

ServiceBusTopicOutputDataSource

Service Bus 토픽 출력 데이터 원본에 대해 설명합니다.

Name	형식	Default value	Description
properties.authenticationMode	AuthenticationMode	ConnectionString	인증 모드.
properties.propertyColumns	string[]		Service Bus 메시지에 사용자 지정 속성으로 연결할 출력 열 이름의 문자열 배열입니다.
properties.serviceBusNamespace	string		원하는 이벤트 허브, Service Bus 큐, Service Bus 토픽 등과 연결된 네임스페이스입니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.sharedAccessPolicyKey	string		지정된 공유 액세스 정책에 대한 공유 액세스 정책 키입니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.sharedAccessPolicyName	string		이벤트 허브, Service Bus 큐, Service Bus 토픽 등에 대한 공유 액세스 정책 이름입니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.systemPropertyColumns	object		Service Bus 토픽 출력과 연결된 시스템 속성입니다. 지원되는 시스템 속성은 ReplyToSessionId, ContentType, To, Subject, CorrelationId, TimeToLive, PartitionKey, SessionId, ScheduledEnqueueTime, MessageId, ReplyTo, Label, ScheduledEnqueueTimeUtc입니다.
properties.topicName	string		Service Bus 토픽의 이름입니다. PUT(CreateOrReplace) 요청에 필요합니다.
type	string: Microsoft.ServiceBus/Topic		기록될 데이터 원본 출력의 형식을 나타냅니다. PUT(CreateOrReplace) 요청에 필요합니다.

Sku

SKU와 연결된 속성입니다.

Name	형식	Description
name	SkuName	SKU의 이름입니다. PUT(CreateOrReplace) 요청에 필요합니다.

SkuName

SKU의 이름입니다. PUT(CreateOrReplace) 요청에 필요합니다.

Name	형식	Description
Standard	string

StorageAccount

Azure Storage 계정과 연결된 속성

Name	형식	Description
accountKey	string	Azure Storage 계정의 계정 키입니다. PUT(CreateOrReplace) 요청에 필요합니다.
accountName	string	Azure Storage 계정의 이름입니다. PUT(CreateOrReplace) 요청에 필요합니다.

StreamingJob

명명된 스트리밍 작업과 연결된 모든 정보를 포함하는 스트리밍 작업 개체입니다.

Name	형식	Description
id	string	리소스에 대한 정규화된 리소스 ID입니다. 예 - /subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/{resourceProviderNamespace}/{resourceType}/{resourceName}
identity	Identity	입력 및 출력으로 인증하는 데 사용할 수 있는 이 작업에 할당된 시스템 할당 관리 ID에 대해 설명합니다.
location	string	리소스가 있는 지리적 위치
name	string	리소스의 이름입니다.
properties.cluster	ClusterInfo	스트리밍 작업이 실행될 클러스터입니다.
properties.compatibilityLevel	CompatibilityLevel	스트리밍 작업의 특정 런타임 동작을 제어합니다.
properties.contentStoragePolicy	ContentStoragePolicy	유효한 값은 JobStorageAccount 및 SystemAccount입니다. JobStorageAccount로 설정하면 사용자가 jobStorageAccount 속성도 지정해야 합니다. .
properties.createdDate	string	값은 스트리밍 작업이 만들어진 시기를 나타내는 ISO-8601 형식의 UTC 타임스탬프입니다.
properties.dataLocale	string	Stream analytics 작업의 데이터 로캘입니다. 값은 집합 https://msdn.microsoft.com/en-us/library/system.globalization.culturetypes(v=vs.110).aspx에서 지원되는 .NET Culture의 이름이어야 합니다. 지정하지 않을 경우 'en-US'으로 기본 설정됩니다.
properties.etag	string	스트리밍 작업의 현재 엔터티 태그입니다. 불투명 문자열입니다. 이를 사용하여 요청 간에 리소스가 변경되었는지 여부를 검색할 수 있습니다. 낙관적 동시성을 위한 쓰기 작업에 If-Match 또는 If-None-Match 헤더에서 사용할 수도 있습니다.
properties.eventsLateArrivalMaxDelayInSeconds	integer	늦게 도착하는 이벤트를 포함하는 최대 허용 지연 시간(초)입니다. 지원되는 범위는-1에서 1814399(20.23:59:59일)이고,-1은 무기한 대기를 지정하는 데 사용됩니다. 속성이 없으면 값이-1인 것으로 해석됩니다.
properties.eventsOutOfOrderMaxDelayInSeconds	integer	순서가 잘못된 이벤트를 다시 순서대로 조정할 수 있는 최대 허용 지연 시간(초)입니다.
properties.eventsOutOfOrderPolicy	EventsOutOfOrderPolicy	입력 이벤트 스트림에 잘못된 순서로 도착하는 이벤트에 적용할 정책을 나타냅니다.
properties.functions	Function[]	스트리밍 작업에 대한 하나 이상의 함수 목록입니다. PUT 요청에서 이 속성을 지정할 때 각 함수의 name 속성이 필요합니다. 이 속성은 PATCH 작업을 통해 수정할 수 없습니다. 개별 변환에 사용할 수 있는 PATCH API를 사용해야 합니다.
properties.inputs	Input[]	스트리밍 작업에 대한 하나 이상의 입력 목록입니다. PUT 요청에서 이 속성을 지정할 때 각 입력에 대한 name 속성이 필요합니다. 이 속성은 PATCH 작업을 통해 수정할 수 없습니다. 개별 입력에 사용할 수 있는 PATCH API를 사용해야 합니다.
properties.jobId	string	스트리밍 작업을 고유하게 식별하는 GUID입니다. 이 GUID는 스트리밍 작업을 만들 때 생성됩니다.
properties.jobState	string	스트리밍 작업의 상태를 설명합니다.
properties.jobStorageAccount	JobStorageAccount	MSI와 Azure Storage 계정과 연결된 속성
properties.jobType	JobType	작업의 형식을 설명합니다. 유효한 모드는 및 'Edge'입니다 `Cloud` .
properties.lastOutputEventTime	string	값은 스트리밍 작업의 마지막 출력 이벤트 시간을 나타내는 ISO-8601 형식의 타임스탬프이거나 출력이 아직 생성되지 않았음을 나타내는 null입니다. 여러 출력 또는 여러 스트림의 경우 해당 집합의 최신 값이 표시됩니다.
properties.outputErrorPolicy	OutputErrorPolicy	형식이 잘못되었기 때문에 출력에 도착하고 외부 스토리지에 쓸 수 없는 이벤트에 적용할 정책을 나타냅니다(누락된 열 값, 잘못된 형식 또는 크기의 열 값).
properties.outputStartMode	OutputStartMode	이 속성은 작업을 만들 때 즉시 시작하려는 경우에만 활용해야 합니다. 값은 JobStartTime, CustomTime 또는 LastOutputEventTime일 수 있습니다. 이 값은 작업이 시작될 때마다 출력 이벤트 스트림의 시작점이 시작될지, outputStartTime 속성을 통해 지정된 사용자 지정 타임스탬프에서 시작해야 하는지 또는 마지막 이벤트 출력 시간부터 시작해야 하는지를 나타냅니다.
properties.outputStartTime	string	값은 출력 이벤트 스트림의 시작 시점을 나타내는 ISO-8601 형식의 타임스탬프 또는 스트리밍 작업이 시작될 때마다 이벤트 출력 스트림이 시작됨을 나타내는 null일 수 있습니다. outputStartMode가 CustomTime으로 설정된 경우 이 속성에는 값이 있어야 합니다.
properties.outputs	Output[]	스트리밍 작업에 대한 하나 이상의 출력 목록입니다. PUT 요청에서 이 속성을 지정할 때 각 출력에 대한 name 속성이 필요합니다. 이 속성은 PATCH 작업을 통해 수정할 수 없습니다. 개별 출력에 사용할 수 있는 PATCH API를 사용해야 합니다.
properties.provisioningState	string	스트리밍 작업의 프로비저닝 상태 설명합니다.
properties.sku	Sku	스트리밍 작업의 SKU에 대해 설명합니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.transformation	Transformation	스트리밍 작업에 사용할 쿼리 및 스트리밍 단위 수를 나타냅니다. PUT 요청에서 이 속성을 지정할 때 변환의 name 속성이 필요합니다. 이 속성은 PATCH 작업을 통해 수정할 수 없습니다. 개별 변환에 사용할 수 있는 PATCH API를 사용해야 합니다.
tags	object	리소스 태그.
type	string	리소스 형식입니다. 예- Microsoft.Compute/virtualMachines 또는 Microsoft.Storage/storageAccounts.

StreamInputProperties

스트림 데이터를 포함하는 입력과 연결된 속성입니다.

Name	형식	Description
compression	Compression	입력 데이터가 압축되는 방법을 설명합니다.
datasource	StreamInputDataSource: BlobStreamInputDataSource EventHubStreamInputDataSource EventHubV2StreamInputDataSource GatewayMessageBusStreamInputDataSource IoTHubStreamInputDataSource	스트림 데이터를 포함하는 입력 데이터 원본에 대해 설명합니다. PUT(CreateOrReplace) 요청에 필요합니다.
diagnostics	Diagnostics	고객의 주의를 끄는 입력, 출력 또는 전체 작업에 적용되는 조건에 대해 설명합니다.
etag	string	입력에 대한 현재 엔터티 태그입니다. 불투명 문자열입니다. 이를 사용하여 요청 간에 리소스가 변경되었는지 여부를 검색할 수 있습니다. 낙관적 동시성을 위한 쓰기 작업에 If-Match 또는 If-None-Match 헤더에서 사용할 수도 있습니다.
partitionKey	string	partitionKey 입력 데이터를 분할하는 데 사용되는 입력 데이터의 키를 설명합니다.
serialization	Serialization: AvroSerialization CsvSerialization JsonSerialization ParquetSerialization	입력의 데이터를 직렬화하는 방법 또는 출력에 쓸 때 데이터가 직렬화되는 방법을 설명합니다. PUT(CreateOrReplace) 요청에 필요합니다.
type	string: Stream	입력이 참조 데이터 또는 스트림 데이터의 원본인지 여부를 나타냅니다. PUT(CreateOrReplace) 요청에 필요합니다.

Transformation

명명된 변환과 관련된 모든 정보를 포함하는 변환 개체입니다. 모든 변환은 스트리밍 작업 아래에 포함됩니다.

Name	형식	Default value	Description
id	string		리소스 ID
name	string		리소스 이름
properties.etag	string		변환에 대한 현재 엔터티 태그입니다. 불투명 문자열입니다. 이를 사용하여 요청 간에 리소스가 변경되었는지 여부를 검색할 수 있습니다. 낙관적 동시성을 위한 쓰기 작업에 If-Match 또는 If-None-Match 헤더에서 사용할 수도 있습니다.
properties.query	string		스트리밍 작업에서 실행할 쿼리를 지정합니다. SAQL(Stream Analytics 쿼리 언어)에 대한 자세한 내용은 를 참조하세요 https://msdn.microsoft.com/library/azure/dn834998 . PUT(CreateOrReplace) 요청에 필요합니다.
properties.streamingUnits	integer	3	스트리밍 작업에서 사용하는 스트리밍 단위 수를 지정합니다.
properties.validStreamingUnits	integer[]		스트리밍 작업이 확장할 수 있는 유효한 스트리밍 단위를 지정합니다.
type	string		리소스 유형

다음을 통해 공유

Streaming Jobs - Create Or Replace

URI 매개 변수

요청 헤더

요청 본문

응답

보안

azure_auth

범위

예제

Create a complete streaming job (a streaming job with a transformation, at least 1 input and at least 1 output)

샘플 요청

샘플 응답

Create a streaming job shell (a streaming job with no inputs, outputs, transformation, or functions)

샘플 요청

샘플 응답

정의

AggregateFunctionProperties

AuthenticationMode

AvroSerialization

AzureDataLakeStoreOutputDataSource

AzureFunctionOutputDataSource

AzureMachineLearningWebServiceFunctionBinding

AzureMachineLearningWebServiceInputColumn

AzureMachineLearningWebServiceInputs

AzureMachineLearningWebServiceOutputColumn

AzureSqlDatabaseOutputDataSource

AzureSqlReferenceInputDataSource

AzureSynapseOutputDataSource

AzureTableOutputDataSource

BlobOutputDataSource

BlobReferenceInputDataSource

BlobStreamInputDataSource

ClusterInfo

CompatibilityLevel

Compression

CompressionType

ContentStoragePolicy

CsvSerialization

DiagnosticCondition

Diagnostics

DocumentDbOutputDataSource

Encoding

Error

EventHubOutputDataSource

EventHubStreamInputDataSource

EventHubV2OutputDataSource

EventHubV2StreamInputDataSource

EventSerializationType

EventsOutOfOrderPolicy

FileReferenceInputDataSource

Function

FunctionInput

FunctionOutput

GatewayMessageBusOutputDataSource

GatewayMessageBusStreamInputDataSource

Identity

Input

IoTHubStreamInputDataSource

JavaScriptFunctionBinding

JobStorageAccount

JobType

JsonOutputSerializationFormat

JsonSerialization

Output

OutputErrorPolicy

OutputStartMode

ParquetSerialization

PowerBIOutputDataSource

ReferenceInputProperties

RefreshType

ScalarFunctionProperties

ServiceBusQueueOutputDataSource

ServiceBusTopicOutputDataSource

Sku

SkuName

StorageAccount

StreamingJob

StreamInputProperties

Transformation