Inputs - Create Or Replace

참조

서비스:: Stream Analytics

API 버전:: 2020-03-01

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

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

URI 매개 변수

Name	In(다음 안에)	필수	형식	Description
inputName	path	True	string	입력의 이름입니다.
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
name	string	리소스 이름
properties	InputProperties: StreamInputProperties ReferenceInputProperties	입력과 연결된 속성입니다. PUT(CreateOrReplace) 요청에 필요합니다.

응답

Name	형식	Description
200 OK	Input	입력이 성공적으로 만들어지거나 대체되었습니다. 헤더 ETag: string
201 Created	Input	입력이 성공적으로 만들어지거나 대체되었습니다. 헤더 ETag: string
Other Status Codes	Error	오류.

Name

형식

Description

200 OK

Input

입력이 성공적으로 만들어지거나 대체되었습니다.

헤더

ETag: string

201 Created

Input

입력이 성공적으로 만들어지거나 대체되었습니다.

헤더

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 Gateway Message Bus input

Create a reference blob input with CSV serialization

Create a reference file input

Create a stream blob input with CSV serialization

Create a stream Event Hub input with JSON serialization

Create a stream IoT Hub input with Avro serialization

Create a Gateway Message Bus input

샘플 요청

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

{
  "properties": {
    "type": "Stream",
    "datasource": {
      "type": "GatewayMessageBus",
      "properties": {
        "topic": "EdgeTopic1"
      }
    }
  }
}

샘플 응답

상태 코드:: 201

ETag: bd8009b3-8165-4bd3-aad2-29a2b378dd14

{
  "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3467/providers/Microsoft.StreamAnalytics/streamingjobs/sj9742/inputs/input7970",
  "name": "input7970",
  "type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
  "properties": {
    "type": "Stream",
    "datasource": {
      "type": "GatewayMessageBus",
      "properties": {
        "topic": "EdgeTopic1"
      }
    }
  }
}

상태 코드:: 200

ETag: bd8009b3-8165-4bd3-aad2-29a2b378dd14

{
  "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3467/providers/Microsoft.StreamAnalytics/streamingjobs/sj9742/inputs/input7970",
  "name": "input7970",
  "type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
  "properties": {
    "type": "Stream",
    "datasource": {
      "type": "GatewayMessageBus",
      "properties": {
        "topic": "EdgeTopic1"
      }
    }
  }
}

Create a reference blob input with CSV serialization

샘플 요청

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

{
  "properties": {
    "type": "Reference",
    "datasource": {
      "type": "Microsoft.Storage/Blob",
      "properties": {
        "storageAccounts": [
          {
            "accountName": "someAccountName",
            "accountKey": "someAccountKey=="
          }
        ],
        "container": "state",
        "pathPattern": "{date}/{time}",
        "dateFormat": "yyyy/MM/dd",
        "timeFormat": "HH"
      }
    },
    "serialization": {
      "type": "Csv",
      "properties": {
        "fieldDelimiter": ",",
        "encoding": "UTF8"
      }
    }
  }
}

import com.azure.resourcemanager.streamanalytics.models.BlobReferenceInputDataSource;
import com.azure.resourcemanager.streamanalytics.models.CsvSerialization;
import com.azure.resourcemanager.streamanalytics.models.Encoding;
import com.azure.resourcemanager.streamanalytics.models.ReferenceInputProperties;

