Aktualizace existující výstup v rámci existující úlohy streamování. To lze použít k částečné aktualizaci (tj. aktualizace jedné nebo dvou vlastností) výstupu, aniž by to mělo vliv na zbytek úlohy nebo definice výstupu.
PATCH https://management.azure.com/subscriptions/{subscriptionId}/resourcegroups/{resourceGroupName}/providers/Microsoft.StreamAnalytics/streamingjobs/{jobName}/outputs/{outputName}?api-version=2020-03-01
Parametry identifikátoru URI
Name |
V |
Vyžadováno |
Typ |
Description |
jobName
|
path |
True
|
string
|
Název úlohy streamování.
|
outputName
|
path |
True
|
string
|
Název výstupu.
|
resourceGroupName
|
path |
True
|
string
|
Název skupiny prostředků. V názvu se rozlišují malá a velká písmena.
Regex pattern: ^[-\w\._\(\)]+$
|
subscriptionId
|
path |
True
|
string
|
ID cílového předplatného.
|
api-version
|
query |
True
|
string
|
Verze rozhraní API, která se má použít pro tuto operaci.
|
Name |
Vyžadováno |
Typ |
Description |
If-Match
|
|
string
|
Značka ETag výstupu. Vynechání této hodnoty vždy přepíše aktuální výstup. Zadejte naposledy zobrazenou hodnotu značky ETag, abyste zabránili náhodnému přepsání souběžných změn.
|
Text požadavku
Name |
Typ |
Description |
name
|
string
|
Název prostředku
|
properties.datasource
|
OutputDataSource:
|
Popisuje zdroj dat, do kterého se bude výstup zapisovat. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
properties.serialization
|
Serialization:
|
Popisuje, jak jsou data ze vstupu serializována nebo jak jsou data serializována při zápisu do výstupu. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
properties.sizeWindow
|
integer
|
Okno velikosti, na které se má výstup Stream Analytics omezit.
|
properties.timeWindow
|
string
|
Časový rámec pro filtrování výstupů úloh Stream Analytics
|
Odpovědi
Name |
Typ |
Description |
200 OK
|
Output
|
Výstup se úspěšně aktualizoval.
Headers
ETag: string
|
Other Status Codes
|
Error
|
Chyba
|
Zabezpečení
azure_auth
Tok Azure Active Directory OAuth2
Type:
oauth2
Flow:
implicit
Authorization URL:
https://login.microsoftonline.com/common/oauth2/authorize
Scopes
Name |
Description |
user_impersonation
|
zosobnění uživatelského účtu
|
Příklady
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"
}
}
}
}
Definice
Name |
Description |
AuthenticationMode
|
Režim ověřování. Platné režimy jsou ConnectionString , Msi a 'UserToken'.
|
AvroSerialization
|
Popisuje, jak jsou data ze vstupu serializována nebo jak jsou data serializována při zápisu do výstupu ve formátu Avro.
|
AzureDataLakeStoreOutputDataSource
|
Popisuje výstupní zdroj dat Azure Data Lake Store.
|
AzureFunctionOutputDataSource
|
Definuje metadata azureFunctionOutputDataSource.
|
AzureSqlDatabaseOutputDataSource
|
Popisuje výstupní zdroj dat Azure SQL databáze.
|
AzureSynapseOutputDataSource
|
Popisuje Azure Synapse výstupní zdroj dat.
|
AzureTableOutputDataSource
|
Popisuje výstupní zdroj dat Tabulky Azure.
|
BlobOutputDataSource
|
Popisuje výstupní zdroj dat objektu blob.
|
CsvSerialization
|
Popisuje, jak jsou data ze vstupu serializována nebo jak jsou data serializována při zápisu do výstupu ve formátu CSV.
|
DiagnosticCondition
|
Podmínka vztahující se na prostředek nebo celkovou úlohu, která si zaslouží pozornost zákazníka.
|
Diagnostics
|
Popisuje podmínky vztahující se na vstup, výstup nebo celkovou úlohu, které vyžadují pozornost zákazníka.
|
DocumentDbOutputDataSource
|
Popisuje výstupní zdroj dat DocumentDB.
|
Encoding
|
Určuje kódování příchozích dat v případě vstupu a kódování odchozích dat v případě výstupu.
|
Error
|
Běžná reprezentace chyb
|
EventHubOutputDataSource
|
Popisuje výstupní zdroj dat centra událostí.
|
EventHubV2OutputDataSource
|
Popisuje výstupní zdroj dat centra událostí.
|
EventSerializationType
|
Označuje typ serializace, který používá vstup nebo výstup. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
GatewayMessageBusOutputDataSource
|
Popisuje výstupní zdroj dat sběrnice zpráv brány.
|
JsonOutputSerializationFormat
|
Určuje formát JSON, ve kterém se bude výstup zapisovat. Aktuálně podporované hodnoty jsou lineSeparated, což znamená, že výstup bude formátován tak, že každý objekt JSON bude oddělený novým řádkem a pole, které označuje, že výstup bude formátován jako pole objektů JSON.
|
JsonSerialization
|
Popisuje, jak se serializují data ze vstupu nebo jak se data serializují při zápisu do výstupu ve formátu JSON.
|
Output
|
Výstupní objekt obsahující všechny informace spojené s pojmenovaným výstupem. Všechny výstupy jsou obsaženy v rámci úlohy streamování.
|
ParquetSerialization
|
Popisuje, jak jsou data ze vstupu serializována nebo jak jsou data serializována při zápisu do výstupu ve formátu Parquet.
|
PowerBIOutputDataSource
|
Popisuje výstupní zdroj dat Power BI.
|
ServiceBusQueueOutputDataSource
|
Popisuje výstupní zdroj dat fronty služby Service Bus.
|
ServiceBusTopicOutputDataSource
|
Popisuje výstupní zdroj dat tématu služby Service Bus.
|
StorageAccount
|
Vlastnosti přidružené k účtu služby Azure Storage
|
AuthenticationMode
Režim ověřování. Platné režimy jsou ConnectionString
, Msi
a 'UserToken'.
Name |
Typ |
Description |
ConnectionString
|
string
|
|
Msi
|
string
|
|
UserToken
|
string
|
|
AvroSerialization
Popisuje, jak jsou data ze vstupu serializována nebo jak jsou data serializována při zápisu do výstupu ve formátu Avro.
Name |
Typ |
Description |
type
|
string:
Avro
|
Označuje typ serializace, který používá vstup nebo výstup. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
AzureDataLakeStoreOutputDataSource
Popisuje výstupní zdroj dat Azure Data Lake Store.
Name |
Typ |
Výchozí hodnota |
Description |
properties.accountName
|
string
|
|
Název účtu Azure Data Lake Store. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
properties.authenticationMode
|
AuthenticationMode
|
ConnectionString
|
Režim ověřování.
|
properties.dateFormat
|
string
|
|
Formát data. Kdykoli se {date} zobrazí v parametru filePathPrefix, použije se jako formát data hodnota této vlastnosti.
|
properties.filePathPrefix
|
string
|
|
Umístění souboru, do kterého má být výstup zapsán. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
properties.refreshToken
|
string
|
|
Obnovovací token, který lze použít k získání platného přístupového tokenu, který pak lze použít k ověření zdroje dat. Platný obnovovací token je v současné době možné získat pouze prostřednictvím webu Azure Portal. Při vytváření zdroje dat a následném přechodu na web Azure Portal k ověření zdroje dat doporučujeme vložit fiktivní hodnotu řetězce, čímž se tato vlastnost aktualizuje platným obnovovacím tokenem. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
properties.tenantId
|
string
|
|
ID tenanta uživatele použitého k získání obnovovacího tokenu Vyžaduje se u požadavků PUT (CreateOrReplace).
|
properties.timeFormat
|
string
|
|
Formát času. Kdykoli se {time} zobrazí v parametru filePathPrefix, použije se jako formát času hodnota této vlastnosti.
|
properties.tokenUserDisplayName
|
string
|
|
Zobrazované jméno uživatele, který byl použit k získání obnovovacího tokenu. Tato vlastnost vám pomůže zapamatovat si, který uživatel byl použit k získání obnovovacího tokenu.
|
properties.tokenUserPrincipalName
|
string
|
|
Hlavní název uživatele (UPN) uživatele, který byl použit k získání obnovovacího tokenu. Tato vlastnost vám pomůže zapamatovat si, který uživatel byl použit k získání obnovovacího tokenu.
|
type
|
string:
Microsoft.DataLake/Accounts
|
|
Označuje typ výstupu zdroje dat, do které se bude zapisovat. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
AzureFunctionOutputDataSource
Definuje metadata azureFunctionOutputDataSource.
Name |
Typ |
Description |
properties.apiKey
|
string
|
Pokud chcete použít funkci Azure Functions z jiného předplatného, můžete to udělat tak, že zadáte klíč pro přístup k funkci.
|
properties.functionAppName
|
string
|
Název aplikace Azure Functions.
|
properties.functionName
|
string
|
Název funkce v aplikaci Azure Functions.
|
properties.maxBatchCount
|
number
|
Vlastnost, která umožňuje zadat maximální počet událostí v každé dávce odesílané do Azure Functions. Výchozí hodnota je 100.
|
properties.maxBatchSize
|
number
|
Vlastnost, která umožňuje nastavit maximální velikost pro každou výstupní dávku odesílanou do funkce Azure. Vstupní jednotka je v bajtech. Ve výchozím nastavení je tato hodnota 262 144 bajtů (256 kB).
|
type
|
string:
Microsoft.AzureFunction
|
Označuje typ výstupu zdroje dat, do které se bude zapisovat. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
AzureSqlDatabaseOutputDataSource
Popisuje výstupní zdroj dat Azure SQL databáze.
Name |
Typ |
Výchozí hodnota |
Description |
properties.authenticationMode
|
AuthenticationMode
|
ConnectionString
|
Režim ověřování.
|
properties.database
|
string
|
|
Název databáze Azure SQL. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
properties.maxBatchCount
|
number
|
|
Maximální počet dávek pro zápis do databáze SQL, výchozí hodnota je 10 000. Volitelné u požadavků PUT.
|
properties.maxWriterCount
|
number
|
|
Maximální počet zapisovačů, aktuálně je k dispozici pouze 1 (jeden zapisovač) a 0 (na základě oddílu dotazu). Volitelné u požadavků PUT.
|
properties.password
|
string
|
|
Heslo, které se použije pro připojení k databázi Azure SQL. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
properties.server
|
string
|
|
Název serveru SQL obsahujícího databázi Azure SQL. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
properties.table
|
string
|
|
Název tabulky v databázi Azure SQL. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
properties.user
|
string
|
|
Uživatelské jméno, které se použije pro připojení k databázi Azure SQL. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
type
|
string:
Microsoft.Sql/Server/Database
|
|
Označuje typ výstupu zdroje dat, do které bude zapsán. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
AzureSynapseOutputDataSource
Popisuje Azure Synapse výstupní zdroj dat.
Name |
Typ |
Description |
properties.database
|
string
|
Název databáze Azure SQL. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
properties.password
|
string
|
Heslo, které se použije pro připojení k databázi Azure SQL. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
properties.server
|
string
|
Název serveru SQL obsahujícího databázi Azure SQL. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
properties.table
|
string
|
Název tabulky v databázi Azure SQL. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
properties.user
|
string
|
Uživatelské jméno, které se použije pro připojení k databázi Azure SQL. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
type
|
string:
Microsoft.Sql/Server/DataWarehouse
|
Označuje typ výstupu zdroje dat, do které bude zapsán. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
AzureTableOutputDataSource
Popisuje výstupní zdroj dat Tabulky Azure.
Name |
Typ |
Description |
properties.accountKey
|
string
|
Klíč účtu pro účet Služby Azure Storage. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
properties.accountName
|
string
|
Název účtu služby Azure Storage. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
properties.batchSize
|
integer
|
Počet řádků, které se mají zapisovat do tabulky Azure najednou.
|
properties.columnsToRemove
|
string[]
|
Pokud je tato položka zadána, každá položka v poli je názvem sloupce, který se má z výstupních entit událostí odebrat (pokud je k dispozici).
|
properties.partitionKey
|
string
|
Tento element označuje název sloupce z příkazu SELECT v dotazu, který se použije jako klíč oddílu pro tabulku Azure. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
properties.rowKey
|
string
|
Tento element označuje název sloupce z příkazu SELECT v dotazu, který se použije jako klíč řádku pro tabulku Azure. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
properties.table
|
string
|
Název tabulky Azure. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
type
|
string:
Microsoft.Storage/Table
|
Označuje typ výstupu zdroje dat, do které bude zapsán. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
BlobOutputDataSource
Popisuje výstupní zdroj dat objektu blob.
Name |
Typ |
Výchozí hodnota |
Description |
properties.authenticationMode
|
AuthenticationMode
|
ConnectionString
|
Režim ověřování.
|
properties.blobPathPrefix
|
string
|
|
Předpona cesty k objektu blob.
|
properties.container
|
string
|
|
Název kontejneru v rámci přidruženého účtu úložiště. Tento kontejner obsahuje objekty blob, ze které se mají číst, nebo do které se zapisuje. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
properties.dateFormat
|
string
|
|
Formát data. Kdykoli se {date} zobrazí v pathPattern, použije se jako formát data hodnota této vlastnosti.
|
properties.pathPattern
|
string
|
|
Vzor cesty k objektu blob. Nejedná se o regulární výraz. Představuje vzor, podle kterého se názvy objektů blob budou shodovat, aby bylo možné určit, jestli se mají zahrnout jako vstup nebo výstup do úlohy. Podrobnější vysvětlení a příklad najdete https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input v tématu nebo https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output .
|
properties.storageAccounts
|
StorageAccount[]
|
|
Seznam jednoho nebo více účtů Azure Storage. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
properties.timeFormat
|
string
|
|
Formát času. Kdykoli se {time} zobrazí v pathPattern, použije se jako formát času hodnota této vlastnosti.
|
type
|
string:
Microsoft.Storage/Blob
|
|
Označuje typ výstupu zdroje dat, do které bude zapsán. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
CsvSerialization
Popisuje, jak jsou data ze vstupu serializována nebo jak jsou data serializována při zápisu do výstupu ve formátu CSV.
DiagnosticCondition
Podmínka vztahující se na prostředek nebo celkovou úlohu, která si zaslouží pozornost zákazníka.
Name |
Typ |
Description |
code
|
string
|
Neprůžný diagnostický kód.
|
message
|
string
|
Zpráva čitelná pro člověka, která podrobně popisuje podmínku. Lokalizované v Accept-Language požadavku klienta.
|
since
|
string
|
Časové razítko UTC, kdy byla podmínka spuštěna. Zákazníci by měli být schopni najít odpovídající událost v provozním protokolu přibližně v této době.
|
Diagnostics
Popisuje podmínky vztahující se na vstup, výstup nebo celkovou úlohu, které vyžadují pozornost zákazníka.
Name |
Typ |
Description |
conditions
|
DiagnosticCondition[]
|
Kolekce nulových nebo více podmínek vztahujících se na prostředek nebo na celkovou úlohu, které vyžadují pozornost zákazníka.
|
DocumentDbOutputDataSource
Popisuje výstupní zdroj dat DocumentDB.
Name |
Typ |
Description |
properties.accountId
|
string
|
Název nebo ID účtu DocumentDB. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
properties.accountKey
|
string
|
Klíč účtu DocumentDB. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
properties.collectionNamePattern
|
string
|
Vzor názvu kolekce pro kolekce, které se mají použít. Formát názvu kolekce je možné vytvořit pomocí volitelného tokenu {partition}, kde oddíly začínají hodnotou 0. Další informace najdete v části DocumentDB v souboru https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output . Vyžaduje se u požadavků PUT (CreateOrReplace).
|
properties.database
|
string
|
Název databáze DocumentDB. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
properties.documentId
|
string
|
Název pole ve výstupních událostech, které slouží k určení primárního klíče, na kterém jsou založeny operace vložení nebo aktualizace.
|
properties.partitionKey
|
string
|
Název pole ve výstupních událostech, které slouží k určení klíče pro dělení výstupu mezi kolekcemi. Pokud collectionNamePattern obsahuje token {partition}, je nutné zadat tuto vlastnost.
|
type
|
string:
Microsoft.Storage/DocumentDB
|
Označuje typ výstupu zdroje dat, do které se bude zapisovat. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
Encoding
Určuje kódování příchozích dat v případě vstupu a kódování odchozích dat v případě výstupu.
Name |
Typ |
Description |
UTF8
|
string
|
|
Error
Běžná reprezentace chyb
Name |
Typ |
Description |
error
|
Error
|
Vlastnosti definice chyby.
|
EventHubOutputDataSource
Popisuje výstupní zdroj dat centra událostí.
Name |
Typ |
Výchozí hodnota |
Description |
authenticationMode
|
AuthenticationMode
|
ConnectionString
|
Režim ověřování.
|
properties.eventHubName
|
string
|
|
Název centra událostí. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
properties.partitionKey
|
string
|
|
Klíč/sloupec, který se používá k určení oddílu, do kterého se mají odesílat data událostí.
|
properties.propertyColumns
|
string[]
|
|
Vlastnosti přidružené k tomuto výstupu centra událostí.
|
serviceBusNamespace
|
string
|
|
Obor názvů přidružený k požadovanému centru událostí, frontě služby Service Bus, tématu služby Service Bus atd. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
sharedAccessPolicyKey
|
string
|
|
Klíč zásad sdíleného přístupu pro zadané zásady sdíleného přístupu. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
sharedAccessPolicyName
|
string
|
|
Název zásad sdíleného přístupu pro centrum událostí, frontu služby Service Bus, téma služby Service Bus atd. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
type
|
string:
Microsoft.ServiceBus/EventHub
|
|
Označuje typ výstupu zdroje dat, do které bude zapsán. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
EventHubV2OutputDataSource
Popisuje výstupní zdroj dat centra událostí.
Name |
Typ |
Výchozí hodnota |
Description |
authenticationMode
|
AuthenticationMode
|
ConnectionString
|
Režim ověřování.
|
properties.eventHubName
|
string
|
|
Název centra událostí. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
properties.partitionKey
|
string
|
|
Klíč/sloupec, který se používá k určení oddílu, do kterého se mají odesílat data událostí.
|
properties.propertyColumns
|
string[]
|
|
Vlastnosti přidružené k tomuto výstupu centra událostí.
|
serviceBusNamespace
|
string
|
|
Obor názvů přidružený k požadovanému centru událostí, frontě služby Service Bus, tématu služby Service Bus atd. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
sharedAccessPolicyKey
|
string
|
|
Klíč zásad sdíleného přístupu pro zadané zásady sdíleného přístupu. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
sharedAccessPolicyName
|
string
|
|
Název zásad sdíleného přístupu pro centrum událostí, frontu služby Service Bus, téma služby Service Bus atd. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
type
|
string:
Microsoft.EventHub/EventHub
|
|
Označuje typ výstupu zdroje dat, do které bude zapsán. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
EventSerializationType
Označuje typ serializace, který používá vstup nebo výstup. Vyžaduje se u požadavků PUT (CreateOrReplace).
Name |
Typ |
Description |
Avro
|
string
|
|
Csv
|
string
|
|
Json
|
string
|
|
Parquet
|
string
|
|
GatewayMessageBusOutputDataSource
Popisuje výstupní zdroj dat sběrnice zpráv brány.
Name |
Typ |
Description |
properties.topic
|
string
|
Název tématu služby Service Bus.
|
type
|
string:
GatewayMessageBus
|
Označuje typ výstupu zdroje dat, do které se bude zapisovat. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
Určuje formát JSON, ve kterém se bude výstup zapisovat. Aktuálně podporované hodnoty jsou lineSeparated, což znamená, že výstup bude formátován tak, že každý objekt JSON bude oddělený novým řádkem a pole, které označuje, že výstup bude formátován jako pole objektů JSON.
Name |
Typ |
Description |
Array
|
string
|
|
LineSeparated
|
string
|
|
JsonSerialization
Popisuje, jak se serializují data ze vstupu nebo jak se data serializují při zápisu do výstupu ve formátu JSON.
Name |
Typ |
Description |
properties.encoding
|
Encoding
|
Určuje kódování příchozích dat v případě vstupu a kódování odchozích dat v případě výstupu. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
properties.format
|
JsonOutputSerializationFormat
|
Tato vlastnost se vztahuje pouze na serializaci výstupů JSON. Nevztahuje se na vstupy. Tato vlastnost určuje formát JSON, ve kterém se bude výstup zapisovat. Aktuálně podporované hodnoty jsou lineSeparated, což znamená, že výstup bude formátován tak, že každý objekt JSON bude oddělený novým řádkem a pole, které označuje, že výstup bude formátován jako pole objektů JSON. Výchozí hodnota je lineSeparated, pokud je vlevo null.
|
type
|
string:
Json
|
Označuje typ serializace, který používá vstup nebo výstup. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
Output
Výstupní objekt obsahující všechny informace spojené s pojmenovaným výstupem. Všechny výstupy jsou obsaženy v rámci úlohy streamování.
Name |
Typ |
Description |
id
|
string
|
ID prostředku
|
name
|
string
|
Název prostředku
|
properties.datasource
|
OutputDataSource:
|
Popisuje zdroj dat, do kterého bude výstup zapsán. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
properties.diagnostics
|
Diagnostics
|
Popisuje podmínky vztahující se na vstup, výstup nebo celkovou úlohu, které vyžadují pozornost zákazníka.
|
properties.etag
|
string
|
Aktuální značka entity pro výstup. Jedná se o neprůsvný řetězec. Můžete ho použít ke zjištění, jestli se prostředek mezi požadavky změnil. Můžete ho také použít v hlavičce If-Match nebo If-None-Match pro operace zápisu pro zajištění optimistické souběžnosti.
|
properties.serialization
|
Serialization:
|
Popisuje, jak jsou data ze vstupu serializována nebo jak jsou data serializována při zápisu do výstupu. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
properties.sizeWindow
|
integer
|
Okno velikosti, na které se má výstup Stream Analytics omezit.
|
properties.timeWindow
|
string
|
Časový rámec pro filtrování výstupů úloh Stream Analytics
|
type
|
string
|
Typ prostředku
|
ParquetSerialization
Popisuje, jak jsou data ze vstupu serializována nebo jak jsou data serializována při zápisu do výstupu ve formátu Parquet.
Name |
Typ |
Description |
type
|
string:
Parquet
|
Označuje typ serializace, který používá vstup nebo výstup. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
PowerBIOutputDataSource
Popisuje výstupní zdroj dat Power BI.
Name |
Typ |
Výchozí hodnota |
Description |
properties.authenticationMode
|
AuthenticationMode
|
ConnectionString
|
Režim ověřování.
|
properties.dataset
|
string
|
|
Název datové sady Power BI. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
properties.groupId
|
string
|
|
ID skupiny Power BI.
|
properties.groupName
|
string
|
|
Název skupiny Power BI. Tato vlastnost vám pomůže zapamatovat si, jaké konkrétní ID skupiny Power BI jste použili.
|
properties.refreshToken
|
string
|
|
Obnovovací token, který lze použít k získání platného přístupového tokenu, který pak lze použít k ověření zdroje dat. Platný obnovovací token je v současné době možné získat pouze prostřednictvím webu Azure Portal. Při vytváření zdroje dat a následném přechodu na web Azure Portal k ověření zdroje dat doporučujeme vložit fiktivní hodnotu řetězce, čímž se tato vlastnost aktualizuje platným obnovovacím tokenem. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
properties.table
|
string
|
|
Název tabulky Power BI v zadané datové sadě. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
properties.tokenUserDisplayName
|
string
|
|
Zobrazované jméno uživatele, který byl použit k získání obnovovacího tokenu. Tato vlastnost vám pomůže zapamatovat si, který uživatel byl použit k získání obnovovacího tokenu.
|
properties.tokenUserPrincipalName
|
string
|
|
Hlavní název uživatele (UPN) uživatele, který byl použit k získání obnovovacího tokenu. Tato vlastnost vám pomůže zapamatovat si, který uživatel byl použit k získání obnovovacího tokenu.
|
type
|
string:
PowerBI
|
|
Označuje typ výstupu zdroje dat, do které se bude zapisovat. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
ServiceBusQueueOutputDataSource
Popisuje výstupní zdroj dat fronty služby Service Bus.
Name |
Typ |
Výchozí hodnota |
Description |
properties.authenticationMode
|
AuthenticationMode
|
ConnectionString
|
Režim ověřování.
|
properties.propertyColumns
|
string[]
|
|
Pole řetězců názvů výstupních sloupců, které mají být připojeny ke zprávě služby Service Bus jako vlastní vlastnosti.
|
properties.queueName
|
string
|
|
Název fronty služby Service Bus. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
properties.serviceBusNamespace
|
string
|
|
Obor názvů přidružený k požadovanému centru událostí, frontě služby Service Bus, tématu služby Service Bus atd. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
properties.sharedAccessPolicyKey
|
string
|
|
Klíč zásad sdíleného přístupu pro zadanou zásadu sdíleného přístupu. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
properties.sharedAccessPolicyName
|
string
|
|
Název zásady sdíleného přístupu pro centrum událostí, frontu služby Service Bus, téma služby Service Bus atd. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
properties.systemPropertyColumns
|
object
|
|
Systémové vlastnosti přidružené k frontě služby Service Bus. Podporují se následující systémové vlastnosti: ReplyToSessionId, ContentType, To, Subject, CorrelationId, TimeToLive, PartitionKey, SessionId, ScheduledEnqueueTime, MessageId, ReplyTo, Label, ScheduledEnqueueTimeUtc.
|
type
|
string:
Microsoft.ServiceBus/Queue
|
|
Označuje typ výstupu zdroje dat, do které se bude zapisovat. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
ServiceBusTopicOutputDataSource
Popisuje výstupní zdroj dat tématu služby Service Bus.
Name |
Typ |
Výchozí hodnota |
Description |
properties.authenticationMode
|
AuthenticationMode
|
ConnectionString
|
Režim ověřování.
|
properties.propertyColumns
|
string[]
|
|
Pole řetězců názvů výstupních sloupců, které mají být připojeny ke zprávě služby Service Bus jako vlastní vlastnosti.
|
properties.serviceBusNamespace
|
string
|
|
Obor názvů přidružený k požadovanému centru událostí, frontě služby Service Bus, tématu služby Service Bus atd. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
properties.sharedAccessPolicyKey
|
string
|
|
Klíč zásad sdíleného přístupu pro zadanou zásadu sdíleného přístupu. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
properties.sharedAccessPolicyName
|
string
|
|
Název zásady sdíleného přístupu pro centrum událostí, frontu služby Service Bus, téma služby Service Bus atd. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
properties.systemPropertyColumns
|
object
|
|
Systémové vlastnosti přidružené k výstupu tématu služby Service Bus. Podporují se následující systémové vlastnosti: ReplyToSessionId, ContentType, To, Subject, CorrelationId, TimeToLive, PartitionKey, SessionId, ScheduledEnqueueTime, MessageId, ReplyTo, Label, ScheduledEnqueueTimeUtc.
|
properties.topicName
|
string
|
|
Název tématu služby Service Bus. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
type
|
string:
Microsoft.ServiceBus/Topic
|
|
Označuje typ výstupu zdroje dat, do které se bude zapisovat. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
StorageAccount
Vlastnosti přidružené k účtu služby Azure Storage
Name |
Typ |
Description |
accountKey
|
string
|
Klíč účtu pro účet služby Azure Storage. Vyžaduje se u požadavků PUT (CreateOrReplace).
|
accountName
|
string
|
Název účtu služby Azure Storage. Vyžaduje se u požadavků PUT (CreateOrReplace).
|