Outputs - Update

Service:

Stream Analytics

API Version:

2020-03-01

기존 스트리밍 작업에서 기존 출력을 업데이트. 나머지 작업 또는 출력 정의에 영향을 주지 않고 출력을 부분적으로 업데이트(예: 하나 또는 두 개의 속성 업데이트)하는 데 사용할 수 있습니다.

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

URI 매개 변수

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

요청 헤더

속성	필수	형식	Description
If-Match		string	출력의 ETag입니다. 이 값을 생략하여 항상 현재 출력을 덮어씁니다. 실수로 동시 변경 내용을 덮어쓰지 않도록 마지막으로 본 ETag 값을 지정합니다.

요청 본문

속성	형식	Description
name	string	리소스 이름
properties.datasource	OutputDataSource: BlobOutputDataSource AzureTableOutputDataSource EventHubOutputDataSource EventHubV2OutputDataSource AzureSqlDatabaseOutputDataSource AzureSynapseOutputDataSource DocumentDbOutputDataSource AzureFunctionOutputDataSource ServiceBusQueueOutputDataSource ServiceBusTopicOutputDataSource PowerBIOutputDataSource AzureDataLakeStoreOutputDataSource GatewayMessageBusOutputDataSource	출력이 기록될 데이터 원본에 대해 설명합니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.serialization	Serialization: ParquetSerialization CsvSerialization JsonSerialization AvroSerialization	입력의 데이터가 직렬화되는 방법 또는 출력에 기록될 때 데이터가 serialize되는 방법을 설명합니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.sizeWindow	integer	Stream Analytics 출력을 제한할 크기 창입니다.
properties.timeWindow	string	Stream Analytics 작업 출력을 필터링하기 위한 시간 프레임입니다.

응답

속성	형식	Description
200 OK	Output	출력이 성공적으로 업데이트되었습니다. Headers ETag: string
Other Status Codes	Error	오류.

보안

azure_auth

Azure Active Directory OAuth2 Flow

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

Scopes

속성	Description
user_impersonation	사용자 계정 가장

예제

Update a blob output with CSV serialization

Update a DocumentDB output

Update a Power BI output

Update a Service Bus Queue output with Avro serialization

Update a Service Bus Topic output with CSV serialization

Update an Azure Data Lake Store output with JSON serialization

Update an Azure Data Warehouse output

Update an Azure Function output

Update an Azure SQL database output

Update an Azure Table output

Update an Event Hub output with JSON serialization

Update a blob output with CSV serialization

Sample Request

HTTP

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

{
  "properties": {
    "datasource": {
      "type": "Microsoft.Storage/Blob",
      "properties": {
        "container": "differentContainer"
      }
    },
    "serialization": {
      "type": "Csv",
      "properties": {
        "fieldDelimiter": "|",
        "encoding": "UTF8"
      }
    }
  }
}

Java

import com.azure.core.util.Context;
import com.azure.resourcemanager.streamanalytics.models.BlobOutputDataSource;
import com.azure.resourcemanager.streamanalytics.models.CsvSerialization;
import com.azure.resourcemanager.streamanalytics.models.Encoding;
import com.azure.resourcemanager.streamanalytics.models.Output;

/** Samples for Outputs Update. */
public final class Main {
    /*
     * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Update_Blob.json
     */
    /**
     * Sample code: Update a blob output with CSV serialization.
     *
     * @param manager Entry point to StreamAnalyticsManager.
     */
    public static void updateABlobOutputWithCSVSerialization(
        com.azure.resourcemanager.streamanalytics.StreamAnalyticsManager manager) {
        Output resource = manager.outputs().getWithResponse("sjrg5023", "sj900", "output1623", Context.NONE).getValue();
        resource
            .update()
            .withDatasource(new BlobOutputDataSource().withContainer("differentContainer"))
            .withSerialization(new CsvSerialization().withFieldDelimiter("|").withEncoding(Encoding.UTF8))
            .apply();
    }
}

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

Go

package armstreamanalytics_test

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/streamanalytics/armstreamanalytics"
)

// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/d55b8005f05b040b852c15e74a0f3e36494a15e1/specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Update_Blob.json
func ExampleOutputsClient_Update_updateABlobOutputWithCsvSerialization() {
	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.NewOutputsClient().Update(ctx, "sjrg5023", "sj900", "output1623", armstreamanalytics.Output{
		Properties: &armstreamanalytics.OutputProperties{
			Datasource: &armstreamanalytics.BlobOutputDataSource{
				Type: to.Ptr("Microsoft.Storage/Blob"),
				Properties: &armstreamanalytics.BlobOutputDataSourceProperties{
					Container: to.Ptr("differentContainer"),
				},
			},
			Serialization: &armstreamanalytics.CSVSerialization{
				Type: to.Ptr(armstreamanalytics.EventSerializationTypeCSV),
				Properties: &armstreamanalytics.CSVSerializationProperties{
					Encoding:       to.Ptr(armstreamanalytics.EncodingUTF8),
					FieldDelimiter: to.Ptr("|"),
				},
			},
		},
	}, &armstreamanalytics.OutputsClientUpdateOptions{IfMatch: 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.Output = armstreamanalytics.Output{
	// 	Name: to.Ptr("output1623"),
	// 	Type: to.Ptr("Microsoft.StreamAnalytics/streamingjobs/outputs"),
	// 	ID: to.Ptr("/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg5023/providers/Microsoft.StreamAnalytics/streamingjobs/sj900/outputs/output1623"),
	// 	Properties: &armstreamanalytics.OutputProperties{
	// 		Datasource: &armstreamanalytics.BlobOutputDataSource{
	// 			Type: to.Ptr("Microsoft.Storage/Blob"),
	// 			Properties: &armstreamanalytics.BlobOutputDataSourceProperties{
	// 				Container: to.Ptr("differentContainer"),
	// 				DateFormat: to.Ptr("yyyy/MM/dd"),
	// 				PathPattern: to.Ptr("{date}/{time}"),
	// 				StorageAccounts: []*armstreamanalytics.StorageAccount{
	// 					{
	// 						AccountName: to.Ptr("someAccountName"),
	// 				}},
	// 				TimeFormat: to.Ptr("HH"),
	// 			},
	// 		},
	// 		Serialization: &armstreamanalytics.CSVSerialization{
	// 			Type: to.Ptr(armstreamanalytics.EventSerializationTypeCSV),
	// 			Properties: &armstreamanalytics.CSVSerializationProperties{
	// 				Encoding: to.Ptr(armstreamanalytics.EncodingUTF8),
	// 				FieldDelimiter: to.Ptr("|"),
	// 			},
	// 		},
	// 	},
	// }
}

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

JavaScript

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

/**
 * This sample demonstrates how to Updates an existing output under an existing streaming job. This can be used to partially update (ie. update one or two properties) an output without affecting the rest the job or output definition.
 *
 * @summary Updates an existing output under an existing streaming job. This can be used to partially update (ie. update one or two properties) an output without affecting the rest the job or output definition.
 * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Update_Blob.json
 */
async function updateABlobOutputWithCsvSerialization() {
  const subscriptionId = "56b5e0a9-b645-407d-99b0-c64f86013e3d";
  const resourceGroupName = "sjrg5023";
  const jobName = "sj900";
  const outputName = "output1623";
  const output = {
    datasource: {
      type: "Microsoft.Storage/Blob",
      container: "differentContainer",
    },
    serialization: { type: "Csv", encoding: "UTF8", fieldDelimiter: "|" },
  };
  const credential = new DefaultAzureCredential();
  const client = new StreamAnalyticsManagementClient(credential, subscriptionId);
  const result = await client.outputs.update(resourceGroupName, jobName, outputName, output);
  console.log(result);
}

updateABlobOutputWithCsvSerialization().catch(console.error);

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

Sample Response

Status code:

200

ETag: 3a1b2023-79a9-4b33-93e8-f49fc3e573fe

Response Body

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

Update a DocumentDB output

Sample Request

HTTP

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

{
  "properties": {
    "datasource": {
      "type": "Microsoft.Storage/DocumentDB",
      "properties": {
        "partitionKey": "differentPartitionKey"
      }
    }
  }
}

Java

import com.azure.core.util.Context;
import com.azure.resourcemanager.streamanalytics.models.DocumentDbOutputDataSource;
import com.azure.resourcemanager.streamanalytics.models.Output;

/** Samples for Outputs Update. */
public final class Main {
    /*
     * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Update_DocumentDB.json
     */
    /**
     * Sample code: Update a DocumentDB output.
     *
     * @param manager Entry point to StreamAnalyticsManager.
     */
    public static void updateADocumentDBOutput(
        com.azure.resourcemanager.streamanalytics.StreamAnalyticsManager manager) {
        Output resource =
            manager.outputs().getWithResponse("sjrg7983", "sj2331", "output3022", Context.NONE).getValue();
        resource
            .update()
            .withDatasource(new DocumentDbOutputDataSource().withPartitionKey("differentPartitionKey"))
            .apply();
    }
}

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

Go

package armstreamanalytics_test

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/streamanalytics/armstreamanalytics"
)

// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/d55b8005f05b040b852c15e74a0f3e36494a15e1/specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Update_DocumentDB.json
func ExampleOutputsClient_Update_updateADocumentDbOutput() {
	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.NewOutputsClient().Update(ctx, "sjrg7983", "sj2331", "output3022", armstreamanalytics.Output{
		Properties: &armstreamanalytics.OutputProperties{
			Datasource: &armstreamanalytics.DocumentDbOutputDataSource{
				Type: to.Ptr("Microsoft.Storage/DocumentDB"),
				Properties: &armstreamanalytics.DocumentDbOutputDataSourceProperties{
					PartitionKey: to.Ptr("differentPartitionKey"),
				},
			},
		},
	}, &armstreamanalytics.OutputsClientUpdateOptions{IfMatch: 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.Output = armstreamanalytics.Output{
	// 	Name: to.Ptr("output3022"),
	// 	Type: to.Ptr("Microsoft.StreamAnalytics/streamingjobs/outputs"),
	// 	ID: to.Ptr("/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg7983/providers/Microsoft.StreamAnalytics/streamingjobs/sj2331/outputs/output3022"),
	// 	Properties: &armstreamanalytics.OutputProperties{
	// 		Datasource: &armstreamanalytics.DocumentDbOutputDataSource{
	// 			Type: to.Ptr("Microsoft.Storage/DocumentDB"),
	// 			Properties: &armstreamanalytics.DocumentDbOutputDataSourceProperties{
	// 				AccountID: to.Ptr("someAccountId"),
	// 				CollectionNamePattern: to.Ptr("collection"),
	// 				Database: to.Ptr("db01"),
	// 				DocumentID: to.Ptr("documentId"),
	// 				PartitionKey: to.Ptr("differentPartitionKey"),
	// 			},
	// 		},
	// 	},
	// }
}

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

JavaScript

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

/**
 * This sample demonstrates how to Updates an existing output under an existing streaming job. This can be used to partially update (ie. update one or two properties) an output without affecting the rest the job or output definition.
 *
 * @summary Updates an existing output under an existing streaming job. This can be used to partially update (ie. update one or two properties) an output without affecting the rest the job or output definition.
 * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Update_DocumentDB.json
 */
async function updateADocumentDbOutput() {
  const subscriptionId = "56b5e0a9-b645-407d-99b0-c64f86013e3d";
  const resourceGroupName = "sjrg7983";
  const jobName = "sj2331";
  const outputName = "output3022";
  const output = {
    datasource: {
      type: "Microsoft.Storage/DocumentDB",
      partitionKey: "differentPartitionKey",
    },
  };
  const credential = new DefaultAzureCredential();
  const client = new StreamAnalyticsManagementClient(credential, subscriptionId);
  const result = await client.outputs.update(resourceGroupName, jobName, outputName, output);
  console.log(result);
}

updateADocumentDbOutput().catch(console.error);

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

Sample Response

Status code:

200

ETag: 7849c132-e995-4631-91c3-931606eec432

Response Body

{
  "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg7983/providers/Microsoft.StreamAnalytics/streamingjobs/sj2331/outputs/output3022",
  "name": "output3022",
  "type": "Microsoft.StreamAnalytics/streamingjobs/outputs",
  "properties": {
    "datasource": {
      "type": "Microsoft.Storage/DocumentDB",
      "properties": {
        "accountId": "someAccountId",
        "database": "db01",
        "collectionNamePattern": "collection",
        "partitionKey": "differentPartitionKey",
        "documentId": "documentId"
      }
    }
  }
}

Update a Power BI output

Sample Request

HTTP

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

{
  "properties": {
    "datasource": {
      "type": "PowerBI",
      "properties": {
        "dataset": "differentDataset"
      }
    }
  }
}

Java

import com.azure.core.util.Context;
import com.azure.resourcemanager.streamanalytics.models.Output;
import com.azure.resourcemanager.streamanalytics.models.PowerBIOutputDataSource;

/** Samples for Outputs Update. */
public final class Main {
    /*
     * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Update_PowerBI.json
     */
    /**
     * Sample code: Update a Power BI output.
     *
     * @param manager Entry point to StreamAnalyticsManager.
     */
    public static void updateAPowerBIOutput(com.azure.resourcemanager.streamanalytics.StreamAnalyticsManager manager) {
        Output resource =
            manager.outputs().getWithResponse("sjrg7983", "sj2331", "output3022", Context.NONE).getValue();
        resource.update().withDatasource(new PowerBIOutputDataSource().withDataset("differentDataset")).apply();
    }
}

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

Go

package armstreamanalytics_test

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/streamanalytics/armstreamanalytics"
)

// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/d55b8005f05b040b852c15e74a0f3e36494a15e1/specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Update_PowerBI.json
func ExampleOutputsClient_Update_updateAPowerBiOutput() {
	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.NewOutputsClient().Update(ctx, "sjrg7983", "sj2331", "output3022", armstreamanalytics.Output{
		Properties: &armstreamanalytics.OutputProperties{
			Datasource: &armstreamanalytics.PowerBIOutputDataSource{
				Type: to.Ptr("PowerBI"),
				Properties: &armstreamanalytics.PowerBIOutputDataSourceProperties{
					Dataset: to.Ptr("differentDataset"),
				},
			},
		},
	}, &armstreamanalytics.OutputsClientUpdateOptions{IfMatch: 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.Output = armstreamanalytics.Output{
	// 	Name: to.Ptr("output3022"),
	// 	Type: to.Ptr("Microsoft.StreamAnalytics/streamingjobs/outputs"),
	// 	ID: to.Ptr("/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg7983/providers/Microsoft.StreamAnalytics/streamingjobs/sj2331/outputs/output3022"),
	// 	Properties: &armstreamanalytics.OutputProperties{
	// 		Datasource: &armstreamanalytics.PowerBIOutputDataSource{
	// 			Type: to.Ptr("PowerBI"),
	// 			Properties: &armstreamanalytics.PowerBIOutputDataSourceProperties{
	// 				TokenUserDisplayName: to.Ptr("Bob Smith"),
	// 				TokenUserPrincipalName: to.Ptr("bobsmith@contoso.com"),
	// 				Dataset: to.Ptr("differentDataset"),
	// 				GroupID: to.Ptr("ac40305e-3e8d-43ac-8161-c33799f43e95"),
	// 				GroupName: to.Ptr("MyPowerBIGroup"),
	// 				Table: to.Ptr("someTable"),
	// 			},
	// 		},
	// 	},
	// }
}

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

JavaScript

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

/**
 * This sample demonstrates how to Updates an existing output under an existing streaming job. This can be used to partially update (ie. update one or two properties) an output without affecting the rest the job or output definition.
 *
 * @summary Updates an existing output under an existing streaming job. This can be used to partially update (ie. update one or two properties) an output without affecting the rest the job or output definition.
 * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Update_PowerBI.json
 */
async function updateAPowerBiOutput() {
  const subscriptionId = "56b5e0a9-b645-407d-99b0-c64f86013e3d";
  const resourceGroupName = "sjrg7983";
  const jobName = "sj2331";
  const outputName = "output3022";
  const output = {
    datasource: { type: "PowerBI", dataset: "differentDataset" },
  };
  const credential = new DefaultAzureCredential();
  const client = new StreamAnalyticsManagementClient(credential, subscriptionId);
  const result = await client.outputs.update(resourceGroupName, jobName, outputName, output);
  console.log(result);
}

updateAPowerBiOutput().catch(console.error);

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

Sample Response

Status code:

200

ETag: 7849c132-e995-4631-91c3-931606eec432

Response Body

{
  "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg7983/providers/Microsoft.StreamAnalytics/streamingjobs/sj2331/outputs/output3022",
  "name": "output3022",
  "type": "Microsoft.StreamAnalytics/streamingjobs/outputs",
  "properties": {
    "datasource": {
      "type": "PowerBI",
      "properties": {
        "dataset": "differentDataset",
        "table": "someTable",
        "tokenUserPrincipalName": "bobsmith@contoso.com",
        "tokenUserDisplayName": "Bob Smith",
        "groupId": "ac40305e-3e8d-43ac-8161-c33799f43e95",
        "groupName": "MyPowerBIGroup"
      }
    }
  }
}

Update a Service Bus Queue output with Avro serialization

Sample Request

HTTP

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

{
  "properties": {
    "datasource": {
      "type": "Microsoft.ServiceBus/Queue",
      "properties": {
        "queueName": "differentQueueName"
      }
    },
    "serialization": {
      "type": "Json",
      "properties": {
        "encoding": "UTF8",
        "format": "LineSeparated"
      }
    }
  }
}

Java

import com.azure.core.util.Context;
import com.azure.resourcemanager.streamanalytics.models.Encoding;
import com.azure.resourcemanager.streamanalytics.models.JsonOutputSerializationFormat;
import com.azure.resourcemanager.streamanalytics.models.JsonSerialization;
import com.azure.resourcemanager.streamanalytics.models.Output;
import com.azure.resourcemanager.streamanalytics.models.ServiceBusQueueOutputDataSource;

/** Samples for Outputs Update. */
public final class Main {
    /*
     * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Update_ServiceBusQueue.json
     */
    /**
     * Sample code: Update a Service Bus Queue output with Avro serialization.
     *
     * @param manager Entry point to StreamAnalyticsManager.
     */
    public static void updateAServiceBusQueueOutputWithAvroSerialization(
        com.azure.resourcemanager.streamanalytics.StreamAnalyticsManager manager) {
        Output resource =
            manager.outputs().getWithResponse("sjrg3410", "sj5095", "output3456", Context.NONE).getValue();
        resource
            .update()
            .withDatasource(new ServiceBusQueueOutputDataSource().withQueueName("differentQueueName"))
            .withSerialization(
                new JsonSerialization()
                    .withEncoding(Encoding.UTF8)
                    .withFormat(JsonOutputSerializationFormat.LINE_SEPARATED))
            .apply();
    }
}

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

Go

package armstreamanalytics_test

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/streamanalytics/armstreamanalytics"
)

// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/d55b8005f05b040b852c15e74a0f3e36494a15e1/specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Update_ServiceBusQueue.json
func ExampleOutputsClient_Update_updateAServiceBusQueueOutputWithAvroSerialization() {
	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.NewOutputsClient().Update(ctx, "sjrg3410", "sj5095", "output3456", armstreamanalytics.Output{
		Properties: &armstreamanalytics.OutputProperties{
			Datasource: &armstreamanalytics.ServiceBusQueueOutputDataSource{
				Type: to.Ptr("Microsoft.ServiceBus/Queue"),
				Properties: &armstreamanalytics.ServiceBusQueueOutputDataSourceProperties{
					QueueName: to.Ptr("differentQueueName"),
				},
			},
			Serialization: &armstreamanalytics.JSONSerialization{
				Type: to.Ptr(armstreamanalytics.EventSerializationTypeJSON),
				Properties: &armstreamanalytics.JSONSerializationProperties{
					Format:   to.Ptr(armstreamanalytics.JSONOutputSerializationFormatLineSeparated),
					Encoding: to.Ptr(armstreamanalytics.EncodingUTF8),
				},
			},
		},
	}, &armstreamanalytics.OutputsClientUpdateOptions{IfMatch: 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.Output = armstreamanalytics.Output{
	// 	Name: to.Ptr("output3456"),
	// 	Type: to.Ptr("Microsoft.StreamAnalytics/streamingjobs/outputs"),
	// 	ID: to.Ptr("/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3410/providers/Microsoft.StreamAnalytics/streamingjobs/sj5095/outputs/output3456"),
	// 	Properties: &armstreamanalytics.OutputProperties{
	// 		Datasource: &armstreamanalytics.ServiceBusQueueOutputDataSource{
	// 			Type: to.Ptr("Microsoft.ServiceBus/Queue"),
	// 			Properties: &armstreamanalytics.ServiceBusQueueOutputDataSourceProperties{
	// 				ServiceBusNamespace: to.Ptr("sdktest"),
	// 				SharedAccessPolicyName: to.Ptr("RootManageSharedAccessKey"),
	// 				PropertyColumns: []*string{
	// 					to.Ptr("column1"),
	// 					to.Ptr("column2")},
	// 					QueueName: to.Ptr("differentQueueName"),
	// 				},
	// 			},
	// 			Serialization: &armstreamanalytics.JSONSerialization{
	// 				Type: to.Ptr(armstreamanalytics.EventSerializationTypeJSON),
	// 				Properties: &armstreamanalytics.JSONSerializationProperties{
	// 					Format: to.Ptr(armstreamanalytics.JSONOutputSerializationFormatLineSeparated),
	// 					Encoding: to.Ptr(armstreamanalytics.EncodingUTF8),
	// 				},
	// 			},
	// 		},
	// 	}
}

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

JavaScript

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

/**
 * This sample demonstrates how to Updates an existing output under an existing streaming job. This can be used to partially update (ie. update one or two properties) an output without affecting the rest the job or output definition.
 *
 * @summary Updates an existing output under an existing streaming job. This can be used to partially update (ie. update one or two properties) an output without affecting the rest the job or output definition.
 * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Update_ServiceBusQueue.json
 */
async function updateAServiceBusQueueOutputWithAvroSerialization() {
  const subscriptionId = "56b5e0a9-b645-407d-99b0-c64f86013e3d";
  const resourceGroupName = "sjrg3410";
  const jobName = "sj5095";
  const outputName = "output3456";
  const output = {
    datasource: {
      type: "Microsoft.ServiceBus/Queue",
      queueName: "differentQueueName",
    },
    serialization: { type: "Json", format: "LineSeparated", encoding: "UTF8" },
  };
  const credential = new DefaultAzureCredential();
  const client = new StreamAnalyticsManagementClient(credential, subscriptionId);
  const result = await client.outputs.update(resourceGroupName, jobName, outputName, output);
  console.log(result);
}

updateAServiceBusQueueOutputWithAvroSerialization().catch(console.error);

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

Sample Response

Status code:

200

ETag: 429adaec-a777-4750-8a39-8d0c931d801c

Response Body

{
  "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg3410/providers/Microsoft.StreamAnalytics/streamingjobs/sj5095/outputs/output3456",
  "name": "output3456",
  "type": "Microsoft.StreamAnalytics/streamingjobs/outputs",
  "properties": {
    "datasource": {
      "type": "Microsoft.ServiceBus/Queue",
      "properties": {
        "queueName": "differentQueueName",
        "propertyColumns": [
          "column1",
          "column2"
        ],
        "serviceBusNamespace": "sdktest",
        "sharedAccessPolicyName": "RootManageSharedAccessKey"
      }
    },
    "serialization": {
      "type": "Json",
      "properties": {
        "encoding": "UTF8",
        "format": "LineSeparated"
      }
    }
  }
}

Update a Service Bus Topic output with CSV serialization

Sample Request

HTTP

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

{
  "properties": {
    "datasource": {
      "type": "Microsoft.ServiceBus/Topic",
      "properties": {
        "topicName": "differentTopicName"
      }
    },
    "serialization": {
      "type": "Csv",
      "properties": {
        "fieldDelimiter": "|",
        "encoding": "UTF8"
      }
    }
  }
}

Java

import com.azure.core.util.Context;
import com.azure.resourcemanager.streamanalytics.models.CsvSerialization;
import com.azure.resourcemanager.streamanalytics.models.Encoding;
import com.azure.resourcemanager.streamanalytics.models.Output;
import com.azure.resourcemanager.streamanalytics.models.ServiceBusTopicOutputDataSource;

/** Samples for Outputs Update. */
public final class Main {
    /*
     * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Update_ServiceBusTopic.json
     */
    /**
     * Sample code: Update a Service Bus Topic output with CSV serialization.
     *
     * @param manager Entry point to StreamAnalyticsManager.
     */
    public static void updateAServiceBusTopicOutputWithCSVSerialization(
        com.azure.resourcemanager.streamanalytics.StreamAnalyticsManager manager) {
        Output resource =
            manager.outputs().getWithResponse("sjrg6450", "sj7094", "output7886", Context.NONE).getValue();
        resource
            .update()
            .withDatasource(new ServiceBusTopicOutputDataSource().withTopicName("differentTopicName"))
            .withSerialization(new CsvSerialization().withFieldDelimiter("|").withEncoding(Encoding.UTF8))
            .apply();
    }
}

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

Go

package armstreamanalytics_test

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/streamanalytics/armstreamanalytics"
)

// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/d55b8005f05b040b852c15e74a0f3e36494a15e1/specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Update_ServiceBusTopic.json
func ExampleOutputsClient_Update_updateAServiceBusTopicOutputWithCsvSerialization() {
	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.NewOutputsClient().Update(ctx, "sjrg6450", "sj7094", "output7886", armstreamanalytics.Output{
		Properties: &armstreamanalytics.OutputProperties{
			Datasource: &armstreamanalytics.ServiceBusTopicOutputDataSource{
				Type: to.Ptr("Microsoft.ServiceBus/Topic"),
				Properties: &armstreamanalytics.ServiceBusTopicOutputDataSourceProperties{
					TopicName: to.Ptr("differentTopicName"),
				},
			},
			Serialization: &armstreamanalytics.CSVSerialization{
				Type: to.Ptr(armstreamanalytics.EventSerializationTypeCSV),
				Properties: &armstreamanalytics.CSVSerializationProperties{
					Encoding:       to.Ptr(armstreamanalytics.EncodingUTF8),
					FieldDelimiter: to.Ptr("|"),
				},
			},
		},
	}, &armstreamanalytics.OutputsClientUpdateOptions{IfMatch: 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.Output = armstreamanalytics.Output{
	// 	Name: to.Ptr("output7886"),
	// 	Type: to.Ptr("Microsoft.StreamAnalytics/streamingjobs/outputs"),
	// 	ID: to.Ptr("/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg6450/providers/Microsoft.StreamAnalytics/streamingjobs/sj7094/outputs/output7886"),
	// 	Properties: &armstreamanalytics.OutputProperties{
	// 		Datasource: &armstreamanalytics.ServiceBusTopicOutputDataSource{
	// 			Type: to.Ptr("Microsoft.ServiceBus/Topic"),
	// 			Properties: &armstreamanalytics.ServiceBusTopicOutputDataSourceProperties{
	// 				ServiceBusNamespace: to.Ptr("sdktest"),
	// 				SharedAccessPolicyName: to.Ptr("RootManageSharedAccessKey"),
	// 				PropertyColumns: []*string{
	// 					to.Ptr("column1"),
	// 					to.Ptr("column2")},
	// 					TopicName: to.Ptr("differentTopicName"),
	// 				},
	// 			},
	// 			Serialization: &armstreamanalytics.CSVSerialization{
	// 				Type: to.Ptr(armstreamanalytics.EventSerializationTypeCSV),
	// 				Properties: &armstreamanalytics.CSVSerializationProperties{
	// 					Encoding: to.Ptr(armstreamanalytics.EncodingUTF8),
	// 					FieldDelimiter: to.Ptr("|"),
	// 				},
	// 			},
	// 		},
	// 	}
}

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

JavaScript

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

/**
 * This sample demonstrates how to Updates an existing output under an existing streaming job. This can be used to partially update (ie. update one or two properties) an output without affecting the rest the job or output definition.
 *
 * @summary Updates an existing output under an existing streaming job. This can be used to partially update (ie. update one or two properties) an output without affecting the rest the job or output definition.
 * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Update_ServiceBusTopic.json
 */
async function updateAServiceBusTopicOutputWithCsvSerialization() {
  const subscriptionId = "56b5e0a9-b645-407d-99b0-c64f86013e3d";
  const resourceGroupName = "sjrg6450";
  const jobName = "sj7094";
  const outputName = "output7886";
  const output = {
    datasource: {
      type: "Microsoft.ServiceBus/Topic",
      topicName: "differentTopicName",
    },
    serialization: { type: "Csv", encoding: "UTF8", fieldDelimiter: "|" },
  };
  const credential = new DefaultAzureCredential();
  const client = new StreamAnalyticsManagementClient(credential, subscriptionId);
  const result = await client.outputs.update(resourceGroupName, jobName, outputName, output);
  console.log(result);
}

updateAServiceBusTopicOutputWithCsvSerialization().catch(console.error);

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

Sample Response

Status code:

200

ETag: c1c2007f-45b2-419a-ae7d-4d2148998460

Response Body

{
  "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg6450/providers/Microsoft.StreamAnalytics/streamingjobs/sj7094/outputs/output7886",
  "name": "output7886",
  "type": "Microsoft.StreamAnalytics/streamingjobs/outputs",
  "properties": {
    "datasource": {
      "type": "Microsoft.ServiceBus/Topic",
      "properties": {
        "topicName": "differentTopicName",
        "propertyColumns": [
          "column1",
          "column2"
        ],
        "serviceBusNamespace": "sdktest",
        "sharedAccessPolicyName": "RootManageSharedAccessKey"
      }
    },
    "serialization": {
      "type": "Csv",
      "properties": {
        "fieldDelimiter": "|",
        "encoding": "UTF8"
      }
    }
  }
}

Update an Azure Data Lake Store output with JSON serialization

Sample Request

HTTP

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

{
  "properties": {
    "datasource": {
      "type": "Microsoft.DataLake/Accounts",
      "properties": {
        "accountName": "differentaccount"
      }
    },
    "serialization": {
      "type": "Json",
      "properties": {
        "encoding": "UTF8",
        "format": "LineSeparated"
      }
    }
  }
}

Java

import com.azure.core.util.Context;
import com.azure.resourcemanager.streamanalytics.models.AzureDataLakeStoreOutputDataSource;
import com.azure.resourcemanager.streamanalytics.models.Encoding;
import com.azure.resourcemanager.streamanalytics.models.JsonOutputSerializationFormat;
import com.azure.resourcemanager.streamanalytics.models.JsonSerialization;
import com.azure.resourcemanager.streamanalytics.models.Output;

/** Samples for Outputs Update. */
public final class Main {
    /*
     * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Update_AzureDataLakeStore.json
     */
    /**
     * Sample code: Update an Azure Data Lake Store output with JSON serialization.
     *
     * @param manager Entry point to StreamAnalyticsManager.
     */
    public static void updateAnAzureDataLakeStoreOutputWithJSONSerialization(
        com.azure.resourcemanager.streamanalytics.StreamAnalyticsManager manager) {
        Output resource =
            manager.outputs().getWithResponse("sjrg6912", "sj3310", "output5195", Context.NONE).getValue();
        resource
            .update()
            .withDatasource(new AzureDataLakeStoreOutputDataSource().withAccountName("differentaccount"))
            .withSerialization(
                new JsonSerialization()
                    .withEncoding(Encoding.UTF8)
                    .withFormat(JsonOutputSerializationFormat.LINE_SEPARATED))
            .apply();
    }
}

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

Go

package armstreamanalytics_test

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/streamanalytics/armstreamanalytics"
)

// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/d55b8005f05b040b852c15e74a0f3e36494a15e1/specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Update_AzureDataLakeStore.json
func ExampleOutputsClient_Update_updateAnAzureDataLakeStoreOutputWithJsonSerialization() {
	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.NewOutputsClient().Update(ctx, "sjrg6912", "sj3310", "output5195", armstreamanalytics.Output{
		Properties: &armstreamanalytics.OutputProperties{
			Datasource: &armstreamanalytics.AzureDataLakeStoreOutputDataSource{
				Type: to.Ptr("Microsoft.DataLake/Accounts"),
				Properties: &armstreamanalytics.AzureDataLakeStoreOutputDataSourceProperties{
					AccountName: to.Ptr("differentaccount"),
				},
			},
			Serialization: &armstreamanalytics.JSONSerialization{
				Type: to.Ptr(armstreamanalytics.EventSerializationTypeJSON),
				Properties: &armstreamanalytics.JSONSerializationProperties{
					Format:   to.Ptr(armstreamanalytics.JSONOutputSerializationFormatLineSeparated),
					Encoding: to.Ptr(armstreamanalytics.EncodingUTF8),
				},
			},
		},
	}, &armstreamanalytics.OutputsClientUpdateOptions{IfMatch: 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.Output = armstreamanalytics.Output{
	// 	Name: to.Ptr("output5195"),
	// 	Type: to.Ptr("Microsoft.StreamAnalytics/streamingjobs/outputs"),
	// 	ID: to.Ptr("/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg6912/providers/Microsoft.StreamAnalytics/streamingjobs/sj3310/outputs/output5195"),
	// 	Properties: &armstreamanalytics.OutputProperties{
	// 		Datasource: &armstreamanalytics.AzureDataLakeStoreOutputDataSource{
	// 			Type: to.Ptr("Microsoft.DataLake/Accounts"),
	// 			Properties: &armstreamanalytics.AzureDataLakeStoreOutputDataSourceProperties{
	// 				TokenUserDisplayName: to.Ptr("Bob Smith"),
	// 				TokenUserPrincipalName: to.Ptr("bobsmith@contoso.com"),
	// 				AccountName: to.Ptr("differentaccount"),
	// 				DateFormat: to.Ptr("yyyy/MM/dd"),
	// 				FilePathPrefix: to.Ptr("{date}/{time}"),
	// 				TenantID: to.Ptr("cea4e98b-c798-49e7-8c40-4a2b3beb47dd"),
	// 				TimeFormat: to.Ptr("HH"),
	// 			},
	// 		},
	// 		Serialization: &armstreamanalytics.JSONSerialization{
	// 			Type: to.Ptr(armstreamanalytics.EventSerializationTypeJSON),
	// 			Properties: &armstreamanalytics.JSONSerializationProperties{
	// 				Format: to.Ptr(armstreamanalytics.JSONOutputSerializationFormatLineSeparated),
	// 				Encoding: to.Ptr(armstreamanalytics.EncodingUTF8),
	// 			},
	// 		},
	// 	},
	// }
}

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

JavaScript

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

/**
 * This sample demonstrates how to Updates an existing output under an existing streaming job. This can be used to partially update (ie. update one or two properties) an output without affecting the rest the job or output definition.
 *
 * @summary Updates an existing output under an existing streaming job. This can be used to partially update (ie. update one or two properties) an output without affecting the rest the job or output definition.
 * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Update_AzureDataLakeStore.json
 */
async function updateAnAzureDataLakeStoreOutputWithJsonSerialization() {
  const subscriptionId = "56b5e0a9-b645-407d-99b0-c64f86013e3d";
  const resourceGroupName = "sjrg6912";
  const jobName = "sj3310";
  const outputName = "output5195";
  const output = {
    datasource: {
      type: "Microsoft.DataLake/Accounts",
      accountName: "differentaccount",
    },
    serialization: { type: "Json", format: "LineSeparated", encoding: "UTF8" },
  };
  const credential = new DefaultAzureCredential();
  const client = new StreamAnalyticsManagementClient(credential, subscriptionId);
  const result = await client.outputs.update(resourceGroupName, jobName, outputName, output);
  console.log(result);
}

updateAnAzureDataLakeStoreOutputWithJsonSerialization().catch(console.error);

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

Sample Response

Status code:

200

ETag: 5020de6b-5bb3-4b88-8606-f11fb3c46185

Response Body

{
  "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg6912/providers/Microsoft.StreamAnalytics/streamingjobs/sj3310/outputs/output5195",
  "name": "output5195",
  "type": "Microsoft.StreamAnalytics/streamingjobs/outputs",
  "properties": {
    "datasource": {
      "type": "Microsoft.DataLake/Accounts",
      "properties": {
        "accountName": "differentaccount",
        "tenantId": "cea4e98b-c798-49e7-8c40-4a2b3beb47dd",
        "tokenUserPrincipalName": "bobsmith@contoso.com",
        "tokenUserDisplayName": "Bob Smith",
        "filePathPrefix": "{date}/{time}",
        "dateFormat": "yyyy/MM/dd",
        "timeFormat": "HH"
      }
    },
    "serialization": {
      "type": "Json",
      "properties": {
        "encoding": "UTF8",
        "format": "LineSeparated"
      }
    }
  }
}

Update an Azure Data Warehouse output

Sample Request

HTTP

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

{
  "properties": {
    "datasource": {
      "type": "Microsoft.Sql/Server/Database",
      "properties": {
        "table": "differentTable"
      }
    }
  }
}

Java

No code sample is available. To request a code sample, open a GitHub issue

Go

package armstreamanalytics_test

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/streamanalytics/armstreamanalytics"
)

// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/d55b8005f05b040b852c15e74a0f3e36494a15e1/specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Update_DataWarehouse.json
func ExampleOutputsClient_Update_updateAnAzureDataWarehouseOutput() {
	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.NewOutputsClient().Update(ctx, "sjrg", "sjName", "dwOutput", armstreamanalytics.Output{
		Properties: &armstreamanalytics.OutputProperties{
			Datasource: &armstreamanalytics.AzureSQLDatabaseOutputDataSource{
				Type: to.Ptr("Microsoft.Sql/Server/Database"),
				Properties: &armstreamanalytics.AzureSQLDatabaseOutputDataSourceProperties{
					Table: to.Ptr("differentTable"),
				},
			},
		},
	}, &armstreamanalytics.OutputsClientUpdateOptions{IfMatch: 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.Output = armstreamanalytics.Output{
	// 	Name: to.Ptr("dwOutput"),
	// 	Type: to.Ptr("Microsoft.StreamAnalytics/streamingjobs/outputs"),
	// 	ID: to.Ptr("/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/sjName/outputs/dwOutput"),
	// 	Properties: &armstreamanalytics.OutputProperties{
	// 		Datasource: &armstreamanalytics.AzureSynapseOutputDataSource{
	// 			Type: to.Ptr("Microsoft.Sql/Server/DataWarehouse"),
	// 			Properties: &armstreamanalytics.AzureSynapseOutputDataSourceProperties{
	// 				Database: to.Ptr("zhayaSQLpool"),
	// 				Server: to.Ptr("asatestserver"),
	// 				Table: to.Ptr("differentTable"),
	// 				User: to.Ptr("tolladmin"),
	// 			},
	// 		},
	// 	},
	// }
}

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

JavaScript

No code sample is available. To request a code sample, open a GitHub issue

Sample Response

Status code:

200

ETag: f489d6f3-fcd5-4bcb-b642-81e987ee16d6

Response Body

{
  "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/sjName/outputs/dwOutput",
  "name": "dwOutput",
  "type": "Microsoft.StreamAnalytics/streamingjobs/outputs",
  "properties": {
    "datasource": {
      "type": "Microsoft.Sql/Server/DataWarehouse",
      "properties": {
        "table": "differentTable",
        "server": "asatestserver",
        "database": "zhayaSQLpool",
        "user": "tolladmin"
      }
    }
  }
}

Update an Azure Function output

Sample Request

HTTP

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

{
  "properties": {
    "datasource": {
      "type": "Microsoft.AzureFunction",
      "properties": {
        "functionName": "differentFunctionName"
      }
    }
  }
}

Java

No code sample is available. To request a code sample, open a GitHub issue

Go

package armstreamanalytics_test

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/streamanalytics/armstreamanalytics"
)

// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/d55b8005f05b040b852c15e74a0f3e36494a15e1/specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Update_AzureFunction.json
func ExampleOutputsClient_Update_updateAnAzureFunctionOutput() {
	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.NewOutputsClient().Update(ctx, "sjrg", "sjName", "azureFunction1", armstreamanalytics.Output{
		Properties: &armstreamanalytics.OutputProperties{
			Datasource: &armstreamanalytics.AzureFunctionOutputDataSource{
				Type: to.Ptr("Microsoft.AzureFunction"),
				Properties: &armstreamanalytics.AzureFunctionOutputDataSourceProperties{
					FunctionName: to.Ptr("differentFunctionName"),
				},
			},
		},
	}, &armstreamanalytics.OutputsClientUpdateOptions{IfMatch: 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.Output = armstreamanalytics.Output{
	// 	Name: to.Ptr("azureFunction1"),
	// 	Type: to.Ptr("Microsoft.StreamAnalytics/streamingjobs/outputs"),
	// 	ID: to.Ptr("/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/sjName/outputs/azureFunction1"),
	// 	Properties: &armstreamanalytics.OutputProperties{
	// 		Datasource: &armstreamanalytics.AzureFunctionOutputDataSource{
	// 			Type: to.Ptr("Microsoft.AzureFunction"),
	// 			Properties: &armstreamanalytics.AzureFunctionOutputDataSourceProperties{
	// 				FunctionAppName: to.Ptr("functionappforasaautomation"),
	// 				FunctionName: to.Ptr("differentFunctionName"),
	// 				MaxBatchCount: to.Ptr[float32](100),
	// 				MaxBatchSize: to.Ptr[float32](256),
	// 			},
	// 		},
	// 	},
	// }
}

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

JavaScript

No code sample is available. To request a code sample, open a GitHub issue

Sample Response

Status code:

200

ETag: f489d6f3-fcd5-4bcb-b642-81e987ee16d6

Response Body

{
  "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg/providers/Microsoft.StreamAnalytics/streamingjobs/sjName/outputs/azureFunction1",
  "name": "azureFunction1",
  "type": "Microsoft.StreamAnalytics/streamingjobs/outputs",
  "properties": {
    "datasource": {
      "type": "Microsoft.AzureFunction",
      "properties": {
        "functionAppName": "functionappforasaautomation",
        "functionName": "differentFunctionName",
        "apiKey": null,
        "maxBatchSize": 256,
        "maxBatchCount": 100
      }
    }
  }
}

Update an Azure SQL database output

Sample Request

HTTP

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

{
  "properties": {
    "datasource": {
      "type": "Microsoft.Sql/Server/Database",
      "properties": {
        "table": "differentTable"
      }
    }
  }
}

Java

import com.azure.core.util.Context;
import com.azure.resourcemanager.streamanalytics.models.AzureSqlDatabaseOutputDataSource;
import com.azure.resourcemanager.streamanalytics.models.Output;

/** Samples for Outputs Update. */
public final class Main {
    /*
     * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Update_AzureSQL.json
     */
    /**
     * Sample code: Update an Azure SQL database output.
     *
     * @param manager Entry point to StreamAnalyticsManager.
     */
    public static void updateAnAzureSQLDatabaseOutput(
        com.azure.resourcemanager.streamanalytics.StreamAnalyticsManager manager) {
        Output resource =
            manager.outputs().getWithResponse("sjrg2157", "sj6458", "output1755", Context.NONE).getValue();
        resource.update().withDatasource(new AzureSqlDatabaseOutputDataSource()).apply();
    }
}

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

Go

package armstreamanalytics_test

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/streamanalytics/armstreamanalytics"
)

// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/d55b8005f05b040b852c15e74a0f3e36494a15e1/specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Update_AzureSQL.json
func ExampleOutputsClient_Update_updateAnAzureSqlDatabaseOutput() {
	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.NewOutputsClient().Update(ctx, "sjrg2157", "sj6458", "output1755", armstreamanalytics.Output{
		Properties: &armstreamanalytics.OutputProperties{
			Datasource: &armstreamanalytics.AzureSQLDatabaseOutputDataSource{
				Type: to.Ptr("Microsoft.Sql/Server/Database"),
				Properties: &armstreamanalytics.AzureSQLDatabaseOutputDataSourceProperties{
					Table: to.Ptr("differentTable"),
				},
			},
		},
	}, &armstreamanalytics.OutputsClientUpdateOptions{IfMatch: 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.Output = armstreamanalytics.Output{
	// 	Name: to.Ptr("output1755"),
	// 	Type: to.Ptr("Microsoft.StreamAnalytics/streamingjobs/outputs"),
	// 	ID: to.Ptr("/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg2157/providers/Microsoft.StreamAnalytics/streamingjobs/sj6458/outputs/output1755"),
	// 	Properties: &armstreamanalytics.OutputProperties{
	// 		Datasource: &armstreamanalytics.AzureSQLDatabaseOutputDataSource{
	// 			Type: to.Ptr("Microsoft.Sql/Server/Database"),
	// 			Properties: &armstreamanalytics.AzureSQLDatabaseOutputDataSourceProperties{
	// 				Database: to.Ptr("someDatabase"),
	// 				Server: to.Ptr("someServer"),
	// 				Table: to.Ptr("differentTable"),
	// 				User: to.Ptr("someUser"),
	// 			},
	// 		},
	// 	},
	// }
}

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

JavaScript

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

/**
 * This sample demonstrates how to Updates an existing output under an existing streaming job. This can be used to partially update (ie. update one or two properties) an output without affecting the rest the job or output definition.
 *
 * @summary Updates an existing output under an existing streaming job. This can be used to partially update (ie. update one or two properties) an output without affecting the rest the job or output definition.
 * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Update_AzureSQL.json
 */
async function updateAnAzureSqlDatabaseOutput() {
  const subscriptionId = "56b5e0a9-b645-407d-99b0-c64f86013e3d";
  const resourceGroupName = "sjrg2157";
  const jobName = "sj6458";
  const outputName = "output1755";
  const output = {
    datasource: {
      type: "Microsoft.Sql/Server/Database",
      table: "differentTable",
    },
  };
  const credential = new DefaultAzureCredential();
  const client = new StreamAnalyticsManagementClient(credential, subscriptionId);
  const result = await client.outputs.update(resourceGroupName, jobName, outputName, output);
  console.log(result);
}

updateAnAzureSqlDatabaseOutput().catch(console.error);

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

Sample Response

Status code:

200

ETag: f489d6f3-fcd5-4bcb-b642-81e987ee16d6

Response Body

{
  "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg2157/providers/Microsoft.StreamAnalytics/streamingjobs/sj6458/outputs/output1755",
  "name": "output1755",
  "type": "Microsoft.StreamAnalytics/streamingjobs/outputs",
  "properties": {
    "datasource": {
      "type": "Microsoft.Sql/Server/Database",
      "properties": {
        "server": "someServer",
        "database": "someDatabase",
        "table": "differentTable",
        "user": "someUser"
      }
    }
  }
}

Update an Azure Table output

Sample Request

HTTP

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

{
  "properties": {
    "datasource": {
      "type": "Microsoft.Storage/Table",
      "properties": {
        "partitionKey": "differentPartitionKey"
      }
    }
  }
}

Java

import com.azure.core.util.Context;
import com.azure.resourcemanager.streamanalytics.models.AzureTableOutputDataSource;
import com.azure.resourcemanager.streamanalytics.models.Output;

/** Samples for Outputs Update. */
public final class Main {
    /*
     * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Update_AzureTable.json
     */
    /**
     * Sample code: Update an Azure Table output.
     *
     * @param manager Entry point to StreamAnalyticsManager.
     */
    public static void updateAnAzureTableOutput(
        com.azure.resourcemanager.streamanalytics.StreamAnalyticsManager manager) {
        Output resource = manager.outputs().getWithResponse("sjrg5176", "sj2790", "output958", Context.NONE).getValue();
        resource
            .update()
            .withDatasource(new AzureTableOutputDataSource().withPartitionKey("differentPartitionKey"))
            .apply();
    }
}

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

Go

package armstreamanalytics_test

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/streamanalytics/armstreamanalytics"
)

// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/d55b8005f05b040b852c15e74a0f3e36494a15e1/specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Update_AzureTable.json
func ExampleOutputsClient_Update_updateAnAzureTableOutput() {
	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.NewOutputsClient().Update(ctx, "sjrg5176", "sj2790", "output958", armstreamanalytics.Output{
		Properties: &armstreamanalytics.OutputProperties{
			Datasource: &armstreamanalytics.AzureTableOutputDataSource{
				Type: to.Ptr("Microsoft.Storage/Table"),
				Properties: &armstreamanalytics.AzureTableOutputDataSourceProperties{
					PartitionKey: to.Ptr("differentPartitionKey"),
				},
			},
		},
	}, &armstreamanalytics.OutputsClientUpdateOptions{IfMatch: 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.Output = armstreamanalytics.Output{
	// 	Name: to.Ptr("output958"),
	// 	Type: to.Ptr("Microsoft.StreamAnalytics/streamingjobs/outputs"),
	// 	ID: to.Ptr("/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg5176/providers/Microsoft.StreamAnalytics/streamingjobs/sj2790/outputs/output958"),
	// 	Properties: &armstreamanalytics.OutputProperties{
	// 		Datasource: &armstreamanalytics.AzureTableOutputDataSource{
	// 			Type: to.Ptr("Microsoft.Storage/Table"),
	// 			Properties: &armstreamanalytics.AzureTableOutputDataSourceProperties{
	// 				AccountName: to.Ptr("someAccountName"),
	// 				BatchSize: to.Ptr[int32](25),
	// 				ColumnsToRemove: []*string{
	// 					to.Ptr("column1"),
	// 					to.Ptr("column2")},
	// 					PartitionKey: to.Ptr("differentPartitionKey"),
	// 					RowKey: to.Ptr("rowKey"),
	// 					Table: to.Ptr("samples"),
	// 				},
	// 			},
	// 		},
	// 	}
}

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

JavaScript

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

/**
 * This sample demonstrates how to Updates an existing output under an existing streaming job. This can be used to partially update (ie. update one or two properties) an output without affecting the rest the job or output definition.
 *
 * @summary Updates an existing output under an existing streaming job. This can be used to partially update (ie. update one or two properties) an output without affecting the rest the job or output definition.
 * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Update_AzureTable.json
 */
async function updateAnAzureTableOutput() {
  const subscriptionId = "56b5e0a9-b645-407d-99b0-c64f86013e3d";
  const resourceGroupName = "sjrg5176";
  const jobName = "sj2790";
  const outputName = "output958";
  const output = {
    datasource: {
      type: "Microsoft.Storage/Table",
      partitionKey: "differentPartitionKey",
    },
  };
  const credential = new DefaultAzureCredential();
  const client = new StreamAnalyticsManagementClient(credential, subscriptionId);
  const result = await client.outputs.update(resourceGroupName, jobName, outputName, output);
  console.log(result);
}

updateAnAzureTableOutput().catch(console.error);

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

Sample Response

Status code:

200

ETag: ea1d20bf-6cb3-40bc-bc7b-ec3a7fd5977e

Response Body

{
  "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg5176/providers/Microsoft.StreamAnalytics/streamingjobs/sj2790/outputs/output958",
  "name": "output958",
  "type": "Microsoft.StreamAnalytics/streamingjobs/outputs",
  "properties": {
    "datasource": {
      "type": "Microsoft.Storage/Table",
      "properties": {
        "accountName": "someAccountName",
        "table": "samples",
        "partitionKey": "differentPartitionKey",
        "rowKey": "rowKey",
        "columnsToRemove": [
          "column1",
          "column2"
        ],
        "batchSize": 25
      }
    }
  }
}

Update an Event Hub output with JSON serialization

Sample Request

HTTP

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

{
  "properties": {
    "datasource": {
      "type": "Microsoft.ServiceBus/EventHub",
      "properties": {
        "partitionKey": "differentPartitionKey"
      }
    },
    "serialization": {
      "type": "Json",
      "properties": {
        "encoding": "UTF8",
        "format": "LineSeparated"
      }
    }
  }
}

Java

import com.azure.core.util.Context;
import com.azure.resourcemanager.streamanalytics.models.Encoding;
import com.azure.resourcemanager.streamanalytics.models.EventHubOutputDataSource;
import com.azure.resourcemanager.streamanalytics.models.JsonOutputSerializationFormat;
import com.azure.resourcemanager.streamanalytics.models.JsonSerialization;
import com.azure.resourcemanager.streamanalytics.models.Output;

/** Samples for Outputs Update. */
public final class Main {
    /*
     * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Update_EventHub.json
     */
    /**
     * Sample code: Update an Event Hub output with JSON serialization.
     *
     * @param manager Entry point to StreamAnalyticsManager.
     */
    public static void updateAnEventHubOutputWithJSONSerialization(
        com.azure.resourcemanager.streamanalytics.StreamAnalyticsManager manager) {
        Output resource =
            manager.outputs().getWithResponse("sjrg6912", "sj3310", "output5195", Context.NONE).getValue();
        resource
            .update()
            .withDatasource(new EventHubOutputDataSource().withPartitionKey("differentPartitionKey"))
            .withSerialization(
                new JsonSerialization()
                    .withEncoding(Encoding.UTF8)
                    .withFormat(JsonOutputSerializationFormat.LINE_SEPARATED))
            .apply();
    }
}

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

Go

package armstreamanalytics_test

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/streamanalytics/armstreamanalytics"
)

// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/d55b8005f05b040b852c15e74a0f3e36494a15e1/specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Update_EventHub.json
func ExampleOutputsClient_Update_updateAnEventHubOutputWithJsonSerialization() {
	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.NewOutputsClient().Update(ctx, "sjrg6912", "sj3310", "output5195", armstreamanalytics.Output{
		Properties: &armstreamanalytics.OutputProperties{
			Datasource: &armstreamanalytics.EventHubOutputDataSource{
				Type: to.Ptr("Microsoft.ServiceBus/EventHub"),
				Properties: &armstreamanalytics.EventHubOutputDataSourceProperties{
					PartitionKey: to.Ptr("differentPartitionKey"),
				},
			},
			Serialization: &armstreamanalytics.JSONSerialization{
				Type: to.Ptr(armstreamanalytics.EventSerializationTypeJSON),
				Properties: &armstreamanalytics.JSONSerializationProperties{
					Format:   to.Ptr(armstreamanalytics.JSONOutputSerializationFormatLineSeparated),
					Encoding: to.Ptr(armstreamanalytics.EncodingUTF8),
				},
			},
		},
	}, &armstreamanalytics.OutputsClientUpdateOptions{IfMatch: 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.Output = armstreamanalytics.Output{
	// 	Name: to.Ptr("output5195"),
	// 	Type: to.Ptr("Microsoft.StreamAnalytics/streamingjobs/outputs"),
	// 	ID: to.Ptr("/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg6912/providers/Microsoft.StreamAnalytics/streamingjobs/sj3310/outputs/output5195"),
	// 	Properties: &armstreamanalytics.OutputProperties{
	// 		Datasource: &armstreamanalytics.EventHubOutputDataSource{
	// 			Type: to.Ptr("Microsoft.ServiceBus/EventHub"),
	// 			Properties: &armstreamanalytics.EventHubOutputDataSourceProperties{
	// 				ServiceBusNamespace: to.Ptr("sdktest"),
	// 				SharedAccessPolicyName: to.Ptr("RootManageSharedAccessKey"),
	// 				EventHubName: to.Ptr("sdkeventhub"),
	// 				PartitionKey: to.Ptr("differentPartitionKey"),
	// 			},
	// 		},
	// 		Serialization: &armstreamanalytics.JSONSerialization{
	// 			Type: to.Ptr(armstreamanalytics.EventSerializationTypeJSON),
	// 			Properties: &armstreamanalytics.JSONSerializationProperties{
	// 				Format: to.Ptr(armstreamanalytics.JSONOutputSerializationFormatLineSeparated),
	// 				Encoding: to.Ptr(armstreamanalytics.EncodingUTF8),
	// 			},
	// 		},
	// 	},
	// }
}

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

JavaScript

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

/**
 * This sample demonstrates how to Updates an existing output under an existing streaming job. This can be used to partially update (ie. update one or two properties) an output without affecting the rest the job or output definition.
 *
 * @summary Updates an existing output under an existing streaming job. This can be used to partially update (ie. update one or two properties) an output without affecting the rest the job or output definition.
 * x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Update_EventHub.json
 */
async function updateAnEventHubOutputWithJsonSerialization() {
  const subscriptionId = "56b5e0a9-b645-407d-99b0-c64f86013e3d";
  const resourceGroupName = "sjrg6912";
  const jobName = "sj3310";
  const outputName = "output5195";
  const output = {
    datasource: {
      type: "Microsoft.ServiceBus/EventHub",
      partitionKey: "differentPartitionKey",
    },
    serialization: { type: "Json", format: "LineSeparated", encoding: "UTF8" },
  };
  const credential = new DefaultAzureCredential();
  const client = new StreamAnalyticsManagementClient(credential, subscriptionId);
  const result = await client.outputs.update(resourceGroupName, jobName, outputName, output);
  console.log(result);
}

updateAnEventHubOutputWithJsonSerialization().catch(console.error);

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

Sample Response

Status code:

200

ETag: 5020de6b-5bb3-4b88-8606-f11fb3c46185

Response Body

{
  "id": "/subscriptions/56b5e0a9-b645-407d-99b0-c64f86013e3d/resourceGroups/sjrg6912/providers/Microsoft.StreamAnalytics/streamingjobs/sj3310/outputs/output5195",
  "name": "output5195",
  "type": "Microsoft.StreamAnalytics/streamingjobs/outputs",
  "properties": {
    "datasource": {
      "type": "Microsoft.ServiceBus/EventHub",
      "properties": {
        "eventHubName": "sdkeventhub",
        "partitionKey": "differentPartitionKey",
        "serviceBusNamespace": "sdktest",
        "sharedAccessPolicyName": "RootManageSharedAccessKey"
      }
    },
    "serialization": {
      "type": "Json",
      "properties": {
        "encoding": "UTF8",
        "format": "LineSeparated"
      }
    }
  }
}

정의

속성	Description
AuthenticationMode	인증 모드. 유효한 모드는 , Msi 및 'UserToken'입니다ConnectionString.
AvroSerialization	입력의 데이터가 직렬화되는 방법 또는 Avro 형식의 출력에 기록될 때 데이터가 serialize되는 방법을 설명합니다.
AzureDataLakeStoreOutputDataSource	Azure Data Lake Store 출력 데이터 원본에 대해 설명합니다.
AzureFunctionOutputDataSource	AzureFunctionOutputDataSource의 메타데이터를 정의합니다.
AzureSqlDatabaseOutputDataSource	Azure SQL 데이터베이스 출력 데이터 원본에 대해 설명합니다.
AzureSynapseOutputDataSource	Azure Synapse 출력 데이터 원본에 대해 설명합니다.
AzureTableOutputDataSource	Azure Table 출력 데이터 원본에 대해 설명합니다.
BlobOutputDataSource	Blob 출력 데이터 원본에 대해 설명합니다.
CsvSerialization	입력의 데이터가 직렬화되는 방법 또는 CSV 형식의 출력에 기록될 때 데이터가 serialize되는 방법을 설명합니다.
DiagnosticCondition	고객의 주의를 끌 수 있는 리소스 또는 전체 작업에 적용되는 조건입니다.
Diagnostics	고객의 주의를 끄는 입력, 출력 또는 전체 작업에 적용되는 조건에 대해 설명합니다.
DocumentDbOutputDataSource	DocumentDB 출력 데이터 원본에 대해 설명합니다.
Encoding	입력의 경우 들어오는 데이터의 인코딩 및 출력의 경우 나가는 데이터의 인코딩을 지정합니다.
Error	일반적인 오류 표현입니다.
EventHubOutputDataSource	이벤트 허브 출력 데이터 원본에 대해 설명합니다.
EventHubV2OutputDataSource	이벤트 허브 출력 데이터 원본에 대해 설명합니다.
EventSerializationType	입력 또는 출력에서 사용하는 serialization 유형을 나타냅니다. PUT(CreateOrReplace) 요청에 필요합니다.
GatewayMessageBusOutputDataSource	게이트웨이 Message Bus 출력 데이터 원본에 대해 설명합니다.
JsonOutputSerializationFormat	출력이 작성될 JSON의 형식을 지정합니다. 현재 지원되는 값은 각 JSON 개체를 새 줄로 구분하고 출력이 JSON 개체의 배열로 형식이 지정됨을 나타내는 'array'를 사용하여 출력의 형식을 지정함을 나타내는 'lineSeparated'입니다.
JsonSerialization	입력의 데이터가 직렬화되는 방법 또는 JSON 형식의 출력에 기록될 때 데이터가 serialize되는 방법을 설명합니다.
Output	명명된 출력과 연결된 모든 정보를 포함하는 출력 개체입니다. 모든 출력은 스트리밍 작업 아래에 포함됩니다.
ParquetSerialization	입력의 데이터가 직렬화되는 방법 또는 Parquet 형식의 출력에 기록될 때 데이터가 serialize되는 방법을 설명합니다.
PowerBIOutputDataSource	Power BI 출력 데이터 원본에 대해 설명합니다.
ServiceBusQueueOutputDataSource	Service Bus 큐 출력 데이터 원본에 대해 설명합니다.
ServiceBusTopicOutputDataSource	Service Bus 토픽 출력 데이터 원본에 대해 설명합니다.
StorageAccount	Azure Storage 계정과 연결된 속성

AuthenticationMode

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

속성	형식	Description
ConnectionString	string
Msi	string
UserToken	string

AvroSerialization

입력의 데이터가 직렬화되는 방법 또는 Avro 형식의 출력에 기록될 때 데이터가 serialize되는 방법을 설명합니다.

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

AzureDataLakeStoreOutputDataSource

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

속성	형식	기본값	Description
properties.accountName	string		Azure Data Lake Store 계정의 이름입니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.authenticationMode	AuthenticationMode	ConnectionString	인증 모드.
properties.dateFormat	string		날짜 형식입니다. {date}가 filePathPrefix에 표시되는 경우 이 속성의 값은 대신 날짜 형식으로 사용됩니다.
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의 메타데이터를 정의합니다.

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

AzureSqlDatabaseOutputDataSource

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

속성	형식	기본값	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 Server의 이름입니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.table	string		Azure SQL 데이터베이스에 있는 테이블의 이름입니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.user	string		Azure SQL 데이터베이스에 연결하는 데 사용할 사용자 이름입니다. PUT(CreateOrReplace) 요청에 필요합니다.
type	string: Microsoft.Sql/Server/Database		기록될 데이터 원본 출력의 형식을 나타냅니다. PUT(CreateOrReplace) 요청에 필요합니다.

AzureSynapseOutputDataSource

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

속성	형식	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 출력 데이터 원본에 대해 설명합니다.

속성	형식	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 출력 데이터 원본에 대해 설명합니다.

속성	형식	기본값	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) 요청에 필요합니다.

CsvSerialization

입력의 데이터가 직렬화되는 방법 또는 CSV 형식의 출력에 기록될 때 데이터가 serialize되는 방법을 설명합니다.

속성	형식	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

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

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

Diagnostics

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

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

DocumentDbOutputDataSource

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

속성	형식	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

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

속성	형식	Description
UTF8	string

Error

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

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

EventHubOutputDataSource

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

속성	형식	기본값	Description
authenticationMode	AuthenticationMode	ConnectionString	인증 모드.
properties.eventHubName	string		이벤트 허브의 이름입니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.partitionKey	string		이벤트 데이터를 보낼 파티션을 결정하는 데 사용되는 키/열입니다.
properties.propertyColumns	string[]		이 이벤트 허브 출력과 연결된 속성입니다.
serviceBusNamespace	string		원하는 Event Hub, 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

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

속성	형식	기본값	Description
authenticationMode	AuthenticationMode	ConnectionString	인증 모드.
properties.eventHubName	string		이벤트 허브의 이름입니다. PUT(CreateOrReplace) 요청에 필요합니다.
properties.partitionKey	string		이벤트 데이터를 보낼 파티션을 결정하는 데 사용되는 키/열입니다.
properties.propertyColumns	string[]		이 이벤트 허브 출력과 연결된 속성입니다.
serviceBusNamespace	string		원하는 Event Hub, 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) 요청에 필요합니다.

속성	형식	Description
Avro	string
Csv	string
Json	string
Parquet	string

GatewayMessageBusOutputDataSource

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

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

JsonOutputSerializationFormat

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

속성	형식	Description
Array	string
LineSeparated	string

JsonSerialization

입력의 데이터가 직렬화되는 방법 또는 JSON 형식의 출력에 기록될 때 데이터가 serialize되는 방법을 설명합니다.

속성	형식	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

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

속성	형식	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	리소스 유형

ParquetSerialization

입력의 데이터가 직렬화되는 방법 또는 Parquet 형식의 출력에 기록될 때 데이터가 serialize되는 방법을 설명합니다.

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

PowerBIOutputDataSource

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

속성	형식	기본값	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) 요청에 필요합니다.

ServiceBusQueueOutputDataSource

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

속성	형식	기본값	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 토픽 출력 데이터 원본에 대해 설명합니다.

속성	형식	기본값	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) 요청에 필요합니다.

StorageAccount

Azure Storage 계정과 연결된 속성

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