/** Samples for Inputs CreateOrReplace. */
public final class Main {
    /*
     * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Input_Create_Reference_Blob_CSV.json
     */
    /**
     * Sample code: Create a reference blob input with CSV serialization.
     *
     * @param manager Entry point to StreamAnalyticsManager.
     */
    public static void createAReferenceBlobInputWithCSVSerialization(
        com.azure.resourcemanager.streamanalytics.StreamAnalyticsManager manager) {
        manager
            .inputs()
            .define("input7225")
            .withExistingStreamingjob("sjrg8440", "sj9597")
            .withProperties(
                new ReferenceInputProperties()
                    .withSerialization(new CsvSerialization().withFieldDelimiter(",").withEncoding(Encoding.UTF8))
                    .withDatasource(new BlobReferenceInputDataSource()))
            .create();
    }
}

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/Input_Create_Reference_Blob_CSV.json
func ExampleInputsClient_CreateOrReplace_createAReferenceBlobInputWithCsvSerialization() {
	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)
	}
	res, err := clientFactory.NewInputsClient().CreateOrReplace(ctx, "sjrg8440", "sj9597", "input7225", armstreamanalytics.Input{
		Properties: &armstreamanalytics.ReferenceInputProperties{
			Type: to.Ptr("Reference"),
			Serialization: &armstreamanalytics.CSVSerialization{
				Type: to.Ptr(armstreamanalytics.EventSerializationTypeCSV),
				Properties: &armstreamanalytics.CSVSerializationProperties{
					Encoding:       to.Ptr(armstreamanalytics.EncodingUTF8),
					FieldDelimiter: to.Ptr(","),
				},
			},
			Datasource: &armstreamanalytics.BlobReferenceInputDataSource{
				Type: to.Ptr("Microsoft.Storage/Blob"),
				Properties: &armstreamanalytics.BlobReferenceInputDataSourceProperties{
					Container:   to.Ptr("state"),
					DateFormat:  to.Ptr("yyyy/MM/dd"),
					PathPattern: to.Ptr("{date}/{time}"),
					StorageAccounts: []*armstreamanalytics.StorageAccount{
						{
							AccountKey:  to.Ptr("someAccountKey=="),
							AccountName: to.Ptr("someAccountName"),
						}},
					TimeFormat: to.Ptr("HH"),
				},
			},
		},
	}, &armstreamanalytics.InputsClientCreateOrReplaceOptions{IfMatch: nil,
		IfNoneMatch: nil,
	})
	if err != nil {
		log.Fatalf("failed to finish the request: %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.Input = armstreamanalytics.Input{
	// 	Name: to.Ptr("input7225"),
	// 	Type: to.Ptr("Microsoft.StreamAnalytics/streamingjobs/inputs"),
	// 	ID: to.Ptr("/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg8440/providers/Microsoft.StreamAnalytics/streamingjobs/sj9597/inputs/input7225"),
	// 	Properties: &armstreamanalytics.ReferenceInputProperties{
	// 		Type: to.Ptr("Reference"),
	// 		Serialization: &armstreamanalytics.CSVSerialization{
	// 			Type: to.Ptr(armstreamanalytics.EventSerializationTypeCSV),
	// 			Properties: &armstreamanalytics.CSVSerializationProperties{
	// 				Encoding: to.Ptr(armstreamanalytics.EncodingUTF8),
	// 				FieldDelimiter: to.Ptr(","),
	// 			},
	// 		},
	// 		Datasource: &armstreamanalytics.BlobReferenceInputDataSource{
	// 			Type: to.Ptr("Microsoft.Storage/Blob"),
	// 			Properties: &armstreamanalytics.BlobReferenceInputDataSourceProperties{
	// 				Container: to.Ptr("state"),
	// 				DateFormat: to.Ptr("yyyy/MM/dd"),
	// 				PathPattern: to.Ptr("{date}/{time}"),
	// 				StorageAccounts: []*armstreamanalytics.StorageAccount{
	// 					{
	// 						AccountName: to.Ptr("someAccountName"),
	// 				}},
	// 				TimeFormat: to.Ptr("HH"),
	// 			},
	// 		},
	// 	},
	// }
}

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 an input or replaces an already existing input under an existing streaming job.
 *
 * @summary Creates an input or replaces an already existing input under an existing streaming job.
 * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Input_Create_Reference_Blob_CSV.json
 */
async function createAReferenceBlobInputWithCsvSerialization() {
  const subscriptionId = "56b5e0a9-b645-407d-99b0-c64f86013e3d";
  const resourceGroupName = "sjrg8440";
  const jobName = "sj9597";
  const inputName = "input7225";
  const input = {
    properties: {
      type: "Reference",
      datasource: {
        type: "Microsoft.Storage/Blob",
        container: "state",
        dateFormat: "yyyy/MM/dd",
        pathPattern: "{date}/{time}",
        storageAccounts: [{ accountKey: "someAccountKey==", accountName: "someAccountName" }],
        timeFormat: "HH",
      },
      serialization: { type: "Csv", encoding: "UTF8", fieldDelimiter: "," },
    },
  };
  const credential = new DefaultAzureCredential();
  const client = new StreamAnalyticsManagementClient(credential, subscriptionId);
  const result = await client.inputs.createOrReplace(resourceGroupName, jobName, inputName, input);
  console.log(result);
}

createAReferenceBlobInputWithCsvSerialization().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: c987701d-4039-47aa-a115-ad84f67d07c5

{
  "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg8440/providers/Microsoft.StreamAnalytics/streamingjobs/sj9597/inputs/input7225",
  "name": "input7225",
  "type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
  "properties": {
    "type": "Reference",
    "datasource": {
      "type": "Microsoft.Storage/Blob",
      "properties": {
        "storageAccounts": [
          {
            "accountName": "someAccountName"
          }
        ],
        "container": "state",
        "pathPattern": "{date}/{time}",
        "dateFormat": "yyyy/MM/dd",
        "timeFormat": "HH"
      }
    },
    "serialization": {
      "type": "Csv",
      "properties": {
        "fieldDelimiter": ",",
        "encoding": "UTF8"
      }
    }
  }
}

상태 코드:: 200

ETag: c987701d-4039-47aa-a115-ad84f67d07c5

{
  "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg8440/providers/Microsoft.StreamAnalytics/streamingjobs/sj9597/inputs/input7225",
  "name": "input7225",
  "type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
  "properties": {
    "type": "Reference",
    "datasource": {
      "type": "Microsoft.Storage/Blob",
      "properties": {
        "storageAccounts": [
          {
            "accountName": "someAccountName"
          }
        ],
        "container": "state",
        "pathPattern": "{date}/{time}",
        "dateFormat": "yyyy/MM/dd",
        "timeFormat": "HH"
      }
    },
    "serialization": {
      "type": "Csv",
      "properties": {
        "fieldDelimiter": ",",
        "encoding": "UTF8"
      }
    }
  }
}

Create a reference file input

샘플 요청

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

{
  "properties": {
    "type": "Reference",
    "datasource": {
      "type": "File",
      "properties": {
        "path": "my/path"
      }
    }
  }
}

샘플 응답

상태 코드:: 201

ETag: c987701d-4039-47aa-a115-ad84f67d07c5

{
  "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg8440/providers/Microsoft.StreamAnalytics/streamingjobs/sj9597/inputs/input7225",
  "name": "input7225",
  "type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
  "properties": {
    "type": "Reference",
    "datasource": {
      "type": "File",
      "properties": {
        "path": "my/path"
      }
    }
  }
}

상태 코드:: 200

ETag: c987701d-4039-47aa-a115-ad84f67d07c5

{
  "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg8440/providers/Microsoft.StreamAnalytics/streamingjobs/sj9597/inputs/input7225",
  "name": "input7225",
  "type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
  "properties": {
    "type": "Reference",
    "datasource": {
      "type": "File",
      "properties": {
        "path": "my/path"
      }
    }
  }
}

Create a stream blob input with CSV serialization

샘플 요청

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

{
  "properties": {
    "type": "Stream",
    "datasource": {
      "type": "Microsoft.Storage/Blob",
      "properties": {
        "storageAccounts": [
          {
            "accountName": "someAccountName",
            "accountKey": "someAccountKey=="
          }
        ],
        "container": "state",
        "pathPattern": "{date}/{time}",
        "dateFormat": "yyyy/MM/dd",
        "timeFormat": "HH",
        "sourcePartitionCount": 16
      }
    },
    "serialization": {
      "type": "Csv",
      "properties": {
        "fieldDelimiter": ",",
        "encoding": "UTF8"
      }
    }
  }
}

import com.azure.resourcemanager.streamanalytics.models.BlobStreamInputDataSource;
import com.azure.resourcemanager.streamanalytics.models.CsvSerialization;
import com.azure.resourcemanager.streamanalytics.models.Encoding;
import com.azure.resourcemanager.streamanalytics.models.StorageAccount;
import com.azure.resourcemanager.streamanalytics.models.StreamInputProperties;
import java.util.Arrays;

/** Samples for Inputs CreateOrReplace. */
public final class Main {
    /*
     * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Input_Create_Stream_Blob_CSV.json
     */
    /**
     * Sample code: Create a stream blob input with CSV serialization.
     *
     * @param manager Entry point to StreamAnalyticsManager.
     */
    public static void createAStreamBlobInputWithCSVSerialization(
        com.azure.resourcemanager.streamanalytics.StreamAnalyticsManager manager) {
        manager
            .inputs()
            .define("input8899")
            .withExistingStreamingjob("sjrg8161", "sj6695")
            .withProperties(
                new StreamInputProperties()
                    .withSerialization(new CsvSerialization().withFieldDelimiter(",").withEncoding(Encoding.UTF8))
                    .withDatasource(
                        new BlobStreamInputDataSource()
                            .withSourcePartitionCount(16)
                            .withStorageAccounts(
                                Arrays
                                    .asList(
                                        new StorageAccount()
                                            .withAccountName("someAccountName")
                                            .withAccountKey("someAccountKey==")))
                            .withContainer("state")
                            .withPathPattern("{date}/{time}")
                            .withDateFormat("yyyy/MM/dd")
                            .withTimeFormat("HH")))
            .create();
    }
}

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/Input_Create_Stream_Blob_CSV.json
func ExampleInputsClient_CreateOrReplace_createAStreamBlobInputWithCsvSerialization() {
	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)
	}
	res, err := clientFactory.NewInputsClient().CreateOrReplace(ctx, "sjrg8161", "sj6695", "input8899", armstreamanalytics.Input{
		Properties: &armstreamanalytics.StreamInputProperties{
			Type: to.Ptr("Stream"),
			Serialization: &armstreamanalytics.CSVSerialization{
				Type: to.Ptr(armstreamanalytics.EventSerializationTypeCSV),
				Properties: &armstreamanalytics.CSVSerializationProperties{
					Encoding:       to.Ptr(armstreamanalytics.EncodingUTF8),
					FieldDelimiter: to.Ptr(","),
				},
			},
			Datasource: &armstreamanalytics.BlobStreamInputDataSource{
				Type: to.Ptr("Microsoft.Storage/Blob"),
				Properties: &armstreamanalytics.BlobStreamInputDataSourceProperties{
					Container:   to.Ptr("state"),
					DateFormat:  to.Ptr("yyyy/MM/dd"),
					PathPattern: to.Ptr("{date}/{time}"),
					StorageAccounts: []*armstreamanalytics.StorageAccount{
						{
							AccountKey:  to.Ptr("someAccountKey=="),
							AccountName: to.Ptr("someAccountName"),
						}},
					TimeFormat:           to.Ptr("HH"),
					SourcePartitionCount: to.Ptr[int32](16),
				},
			},
		},
	}, &armstreamanalytics.InputsClientCreateOrReplaceOptions{IfMatch: nil,
		IfNoneMatch: nil,
	})
	if err != nil {
		log.Fatalf("failed to finish the request: %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.Input = armstreamanalytics.Input{
	// 	Name: to.Ptr("input8899"),
	// 	Type: to.Ptr("Microsoft.StreamAnalytics/streamingjobs/inputs"),
	// 	ID: to.Ptr("/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg8161/providers/Microsoft.StreamAnalytics/streamingjobs/sj6695/inputs/input8899"),
	// 	Properties: &armstreamanalytics.StreamInputProperties{
	// 		Type: to.Ptr("Stream"),
	// 		Serialization: &armstreamanalytics.CSVSerialization{
	// 			Type: to.Ptr(armstreamanalytics.EventSerializationTypeCSV),
	// 			Properties: &armstreamanalytics.CSVSerializationProperties{
	// 				Encoding: to.Ptr(armstreamanalytics.EncodingUTF8),
	// 				FieldDelimiter: to.Ptr(","),
	// 			},
	// 		},
	// 		Datasource: &armstreamanalytics.BlobStreamInputDataSource{
	// 			Type: to.Ptr("Microsoft.Storage/Blob"),
	// 			Properties: &armstreamanalytics.BlobStreamInputDataSourceProperties{
	// 				Container: to.Ptr("state"),
	// 				DateFormat: to.Ptr("yyyy/MM/dd"),
	// 				PathPattern: to.Ptr("{date}/{time}"),
	// 				StorageAccounts: []*armstreamanalytics.StorageAccount{
	// 					{
	// 						AccountName: to.Ptr("someAccountName"),
	// 				}},
	// 				TimeFormat: to.Ptr("HH"),
	// 				SourcePartitionCount: to.Ptr[int32](16),
	// 			},
	// 		},
	// 	},
	// }
}

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 an input or replaces an already existing input under an existing streaming job.
 *
 * @summary Creates an input or replaces an already existing input under an existing streaming job.
 * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Input_Create_Stream_Blob_CSV.json
 */
async function createAStreamBlobInputWithCsvSerialization() {
  const subscriptionId = "56b5e0a9-b645-407d-99b0-c64f86013e3d";
  const resourceGroupName = "sjrg8161";
  const jobName = "sj6695";
  const inputName = "input8899";
  const input = {
    properties: {
      type: "Stream",
      datasource: {
        type: "Microsoft.Storage/Blob",
        container: "state",
        dateFormat: "yyyy/MM/dd",
        pathPattern: "{date}/{time}",
        sourcePartitionCount: 16,
        storageAccounts: [{ accountKey: "someAccountKey==", accountName: "someAccountName" }],
        timeFormat: "HH",
      },
      serialization: { type: "Csv", encoding: "UTF8", fieldDelimiter: "," },
    },
  };
  const credential = new DefaultAzureCredential();
  const client = new StreamAnalyticsManagementClient(credential, subscriptionId);
  const result = await client.inputs.createOrReplace(resourceGroupName, jobName, inputName, input);
  console.log(result);
}

createAStreamBlobInputWithCsvSerialization().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: 475074b8-c957-4b1f-a219-12b8399c3d4c

{
  "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg8161/providers/Microsoft.StreamAnalytics/streamingjobs/sj6695/inputs/input8899",
  "name": "input8899",
  "type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
  "properties": {
    "type": "Stream",
    "datasource": {
      "type": "Microsoft.Storage/Blob",
      "properties": {
        "sourcePartitionCount": 16,
        "storageAccounts": [
          {
            "accountName": "someAccountName"
          }
        ],
        "container": "state",
        "pathPattern": "{date}/{time}",
        "dateFormat": "yyyy/MM/dd",
        "timeFormat": "HH"
      }
    },
    "serialization": {
      "type": "Csv",
      "properties": {
        "fieldDelimiter": ",",
        "encoding": "UTF8"
      }
    }
  }
}

상태 코드:: 200

ETag: 475074b8-c957-4b1f-a219-12b8399c3d4c

{
  "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg8161/providers/Microsoft.StreamAnalytics/streamingjobs/sj6695/inputs/input8899",
  "name": "input8899",
  "type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
  "properties": {
    "type": "Stream",
    "datasource": {
      "type": "Microsoft.Storage/Blob",
      "properties": {
        "sourcePartitionCount": 16,
        "storageAccounts": [
          {
            "accountName": "someAccountName"
          }
        ],
        "container": "state",
        "pathPattern": "{date}/{time}",
        "dateFormat": "yyyy/MM/dd",
        "timeFormat": "HH"
      }
    },
    "serialization": {
      "type": "Csv",
      "properties": {
        "fieldDelimiter": ",",
        "encoding": "UTF8"
      }
    }
  }
}

Create a stream Event Hub input with JSON serialization

샘플 요청

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

{
  "properties": {
    "type": "Stream",
    "datasource": {
      "type": "Microsoft.ServiceBus/EventHub",
      "properties": {
        "serviceBusNamespace": "sdktest",
        "sharedAccessPolicyName": "RootManageSharedAccessKey",
        "sharedAccessPolicyKey": "someSharedAccessPolicyKey==",
        "eventHubName": "sdkeventhub",
        "consumerGroupName": "sdkconsumergroup"
      }
    },
    "serialization": {
      "type": "Json",
      "properties": {
        "encoding": "UTF8"
      }
    }
  }
}

import com.azure.resourcemanager.streamanalytics.models.Encoding;
import com.azure.resourcemanager.streamanalytics.models.EventHubStreamInputDataSource;
import com.azure.resourcemanager.streamanalytics.models.JsonSerialization;
import com.azure.resourcemanager.streamanalytics.models.StreamInputProperties;

/** Samples for Inputs CreateOrReplace. */
public final class Main {
    /*
     * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Input_Create_Stream_EventHub_JSON.json
     */
    /**
     * Sample code: Create a stream Event Hub input with JSON serialization.
     *
     * @param manager Entry point to StreamAnalyticsManager.
     */
    public static void createAStreamEventHubInputWithJSONSerialization(
        com.azure.resourcemanager.streamanalytics.StreamAnalyticsManager manager) {
        manager
            .inputs()
            .define("input7425")
            .withExistingStreamingjob("sjrg3139", "sj197")
            .withProperties(
                new StreamInputProperties()
                    .withSerialization(new JsonSerialization().withEncoding(Encoding.UTF8))
                    .withDatasource(
                        new EventHubStreamInputDataSource()
                            .withConsumerGroupName("sdkconsumergroup")
                            .withEventHubName("sdkeventhub")
                            .withServiceBusNamespace("sdktest")
                            .withSharedAccessPolicyName("RootManageSharedAccessKey")
                            .withSharedAccessPolicyKey("someSharedAccessPolicyKey==")))
            .create();
    }
}

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/Input_Create_Stream_EventHub_JSON.json
func ExampleInputsClient_CreateOrReplace_createAStreamEventHubInputWithJsonSerialization() {
	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)
	}
	res, err := clientFactory.NewInputsClient().CreateOrReplace(ctx, "sjrg3139", "sj197", "input7425", armstreamanalytics.Input{
		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.EventHubStreamInputDataSource{
				Type: to.Ptr("Microsoft.ServiceBus/EventHub"),
				Properties: &armstreamanalytics.EventHubStreamInputDataSourceProperties{
					ServiceBusNamespace:    to.Ptr("sdktest"),
					SharedAccessPolicyKey:  to.Ptr("someSharedAccessPolicyKey=="),
					SharedAccessPolicyName: to.Ptr("RootManageSharedAccessKey"),
					EventHubName:           to.Ptr("sdkeventhub"),
					ConsumerGroupName:      to.Ptr("sdkconsumergroup"),
				},
			},
		},
	}, &armstreamanalytics.InputsClientCreateOrReplaceOptions{IfMatch: nil,
		IfNoneMatch: nil,
	})
	if err != nil {
		log.Fatalf("failed to finish the request: %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.Input = armstreamanalytics.Input{
	// 	Name: to.Ptr("input7425"),
	// 	Type: to.Ptr("Microsoft.StreamAnalytics/streamingjobs/inputs"),
	// 	ID: to.Ptr("/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3139/providers/Microsoft.StreamAnalytics/streamingjobs/sj197/inputs/input7425"),
	// 	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.EventHubStreamInputDataSource{
	// 			Type: to.Ptr("Microsoft.ServiceBus/EventHub"),
	// 			Properties: &armstreamanalytics.EventHubStreamInputDataSourceProperties{
	// 				ServiceBusNamespace: to.Ptr("sdktest"),
	// 				SharedAccessPolicyName: to.Ptr("RootManageSharedAccessKey"),
	// 				EventHubName: to.Ptr("sdkeventhub"),
	// 				ConsumerGroupName: to.Ptr("sdkconsumergroup"),
	// 			},
	// 		},
	// 	},
	// }
}

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 an input or replaces an already existing input under an existing streaming job.
 *
 * @summary Creates an input or replaces an already existing input under an existing streaming job.
 * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Input_Create_Stream_EventHub_JSON.json
 */
async function createAStreamEventHubInputWithJsonSerialization() {
  const subscriptionId = "56b5e0a9-b645-407d-99b0-c64f86013e3d";
  const resourceGroupName = "sjrg3139";
  const jobName = "sj197";
  const inputName = "input7425";
  const input = {
    properties: {
      type: "Stream",
      datasource: {
        type: "Microsoft.ServiceBus/EventHub",
        consumerGroupName: "sdkconsumergroup",
        eventHubName: "sdkeventhub",
        serviceBusNamespace: "sdktest",
        sharedAccessPolicyKey: "someSharedAccessPolicyKey==",
        sharedAccessPolicyName: "RootManageSharedAccessKey",
      },
      serialization: { type: "Json", encoding: "UTF8" },
    },
  };
  const credential = new DefaultAzureCredential();
  const client = new StreamAnalyticsManagementClient(credential, subscriptionId);
  const result = await client.inputs.createOrReplace(resourceGroupName, jobName, inputName, input);
  console.log(result);
}

createAStreamEventHubInputWithJsonSerialization().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: afd0d184-37e9-4370-9e55-32501bc4de3a

{
  "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3139/providers/Microsoft.StreamAnalytics/streamingjobs/sj197/inputs/input7425",
  "name": "input7425",
  "type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
  "properties": {
    "type": "Stream",
    "datasource": {
      "type": "Microsoft.ServiceBus/EventHub",
      "properties": {
        "eventHubName": "sdkeventhub",
        "consumerGroupName": "sdkconsumergroup",
        "serviceBusNamespace": "sdktest",
        "sharedAccessPolicyName": "RootManageSharedAccessKey"
      }
    },
    "serialization": {
      "type": "Json",
      "properties": {
        "encoding": "UTF8"
      }
    }
  }
}

상태 코드:: 200

ETag: afd0d184-37e9-4370-9e55-32501bc4de3a

{
  "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3139/providers/Microsoft.StreamAnalytics/streamingjobs/sj197/inputs/input7425",
  "name": "input7425",
  "type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
  "properties": {
    "type": "Stream",
    "datasource": {
      "type": "Microsoft.ServiceBus/EventHub",
      "properties": {
        "eventHubName": "sdkeventhub",
        "consumerGroupName": "sdkconsumergroup",
        "serviceBusNamespace": "sdktest",
        "sharedAccessPolicyName": "RootManageSharedAccessKey"
      }
    },
    "serialization": {
      "type": "Json",
      "properties": {
        "encoding": "UTF8"
      }
    }
  }
}

Create a stream IoT Hub input with Avro serialization

샘플 요청

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

{
  "properties": {
    "type": "Stream",
    "datasource": {
      "type": "Microsoft.Devices/IotHubs",
      "properties": {
        "iotHubNamespace": "iothub",
        "sharedAccessPolicyName": "owner",
        "sharedAccessPolicyKey": "sharedAccessPolicyKey=",
        "consumerGroupName": "sdkconsumergroup",
        "endpoint": "messages/events"
      }
    },
    "serialization": {
      "type": "Avro"
    }
  }
}

import com.azure.resourcemanager.streamanalytics.models.AvroSerialization;
import com.azure.resourcemanager.streamanalytics.models.IoTHubStreamInputDataSource;
import com.azure.resourcemanager.streamanalytics.models.StreamInputProperties;

/** Samples for Inputs CreateOrReplace. */
public final class Main {
    /*
     * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Input_Create_Stream_IoTHub_Avro.json
     */
    /**
     * Sample code: Create a stream IoT Hub input with Avro serialization.
     *
     * @param manager Entry point to StreamAnalyticsManager.
     */
    public static void createAStreamIoTHubInputWithAvroSerialization(
        com.azure.resourcemanager.streamanalytics.StreamAnalyticsManager manager) {
        manager
            .inputs()
            .define("input7970")
            .withExistingStreamingjob("sjrg3467", "sj9742")
            .withProperties(
                new StreamInputProperties()
                    .withSerialization(new AvroSerialization())
                    .withDatasource(
                        new IoTHubStreamInputDataSource()
                            .withIotHubNamespace("iothub")
                            .withSharedAccessPolicyName("owner")
                            .withSharedAccessPolicyKey("sharedAccessPolicyKey=")
                            .withConsumerGroupName("sdkconsumergroup")
                            .withEndpoint("messages/events")))
            .create();
    }
}

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/Input_Create_Stream_IoTHub_Avro.json
func ExampleInputsClient_CreateOrReplace_createAStreamIoTHubInputWithAvroSerialization() {
	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)
	}
	res, err := clientFactory.NewInputsClient().CreateOrReplace(ctx, "sjrg3467", "sj9742", "input7970", armstreamanalytics.Input{
		Properties: &armstreamanalytics.StreamInputProperties{
			Type: to.Ptr("Stream"),
			Serialization: &armstreamanalytics.AvroSerialization{
				Type: to.Ptr(armstreamanalytics.EventSerializationTypeAvro),
			},
			Datasource: &armstreamanalytics.IoTHubStreamInputDataSource{
				Type: to.Ptr("Microsoft.Devices/IotHubs"),
				Properties: &armstreamanalytics.IoTHubStreamInputDataSourceProperties{
					ConsumerGroupName:      to.Ptr("sdkconsumergroup"),
					Endpoint:               to.Ptr("messages/events"),
					IotHubNamespace:        to.Ptr("iothub"),
					SharedAccessPolicyKey:  to.Ptr("sharedAccessPolicyKey="),
					SharedAccessPolicyName: to.Ptr("owner"),
				},
			},
		},
	}, &armstreamanalytics.InputsClientCreateOrReplaceOptions{IfMatch: nil,
		IfNoneMatch: nil,
	})
	if err != nil {
		log.Fatalf("failed to finish the request: %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.Input = armstreamanalytics.Input{
	// 	Name: to.Ptr("input7970"),
	// 	Type: to.Ptr("Microsoft.StreamAnalytics/streamingjobs/inputs"),
	// 	ID: to.Ptr("/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3467/providers/Microsoft.StreamAnalytics/streamingjobs/sj9742/inputs/input7970"),
	// 	Properties: &armstreamanalytics.StreamInputProperties{
	// 		Type: to.Ptr("Stream"),
	// 		Serialization: &armstreamanalytics.AvroSerialization{
	// 			Type: to.Ptr(armstreamanalytics.EventSerializationTypeAvro),
	// 			Properties: map[string]any{
	// 			},
	// 		},
	// 		Datasource: &armstreamanalytics.IoTHubStreamInputDataSource{
	// 			Type: to.Ptr("Microsoft.Devices/IotHubs"),
	// 			Properties: &armstreamanalytics.IoTHubStreamInputDataSourceProperties{
	// 				ConsumerGroupName: to.Ptr("sdkconsumergroup"),
	// 				Endpoint: to.Ptr("messages/events"),
	// 				IotHubNamespace: to.Ptr("iothub"),
	// 				SharedAccessPolicyName: to.Ptr("owner"),
	// 			},
	// 		},
	// 	},
	// }
}

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 an input or replaces an already existing input under an existing streaming job.
 *
 * @summary Creates an input or replaces an already existing input under an existing streaming job.
 * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Input_Create_Stream_IoTHub_Avro.json
 */
async function createAStreamIoTHubInputWithAvroSerialization() {
  const subscriptionId = "56b5e0a9-b645-407d-99b0-c64f86013e3d";
  const resourceGroupName = "sjrg3467";
  const jobName = "sj9742";
  const inputName = "input7970";
  const input = {
    properties: {
      type: "Stream",
      datasource: {
        type: "Microsoft.Devices/IotHubs",
        consumerGroupName: "sdkconsumergroup",
        endpoint: "messages/events",
        iotHubNamespace: "iothub",
        sharedAccessPolicyKey: "sharedAccessPolicyKey=",
        sharedAccessPolicyName: "owner",
      },
      serialization: { type: "Avro" },
    },
  };
  const credential = new DefaultAzureCredential();
  const client = new StreamAnalyticsManagementClient(credential, subscriptionId);
  const result = await client.inputs.createOrReplace(resourceGroupName, jobName, inputName, input);
  console.log(result);
}

createAStreamIoTHubInputWithAvroSerialization().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: bd8009b3-8165-4bd3-aad2-29a2b378dd14

{
  "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3467/providers/Microsoft.StreamAnalytics/streamingjobs/sj9742/inputs/input7970",
  "name": "input7970",
  "type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
  "properties": {
    "type": "Stream",
    "datasource": {
      "type": "Microsoft.Devices/IotHubs",
      "properties": {
        "iotHubNamespace": "iothub",
        "sharedAccessPolicyName": "owner",
        "endpoint": "messages/events",
        "consumerGroupName": "sdkconsumergroup"
      }
    },
    "serialization": {
      "type": "Avro",
      "properties": {}
    }
  }
}

상태 코드:: 200

ETag: bd8009b3-8165-4bd3-aad2-29a2b378dd14

{
  "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3467/providers/Microsoft.StreamAnalytics/streamingjobs/sj9742/inputs/input7970",
  "name": "input7970",
  "type": "Microsoft.StreamAnalytics/streamingjobs/inputs",
  "properties": {
    "type": "Stream",
    "datasource": {
      "type": "Microsoft.Devices/IotHubs",
      "properties": {
        "iotHubNamespace": "iothub",
        "sharedAccessPolicyName": "owner",
        "endpoint": "messages/events",
        "consumerGroupName": "sdkconsumergroup"
      }
    },
    "serialization": {
      "type": "Avro",
      "properties": {}
    }
  }
}

정의

Name	Description
AuthenticationMode	인증 모드. 유효한 모드는 , `Msi` 및 'UserToken'입니다`ConnectionString`.
AvroSerialization	입력의 데이터를 직렬화하는 방법 또는 Avro 형식으로 출력에 쓸 때 데이터가 직렬화되는 방법을 설명합니다.
AzureSqlReferenceInputDataSource	Azure SQL 데이터베이스 참조 입력 데이터 원본에 대해 설명합니다.
BlobReferenceInputDataSource	참조 데이터가 포함된 Blob 입력 데이터 원본에 대해 설명합니다.
BlobStreamInputDataSource	스트림 데이터를 포함하는 Blob 입력 데이터 원본에 대해 설명합니다.
Compression	입력 데이터가 압축되는 방법을 설명합니다.
CompressionType	입력에서 사용하는 압축 유형을 나타냅니다. PUT(CreateOrReplace) 요청에 필요합니다.
CsvSerialization	입력의 데이터를 직렬화하는 방법 또는 CSV 형식으로 출력에 쓸 때 데이터가 serialize되는 방법을 설명합니다.
DiagnosticCondition	리소스 또는 전체 작업에 적용할 수 있는 조건으로 고객의 주의를 끌 수 있습니다.
Diagnostics	고객의 주의를 끌 수 있는 입력, 출력 또는 전체 작업에 적용되는 조건을 설명합니다.
Encoding	입력의 경우 들어오는 데이터의 인코딩 및 출력의 경우 나가는 데이터의 인코딩을 지정합니다.
Error	일반적인 오류 표현입니다.
EventHubStreamInputDataSource	스트림 데이터를 포함하는 이벤트 허브 입력 데이터 원본에 대해 설명합니다.
EventHubV2StreamInputDataSource	스트림 데이터를 포함하는 이벤트 허브 입력 데이터 원본에 대해 설명합니다.
EventSerializationType	입력 또는 출력에서 사용하는 serialization 유형을 나타냅니다. PUT(CreateOrReplace) 요청에 필요합니다.
FileReferenceInputDataSource	참조 데이터가 포함된 파일 입력 데이터 원본에 대해 설명합니다.
GatewayMessageBusStreamInputDataSource	스트림 데이터를 포함하는 Blob 입력 데이터 원본에 대해 설명합니다.
Input	명명된 입력과 연결된 모든 정보를 포함하는 입력 개체입니다. 모든 입력은 스트리밍 작업 아래에 포함됩니다.
IoTHubStreamInputDataSource	스트림 데이터를 포함하는 IoT Hub 입력 데이터 원본에 대해 설명합니다.
JsonOutputSerializationFormat	출력이 기록될 JSON의 형식을 지정합니다. 현재 지원되는 값은 각 JSON 개체를 새 줄로 구분하고 출력이 JSON 개체의 배열로 형식이 지정됨을 나타내는 'array'로 구분하여 출력의 형식을 지정함을 나타내는 'lineSeparated'입니다.
JsonSerialization	입력의 데이터를 직렬화하는 방법 또는 JSON 형식으로 출력에 쓸 때 데이터가 serialize되는 방법을 설명합니다.
ParquetSerialization	입력의 데이터를 직렬화하는 방법 또는 Parquet 형식으로 출력에 쓸 때 데이터가 serialize되는 방법을 설명합니다.
ReferenceInputProperties	참조 데이터가 포함된 입력과 연결된 속성입니다.
RefreshType	데이터 새로 고침 옵션의 형식을 나타냅니다.
StorageAccount	Azure Storage 계정과 연결된 속성
StreamInputProperties	스트림 데이터를 포함하는 입력과 연결된 속성입니다.

AuthenticationMode

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

Name	형식	Description
ConnectionString	string
Msi	string
UserToken	string

AvroSerialization

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

Name	형식	Description
type	string: Avro	입력 또는 출력에서 사용하는 serialization 유형을 나타냅니다. 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) 요청에 필요합니다.

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) 요청에 필요합니다.

