Var olan bir akış işinin altında var olan bir çıkışı Güncelleştirmeler. Bu, işi veya çıkış tanımını etkilemeden bir çıkışı kısmen güncelleştirmek (bir veya iki özelliği güncelleştirmek) için kullanılabilir.
PATCH https://management.azure.com/subscriptions/{subscriptionId}/resourcegroups/{resourceGroupName}/providers/Microsoft.StreamAnalytics/streamingjobs/{jobName}/outputs/{outputName}?api-version=2020-03-01
URI Parametreleri
Name |
İçinde |
Gerekli |
Tür |
Description |
jobName
|
path |
True
|
string
|
Akış işinin adı.
|
outputName
|
path |
True
|
string
|
Çıkışın adı.
|
resourceGroupName
|
path |
True
|
string
|
Kaynak grubunun adı. Ad büyük/küçük harfe duyarlı değildir.
Regex pattern: ^[-\w\._\(\)]+$
|
subscriptionId
|
path |
True
|
string
|
Hedef aboneliğin kimliği.
|
api-version
|
query |
True
|
string
|
Bu işlem için kullanılacak API sürümü.
|
Name |
Gerekli |
Tür |
Description |
If-Match
|
|
string
|
Çıkışın ETag'i. Geçerli çıkışın üzerine her zaman yazmak için bu değeri atla. Eş zamanlı değişikliklerin yanlışlıkla üzerine yazılmasını önlemek için son görülen ETag değerini belirtin.
|
İstek Gövdesi
Name |
Tür |
Description |
name
|
string
|
Kaynak adı
|
properties.datasource
|
OutputDataSource:
|
Çıktının yazılacağı veri kaynağını açıklar. PUT (CreateOrReplace) isteklerinde gereklidir.
|
properties.serialization
|
Serialization:
|
Girişten alınan verilerin nasıl serileştirildiği veya çıkışa yazıldığında verilerin nasıl seri hale getirildiği açıklanır. PUT (CreateOrReplace) isteklerinde gereklidir.
|
properties.sizeWindow
|
integer
|
Stream Analytics çıkışını kısıtlamak için boyut penceresi.
|
properties.timeWindow
|
string
|
Stream Analytics işi çıkışlarını filtrelemek için zaman çerçevesi.
|
Yanıtlar
Name |
Tür |
Description |
200 OK
|
Output
|
Çıkış başarıyla güncelleştirildi.
Headers
ETag: string
|
Other Status Codes
|
Error
|
Hata.
|
Güvenlik
azure_auth
Azure Active Directory OAuth2 Flow
Type:
oauth2
Flow:
implicit
Authorization URL:
https://login.microsoftonline.com/common/oauth2/authorize
Scopes
Name |
Description |
user_impersonation
|
kullanıcı hesabınızın kimliğine bürünme
|
Örnekler
Update a blob output with CSV serialization
Sample Request
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"
}
}
}
}
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
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
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
ETag: 3a1b2023-79a9-4b33-93e8-f49fc3e573fe
{
"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
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"
}
}
}
}
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
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
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
ETag: 7849c132-e995-4631-91c3-931606eec432
{
"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
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"
}
}
}
}
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
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
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
ETag: 7849c132-e995-4631-91c3-931606eec432
{
"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
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"
}
}
}
}
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
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
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
ETag: 429adaec-a777-4750-8a39-8d0c931d801c
{
"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
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"
}
}
}
}
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
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
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
ETag: c1c2007f-45b2-419a-ae7d-4d2148998460
{
"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
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"
}
}
}
}
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
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
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
ETag: 5020de6b-5bb3-4b88-8606-f11fb3c46185
{
"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
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"
}
}
}
}
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
Sample Response
ETag: f489d6f3-fcd5-4bcb-b642-81e987ee16d6
{
"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
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"
}
}
}
}
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
Sample Response
ETag: f489d6f3-fcd5-4bcb-b642-81e987ee16d6
{
"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
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"
}
}
}
}
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
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
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
ETag: f489d6f3-fcd5-4bcb-b642-81e987ee16d6
{
"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
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"
}
}
}
}
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
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
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
ETag: ea1d20bf-6cb3-40bc-bc7b-ec3a7fd5977e
{
"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
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"
}
}
}
}
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
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
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
ETag: 5020de6b-5bb3-4b88-8606-f11fb3c46185
{
"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"
}
}
}
}
Tanımlar
AuthenticationMode
Kimlik Doğrulama Modu. Geçerli modlar , Msi
ve 'UserToken'dırConnectionString
.
Name |
Tür |
Description |
ConnectionString
|
string
|
|
Msi
|
string
|
|
UserToken
|
string
|
|
AvroSerialization
Bir girişteki verilerin nasıl serileştirildiği veya Avro biçiminde bir çıkışa yazıldığında verilerin nasıl seri hale getirildiği açıklanır.
Name |
Tür |
Description |
type
|
string:
Avro
|
Girişin veya çıkışın kullandığı serileştirme türünü gösterir. PUT (CreateOrReplace) isteklerinde gereklidir.
|
AzureDataLakeStoreOutputDataSource
Azure Data Lake Store çıkış veri kaynağını açıklar.
Name |
Tür |
Varsayılan değer |
Description |
properties.accountName
|
string
|
|
Azure Data Lake Store hesabının adı. PUT (CreateOrReplace) isteklerinde gereklidir.
|
properties.authenticationMode
|
AuthenticationMode
|
ConnectionString
|
Kimlik Doğrulama Modu.
|
properties.dateFormat
|
string
|
|
Tarih biçimi. filePathPrefix'te {date} nerede görünüyorsa, bunun yerine bu özelliğin değeri tarih biçimi olarak kullanılır.
|
properties.filePathPrefix
|
string
|
|
Çıktının yazılması gereken dosyanın konumu. PUT (CreateOrReplace) isteklerinde gereklidir.
|
properties.refreshToken
|
string
|
|
Daha sonra veri kaynağıyla kimlik doğrulaması yapmak için kullanılabilecek geçerli bir erişim belirteci almak için kullanılabilecek bir yenileme belirteci. Geçerli bir yenileme belirteci şu anda yalnızca Azure Portal aracılığıyla edinilebilir. Veri kaynağını oluştururken ve ardından Azure Portal'a giderek bu özelliği geçerli bir yenileme belirteci ile güncelleştirecek olan veri kaynağının kimliğini doğrulamak için buraya sahte bir dize değeri koymanızı öneririz. PUT (CreateOrReplace) isteklerinde gereklidir.
|
properties.tenantId
|
string
|
|
Yenileme belirtecini almak için kullanılan kullanıcının kiracı kimliği. PUT (CreateOrReplace) isteklerinde gereklidir.
|
properties.timeFormat
|
string
|
|
Saat biçimi. filePathPrefix'te {time} nerede görünüyorsa, bunun yerine bu özelliğin değeri saat biçimi olarak kullanılır.
|
properties.tokenUserDisplayName
|
string
|
|
Yenileme belirtecini almak için kullanılan kullanıcının görünen adı. Yenileme belirtecini almak için hangi kullanıcının kullanıldığını hatırlamaya yardımcı olması için bu özelliği kullanın.
|
properties.tokenUserPrincipalName
|
string
|
|
Yenileme belirtecini almak için kullanılan kullanıcının kullanıcı asıl adı (UPN). Yenileme belirtecini almak için hangi kullanıcının kullanıldığını hatırlamaya yardımcı olması için bu özelliği kullanın.
|
type
|
string:
Microsoft.DataLake/Accounts
|
|
Veri kaynağı çıkışının yazılacağı türü gösterir. PUT (CreateOrReplace) isteklerinde gereklidir.
|
AzureFunctionOutputDataSource
AzureFunctionOutputDataSource meta verilerini tanımlar
Name |
Tür |
Description |
properties.apiKey
|
string
|
Başka bir abonelikten Bir Azure İşlevi kullanmak istiyorsanız, işlevinize erişmek için anahtarı sağlayarak bunu yapabilirsiniz.
|
properties.functionAppName
|
string
|
Azure İşlevleri uygulamanızın adı.
|
properties.functionName
|
string
|
Azure İşlevleri uygulamanızdaki işlevin adı.
|
properties.maxBatchCount
|
number
|
Azure İşlevleri gönderilen her toplu işte en fazla olay sayısını belirtmenize olanak tanıyan özellik. Varsayılan değer 100’dür.
|
properties.maxBatchSize
|
number
|
Azure işlevinize gönderilen her çıkış toplu işlemi için en büyük boyutu ayarlamanıza olanak tanıyan özellik. Giriş birimi bayt cinsindendir. Varsayılan olarak, bu değer 262.144 bayttır (256 KB).
|
type
|
string:
Microsoft.AzureFunction
|
Veri kaynağı çıkışının yazılacağı türü gösterir. PUT (CreateOrReplace) isteklerinde gereklidir.
|
AzureSqlDatabaseOutputDataSource
Azure SQL veritabanı çıkış veri kaynağını açıklar.
Name |
Tür |
Varsayılan değer |
Description |
properties.authenticationMode
|
AuthenticationMode
|
ConnectionString
|
Kimlik Doğrulama Modu.
|
properties.database
|
string
|
|
Azure SQL veritabanının adı. PUT (CreateOrReplace) isteklerinde gereklidir.
|
properties.maxBatchCount
|
number
|
|
Sql veritabanına yazma için maksimum Batch sayısı; varsayılan değer 10.000'dir. PUT isteklerinde isteğe bağlı.
|
properties.maxWriterCount
|
number
|
|
En Fazla Yazıcı sayısı; şu anda yalnızca 1 (tek yazıcı) ve 0 (sorgu bölümüne göre) kullanılabilir. PUT isteklerinde isteğe bağlı.
|
properties.password
|
string
|
|
Azure SQL veritabanına bağlanmak için kullanılacak parola. PUT (CreateOrReplace) isteklerinde gereklidir.
|
properties.server
|
string
|
|
Azure SQL veritabanını içeren SQL sunucusunun adı. PUT (CreateOrReplace) isteklerinde gereklidir.
|
properties.table
|
string
|
|
Azure SQL veritabanındaki tablonun adı. PUT (CreateOrReplace) isteklerinde gereklidir.
|
properties.user
|
string
|
|
Azure SQL veritabanına bağlanmak için kullanılacak kullanıcı adı. PUT (CreateOrReplace) isteklerinde gereklidir.
|
type
|
string:
Microsoft.Sql/Server/Database
|
|
Veri kaynağı çıkışının yazılacağı türü gösterir. PUT (CreateOrReplace) isteklerinde gereklidir.
|
AzureSynapseOutputDataSource
Azure Synapse çıktı veri kaynağını açıklar.
Name |
Tür |
Description |
properties.database
|
string
|
Azure SQL veritabanının adı. PUT (CreateOrReplace) isteklerinde gereklidir.
|
properties.password
|
string
|
Azure SQL veritabanına bağlanmak için kullanılacak parola. PUT (CreateOrReplace) isteklerinde gereklidir.
|
properties.server
|
string
|
Azure SQL veritabanını içeren SQL sunucusunun adı. PUT (CreateOrReplace) isteklerinde gereklidir.
|
properties.table
|
string
|
Azure SQL veritabanındaki tablonun adı. PUT (CreateOrReplace) isteklerinde gereklidir.
|
properties.user
|
string
|
Azure SQL veritabanına bağlanmak için kullanılacak kullanıcı adı. PUT (CreateOrReplace) isteklerinde gereklidir.
|
type
|
string:
Microsoft.Sql/Server/DataWarehouse
|
Veri kaynağı çıkışının yazılacağı türü gösterir. PUT (CreateOrReplace) isteklerinde gereklidir.
|
AzureTableOutputDataSource
Azure Tablosu çıkış veri kaynağını açıklar.
Name |
Tür |
Description |
properties.accountKey
|
string
|
Azure Depolama hesabının hesap anahtarı. PUT (CreateOrReplace) isteklerinde gereklidir.
|
properties.accountName
|
string
|
Azure Depolama hesabının adı. PUT (CreateOrReplace) isteklerinde gereklidir.
|
properties.batchSize
|
integer
|
Bir kerede Azure Tablosuna yazacak satır sayısı.
|
properties.columnsToRemove
|
string[]
|
Belirtilirse, dizideki her öğe çıkış olayı varlıklarından kaldırılacak (varsa) bir sütunun adıdır.
|
properties.partitionKey
|
string
|
Bu öğe, Azure Tablosu için bölüm anahtarı olarak kullanılacak sorgudaki SELECT deyiminden bir sütunun adını gösterir. PUT (CreateOrReplace) isteklerinde gereklidir.
|
properties.rowKey
|
string
|
Bu öğe, Sorgudaki SELECT deyiminden azure tablosu için satır anahtarı olarak kullanılacak sütunun adını gösterir. PUT (CreateOrReplace) isteklerinde gereklidir.
|
properties.table
|
string
|
Azure Tablosunun adı. PUT (CreateOrReplace) isteklerinde gereklidir.
|
type
|
string:
Microsoft.Storage/Table
|
Veri kaynağı çıkışının yazılacağı türü gösterir. PUT (CreateOrReplace) isteklerinde gereklidir.
|
BlobOutputDataSource
Blob çıktısı veri kaynağını açıklar.
Name |
Tür |
Varsayılan değer |
Description |
properties.authenticationMode
|
AuthenticationMode
|
ConnectionString
|
Kimlik Doğrulama Modu.
|
properties.blobPathPrefix
|
string
|
|
Blob yolu ön eki.
|
properties.container
|
string
|
|
İlişkili Depolama hesabı içindeki bir kapsayıcının adı. Bu kapsayıcı, okunacak veya yazılacak blobları içerir. PUT (CreateOrReplace) isteklerinde gereklidir.
|
properties.dateFormat
|
string
|
|
Tarih biçimi. pathPattern içinde {date} nerede görünürse görün, bunun yerine bu özelliğin değeri tarih biçimi olarak kullanılır.
|
properties.pathPattern
|
string
|
|
Blob yolu deseni. Normal bir ifade değil. Blob adlarının işe giriş veya çıkış olarak eklenip eklenmeyeceğini belirlemek için eşleştirileceği bir düzeni temsil eder. Daha ayrıntılı bir açıklama ve örnek için veya https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output bölümüne bakınhttps://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input.
|
properties.storageAccounts
|
StorageAccount[]
|
|
Bir veya daha fazla Azure Depolama hesabının listesi. PUT (CreateOrReplace) isteklerinde gereklidir.
|
properties.timeFormat
|
string
|
|
Saat biçimi. pathPattern içinde {time} nerede görünürse görünsin, bunun yerine bu özelliğin değeri saat biçimi olarak kullanılır.
|
type
|
string:
Microsoft.Storage/Blob
|
|
Veri kaynağı çıkışının yazılacağı türü gösterir. PUT (CreateOrReplace) isteklerinde gereklidir.
|
CsvSerialization
Girişteki verilerin nasıl serileştirildiği veya CSV biçiminde bir çıkışa yazıldığında verilerin nasıl seri hale getirildiği açıklanır.
DiagnosticCondition
Kaynak veya genel iş için geçerli olan ve müşteri dikkatini gerektiren koşul.
Name |
Tür |
Description |
code
|
string
|
Opak tanılama kodu.
|
message
|
string
|
Koşulu ayrıntılı olarak açıklayan, insanlar tarafından okunabilen ileti. İstemci isteğinin Accept-Language yerelleştirilmiş.
|
since
|
string
|
Koşulun ne zaman başladığının UTC zaman damgası. Müşteriler bu süre içinde ops günlüğünde ilgili bir olayı bulabilmelidir.
|
Diagnostics
Giriş, Çıkış veya işin tamamı için geçerli olan ve müşteri dikkatini gerektiren koşulları açıklar.
Name |
Tür |
Description |
conditions
|
DiagnosticCondition[]
|
Kaynak için veya genel iş için geçerli olan ve müşteri dikkatini gerektiren sıfır veya daha fazla koşul koleksiyonu.
|
DocumentDbOutputDataSource
DocumentDB çıkış veri kaynağını açıklar.
Name |
Tür |
Description |
properties.accountId
|
string
|
DocumentDB hesabı adı veya kimliği. PUT (CreateOrReplace) isteklerinde gereklidir.
|
properties.accountKey
|
string
|
DocumentDB hesabının hesap anahtarı. PUT (CreateOrReplace) isteklerinde gereklidir.
|
properties.collectionNamePattern
|
string
|
Kullanılacak koleksiyonlar için koleksiyon adı deseni. Koleksiyon adı biçimi, bölümlerin 0'dan başladığı isteğe bağlı {partition} belirteci kullanılarak oluşturulabilir. Daha fazla bilgi için belgenin https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output DocumentDB bölümüne bakın. PUT (CreateOrReplace) isteklerinde gereklidir.
|
properties.database
|
string
|
DocumentDB veritabanının adı. PUT (CreateOrReplace) isteklerinde gereklidir.
|
properties.documentId
|
string
|
Ekleme veya güncelleştirme işlemlerinin temel aldığı birincil anahtarı belirtmek için kullanılan çıkış olaylarındaki alanın adı.
|
properties.partitionKey
|
string
|
Çıktıyı koleksiyonlar arasında bölümleme anahtarını belirtmek için kullanılan çıkış olaylarındaki alanın adı. 'collectionNamePattern' {partition} belirtecini içeriyorsa, bu özelliğin belirtilmesi gerekir.
|
type
|
string:
Microsoft.Storage/DocumentDB
|
Veri kaynağı çıkışının yazılacağı türü gösterir. PUT (CreateOrReplace) isteklerinde gereklidir.
|
Encoding
Giriş durumunda gelen verilerin kodlamasını ve çıkış durumunda giden verilerin kodlamasını belirtir.
Name |
Tür |
Description |
UTF8
|
string
|
|
Error
Genel hata gösterimi.
Name |
Tür |
Description |
error
|
Error
|
Hata tanımı özellikleri.
|
EventHubOutputDataSource
Olay Hub'ı çıkış veri kaynağını açıklar.
Name |
Tür |
Varsayılan değer |
Description |
authenticationMode
|
AuthenticationMode
|
ConnectionString
|
Kimlik Doğrulama Modu.
|
properties.eventHubName
|
string
|
|
Olay Hub'ının adı. PUT (CreateOrReplace) isteklerinde gereklidir.
|
properties.partitionKey
|
string
|
|
Olay verilerinin hangi bölüme gönderileceğini belirlemek için kullanılan anahtar/sütun.
|
properties.propertyColumns
|
string[]
|
|
Bu Olay Hub'ı çıkışıyla ilişkili özellikler.
|
serviceBusNamespace
|
string
|
|
İstenen Olay Hub'ı, Service Bus Kuyruğu, Service Bus Konusu vb. ile ilişkilendirilmiş ad alanı. PUT (CreateOrReplace) isteklerinde gereklidir.
|
sharedAccessPolicyKey
|
string
|
|
Belirtilen paylaşılan erişim ilkesi için paylaşılan erişim ilkesi anahtarı. PUT (CreateOrReplace) isteklerinde gereklidir.
|
sharedAccessPolicyName
|
string
|
|
Olay Hub'ı, Service Bus Kuyruğu, Service Bus Konusu vb. için paylaşılan erişim ilkesi adı. PUT (CreateOrReplace) isteklerinde gereklidir.
|
type
|
string:
Microsoft.ServiceBus/EventHub
|
|
Veri kaynağı çıkışının yazılacağı türü gösterir. PUT (CreateOrReplace) isteklerinde gereklidir.
|
EventHubV2OutputDataSource
Olay Hub'ı çıkış veri kaynağını açıklar.
Name |
Tür |
Varsayılan değer |
Description |
authenticationMode
|
AuthenticationMode
|
ConnectionString
|
Kimlik Doğrulama Modu.
|
properties.eventHubName
|
string
|
|
Olay Hub'ının adı. PUT (CreateOrReplace) isteklerinde gereklidir.
|
properties.partitionKey
|
string
|
|
Olay verilerinin hangi bölüme gönderileceğini belirlemek için kullanılan anahtar/sütun.
|
properties.propertyColumns
|
string[]
|
|
Bu Olay Hub'ı çıkışıyla ilişkili özellikler.
|
serviceBusNamespace
|
string
|
|
İstenen Olay Hub'ı, Service Bus Kuyruğu, Service Bus Konusu vb. ile ilişkilendirilmiş ad alanı. PUT (CreateOrReplace) isteklerinde gereklidir.
|
sharedAccessPolicyKey
|
string
|
|
Belirtilen paylaşılan erişim ilkesi için paylaşılan erişim ilkesi anahtarı. PUT (CreateOrReplace) isteklerinde gereklidir.
|
sharedAccessPolicyName
|
string
|
|
Olay Hub'ı, Service Bus Kuyruğu, Service Bus Konusu vb. için paylaşılan erişim ilkesi adı. PUT (CreateOrReplace) isteklerinde gereklidir.
|
type
|
string:
Microsoft.EventHub/EventHub
|
|
Veri kaynağı çıkışının yazılacağı türü gösterir. PUT (CreateOrReplace) isteklerinde gereklidir.
|
EventSerializationType
Girişin veya çıkışın kullandığı serileştirme türünü gösterir. PUT (CreateOrReplace) isteklerinde gereklidir.
Name |
Tür |
Description |
Avro
|
string
|
|
Csv
|
string
|
|
Json
|
string
|
|
Parquet
|
string
|
|
GatewayMessageBusOutputDataSource
Ağ Geçidi İleti Veri Yolu çıkış veri kaynağını açıklar.
Name |
Tür |
Description |
properties.topic
|
string
|
Service Bus konusunun adı.
|
type
|
string:
GatewayMessageBus
|
Veri kaynağı çıkışının yazılacağı türü gösterir. PUT (CreateOrReplace) isteklerinde gereklidir.
|
Çıkışın yazılacağı JSON biçimini belirtir. Şu anda desteklenen değerler, çıkışın her JSON nesnesinin yeni bir satırla ayrılması ve çıkışın bir JSON nesneleri dizisi olarak biçimlendirileceğini belirten 'dizi' ile biçimlendirileceğini belirten 'lineSeparated' değerleridir.
Name |
Tür |
Description |
Array
|
string
|
|
LineSeparated
|
string
|
|
JsonSerialization
Bir girişteki verilerin nasıl serileştirildiği veya JSON biçiminde bir çıkışa yazıldığında verilerin nasıl seri hale getirildiği açıklanır.
Name |
Tür |
Description |
properties.encoding
|
Encoding
|
Giriş durumunda gelen verilerin kodlamasını ve çıkış durumunda giden verilerin kodlamasını belirtir. PUT (CreateOrReplace) isteklerinde gereklidir.
|
properties.format
|
JsonOutputSerializationFormat
|
Bu özellik yalnızca çıkışların JSON serileştirmesi için geçerlidir. Girişler için geçerli değildir. Bu özellik, çıkışın yazılacağı JSON biçimini belirtir. Şu anda desteklenen değerler, çıkışın her JSON nesnesinin yeni bir satırla ayrılması ve çıkışın bir JSON nesneleri dizisi olarak biçimlendirileceğini belirten 'dizi' ile biçimlendirileceğini belirten 'lineSeparated' değerleridir. Varsayılan değer null bırakılırsa 'lineSeparated' değeridir.
|
type
|
string:
Json
|
Girişin veya çıkışın kullandığı serileştirme türünü gösterir. PUT (CreateOrReplace) isteklerinde gereklidir.
|
Output
Adlandırılmış çıkışla ilişkili tüm bilgileri içeren bir çıkış nesnesi. Tüm çıkışlar bir akış işinin altında yer alır.
Name |
Tür |
Description |
id
|
string
|
Kaynak Kimliği
|
name
|
string
|
Kaynak adı
|
properties.datasource
|
OutputDataSource:
|
Çıktının yazılacağı veri kaynağını açıklar. PUT (CreateOrReplace) isteklerinde gereklidir.
|
properties.diagnostics
|
Diagnostics
|
Giriş, Çıkış veya işin tamamı için geçerli olan ve müşteri dikkatini gerektiren koşulları açıklar.
|
properties.etag
|
string
|
Çıkış için geçerli varlık etiketi. Bu, opak bir dizedir. Kaynağın istekler arasında değişip değişmediğini algılamak için bunu kullanabilirsiniz. İyimser eşzamanlılık için yazma işlemleri için If-Match veya If-None-Match üst bilgilerinde de kullanabilirsiniz.
|
properties.serialization
|
Serialization:
|
Girişten alınan verilerin nasıl serileştirildiği veya çıkışa yazıldığında verilerin nasıl seri hale getirildiği açıklanır. PUT (CreateOrReplace) isteklerinde gereklidir.
|
properties.sizeWindow
|
integer
|
Stream Analytics çıkışını kısıtlamak için boyut penceresi.
|
properties.timeWindow
|
string
|
Stream Analytics işi çıkışlarını filtrelemek için zaman çerçevesi.
|
type
|
string
|
Kaynak türü
|
ParquetSerialization
Girişteki verilerin nasıl seri hale getirildiği veya Parquet biçiminde bir çıkışa yazıldığında verilerin nasıl seri hale getirildiği açıklanır.
Name |
Tür |
Description |
type
|
string:
Parquet
|
Girişin veya çıkışın kullandığı serileştirme türünü gösterir. PUT (CreateOrReplace) isteklerinde gereklidir.
|
PowerBIOutputDataSource
Power BI çıkış veri kaynağını açıklar.
Name |
Tür |
Varsayılan değer |
Description |
properties.authenticationMode
|
AuthenticationMode
|
ConnectionString
|
Kimlik Doğrulama Modu.
|
properties.dataset
|
string
|
|
Power BI veri kümesinin adı. PUT (CreateOrReplace) isteklerinde gereklidir.
|
properties.groupId
|
string
|
|
Power BI grubunun kimliği.
|
properties.groupName
|
string
|
|
Power BI grubunun adı. Hangi Power BI grup kimliğinin kullanıldığını hatırlamaya yardımcı olması için bu özelliği kullanın.
|
properties.refreshToken
|
string
|
|
Daha sonra veri kaynağıyla kimlik doğrulaması yapmak için kullanılabilecek geçerli bir erişim belirteci almak için kullanılabilecek bir yenileme belirteci. Geçerli bir yenileme belirteci şu anda yalnızca Azure Portal aracılığıyla edinilebilir. Veri kaynağını oluştururken ve ardından Azure Portal'a giderek bu özelliği geçerli bir yenileme belirteci ile güncelleştirecek olan veri kaynağının kimliğini doğrulamak için buraya sahte bir dize değeri koymanızı öneririz. PUT (CreateOrReplace) isteklerinde gereklidir.
|
properties.table
|
string
|
|
Belirtilen veri kümesinin altındaki Power BI tablosunun adı. PUT (CreateOrReplace) isteklerinde gereklidir.
|
properties.tokenUserDisplayName
|
string
|
|
Yenileme belirtecini almak için kullanılan kullanıcının görünen adı. Yenileme belirtecini almak için hangi kullanıcının kullanıldığını hatırlamaya yardımcı olması için bu özelliği kullanın.
|
properties.tokenUserPrincipalName
|
string
|
|
Yenileme belirtecini almak için kullanılan kullanıcının kullanıcı asıl adı (UPN). Yenileme belirtecini almak için hangi kullanıcının kullanıldığını hatırlamaya yardımcı olması için bu özelliği kullanın.
|
type
|
string:
PowerBI
|
|
Veri kaynağı çıkışının yazılacağı türü gösterir. PUT (CreateOrReplace) isteklerinde gereklidir.
|
ServiceBusQueueOutputDataSource
Service Bus Kuyruğu çıkış veri kaynağını açıklar.
Name |
Tür |
Varsayılan değer |
Description |
properties.authenticationMode
|
AuthenticationMode
|
ConnectionString
|
Kimlik Doğrulama Modu.
|
properties.propertyColumns
|
string[]
|
|
Service Bus iletilerine özel özellikler olarak eklenecek çıkış sütunlarının adlarını içeren bir dize dizisi.
|
properties.queueName
|
string
|
|
Service Bus Kuyruğunun adı. PUT (CreateOrReplace) isteklerinde gereklidir.
|
properties.serviceBusNamespace
|
string
|
|
İstenen Olay Hub'ı, Service Bus Kuyruğu, Service Bus Konusu vb. ile ilişkilendirilmiş ad alanı. PUT (CreateOrReplace) isteklerinde gereklidir.
|
properties.sharedAccessPolicyKey
|
string
|
|
Belirtilen paylaşılan erişim ilkesi için paylaşılan erişim ilkesi anahtarı. PUT (CreateOrReplace) isteklerinde gereklidir.
|
properties.sharedAccessPolicyName
|
string
|
|
Olay Hub'ı, Service Bus Kuyruğu, Service Bus Konusu vb. için paylaşılan erişim ilkesi adı. PUT (CreateOrReplace) isteklerinde gereklidir.
|
properties.systemPropertyColumns
|
object
|
|
Service Bus Kuyruğu ile ilişkili sistem özellikleri. Aşağıdaki sistem özellikleri desteklenir: ReplyToSessionId, ContentType, To, Subject, CorrelationId, TimeToLive, PartitionKey, SessionId, ScheduledEnqueueTime, MessageId, ReplyTo, Label, ScheduledEnqueueTimeUtc.
|
type
|
string:
Microsoft.ServiceBus/Queue
|
|
Veri kaynağı çıkışının yazılacağı türü gösterir. PUT (CreateOrReplace) isteklerinde gereklidir.
|
ServiceBusTopicOutputDataSource
Service Bus Konusu çıkış veri kaynağını açıklar.
Name |
Tür |
Varsayılan değer |
Description |
properties.authenticationMode
|
AuthenticationMode
|
ConnectionString
|
Kimlik Doğrulama Modu.
|
properties.propertyColumns
|
string[]
|
|
Service Bus iletilerine özel özellikler olarak eklenecek çıkış sütunlarının adlarını içeren bir dize dizisi.
|
properties.serviceBusNamespace
|
string
|
|
İstenen Olay Hub'ı, Service Bus Kuyruğu, Service Bus Konusu vb. ile ilişkilendirilmiş ad alanı. PUT (CreateOrReplace) isteklerinde gereklidir.
|
properties.sharedAccessPolicyKey
|
string
|
|
Belirtilen paylaşılan erişim ilkesi için paylaşılan erişim ilkesi anahtarı. PUT (CreateOrReplace) isteklerinde gereklidir.
|
properties.sharedAccessPolicyName
|
string
|
|
Olay Hub'ı, Service Bus Kuyruğu, Service Bus Konusu vb. için paylaşılan erişim ilkesi adı. PUT (CreateOrReplace) isteklerinde gereklidir.
|
properties.systemPropertyColumns
|
object
|
|
Service Bus Konu Çıkışı ile ilişkili sistem özellikleri. Aşağıdaki sistem özellikleri desteklenir: ReplyToSessionId, ContentType, To, Subject, CorrelationId, TimeToLive, PartitionKey, SessionId, ScheduledEnqueueTime, MessageId, ReplyTo, Label, ScheduledEnqueueTimeUtc.
|
properties.topicName
|
string
|
|
Service Bus Konusunun adı. PUT (CreateOrReplace) isteklerinde gereklidir.
|
type
|
string:
Microsoft.ServiceBus/Topic
|
|
Veri kaynağı çıkışının yazılacağı türü gösterir. PUT (CreateOrReplace) isteklerinde gereklidir.
|
StorageAccount
Azure Depolama hesabıyla ilişkili özellikler
Name |
Tür |
Description |
accountKey
|
string
|
Azure Depolama hesabının hesap anahtarı. PUT (CreateOrReplace) isteklerinde gereklidir.
|
accountName
|
string
|
Azure Depolama hesabının adı. PUT (CreateOrReplace) isteklerinde gereklidir.
|