Compression

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

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

CompressionType

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

Name	형식	Description
Deflate	string
GZip	string
None	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개 이상의 조건 컬렉션입니다.

Encoding

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

Name	형식	Description
UTF8	string

Error

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

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

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) 요청에 필요합니다.

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

FileReferenceInputDataSource

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

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

GatewayMessageBusStreamInputDataSource

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

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

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) 요청에 필요합니다.

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) 요청에 필요합니다.

ParquetSerialization

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

Name	형식	Description
type	string: Parquet	입력 또는 출력에서 사용하는 serialization 유형을 나타냅니다. 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	입력의 데이터가 직렬화되는 방법 또는 출력에 기록될 때 데이터가 serialize되는 방법을 설명합니다. PUT(CreateOrReplace) 요청에 필요합니다.
type	string: Reference	입력이 참조 데이터 또는 스트림 데이터의 원본인지 여부를 나타냅니다. PUT(CreateOrReplace) 요청에 필요합니다.

RefreshType

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

Name	형식	Description
RefreshPeriodicallyWithDelta	string
RefreshPeriodicallyWithFull	string
Static	string

StorageAccount

Azure Storage 계정과 연결된 속성

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

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	입력의 데이터가 직렬화되는 방법 또는 출력에 기록될 때 데이터가 serialize되는 방법을 설명합니다. PUT(CreateOrReplace) 요청에 필요합니다.
type	string: Stream	입력이 참조 데이터 또는 스트림 데이터의 원본인지 여부를 나타냅니다. PUT(CreateOrReplace) 요청에 필요합니다.

다음을 통해 공유

Inputs - Create Or Replace

URI 매개 변수

요청 헤더

요청 본문

응답

보안

azure_auth

범위

예제

Create a Gateway Message Bus input

샘플 요청

샘플 응답

Create a reference blob input with CSV serialization

샘플 요청

샘플 응답

Create a reference file input

샘플 요청

샘플 응답

Create a stream blob input with CSV serialization

샘플 요청

샘플 응답

Create a stream Event Hub input with JSON serialization

샘플 요청

샘플 응답

Create a stream IoT Hub input with Avro serialization

샘플 요청

샘플 응답

정의

AuthenticationMode

AvroSerialization

AzureSqlReferenceInputDataSource

BlobReferenceInputDataSource

BlobStreamInputDataSource

Compression

CompressionType

CsvSerialization

DiagnosticCondition

Diagnostics

Encoding

Error

EventHubStreamInputDataSource

EventHubV2StreamInputDataSource

EventSerializationType

FileReferenceInputDataSource

GatewayMessageBusStreamInputDataSource

Input

IoTHubStreamInputDataSource

JsonOutputSerializationFormat

JsonSerialization

ParquetSerialization

ReferenceInputProperties

RefreshType

StorageAccount

StreamInputProperties

추가 리소스