Aktualizacje istniejące dane wyjściowe w ramach istniejącego zadania przesyłania strumieniowego. Może to służyć do częściowej aktualizacji (tj. zaktualizowania jednej lub dwóch właściwości) danych wyjściowych bez wpływu na pozostałą część zadania lub definicję danych wyjściowych.
PATCH https://management.azure.com/subscriptions/{subscriptionId}/resourcegroups/{resourceGroupName}/providers/Microsoft.StreamAnalytics/streamingjobs/{jobName}/outputs/{outputName}?api-version=2020-03-01
Parametry identyfikatora URI
Nazwa |
W |
Wymagane |
Typ |
Opis |
jobName
|
path |
True
|
string
|
Nazwa zadania przesyłania strumieniowego.
|
outputName
|
path |
True
|
string
|
Nazwa danych wyjściowych.
|
resourceGroupName
|
path |
True
|
string
|
Nazwa grupy zasobów. W nazwie jest uwzględniana wielkość liter.
Regex pattern: ^[-\w\._\(\)]+$
|
subscriptionId
|
path |
True
|
string
|
Identyfikator subskrypcji docelowej.
|
api-version
|
query |
True
|
string
|
Wersja interfejsu API do użycia dla tej operacji.
|
Nazwa |
Wymagane |
Typ |
Opis |
If-Match
|
|
string
|
Element ETag danych wyjściowych. Pomiń tę wartość, aby zawsze zastąpić bieżące dane wyjściowe. Określ ostatnio widzianą wartość elementu ETag, aby zapobiec przypadkowemu zastępowaniu współbieżnych zmian.
|
Treść żądania
Nazwa |
Typ |
Opis |
name
|
string
|
Nazwa zasobu
|
properties.datasource
|
OutputDataSource:
|
Opisuje źródło danych, do którego zostaną zapisane dane wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).
|
properties.serialization
|
Serialization:
|
Opisuje, jak dane z danych wejściowych są serializowane lub jak dane są serializowane podczas zapisywania w danych wyjściowych. Wymagane w żądaniach PUT (CreateOrReplace).
|
properties.sizeWindow
|
integer
|
Okno rozmiaru ograniczające dane wyjściowe usługi Stream Analytics.
|
properties.timeWindow
|
string
|
Przedział czasu filtrowania danych wyjściowych zadania usługi Stream Analytics.
|
Odpowiedzi
Nazwa |
Typ |
Opis |
200 OK
|
Output
|
Dane wyjściowe zostały pomyślnie zaktualizowane.
Headers
ETag: string
|
Other Status Codes
|
Error
|
Błąd.
|
Zabezpieczenia
azure_auth
Przepływ OAuth2 usługi Azure Active Directory
Type:
oauth2
Flow:
implicit
Authorization URL:
https://login.microsoftonline.com/common/oauth2/authorize
Scopes
Nazwa |
Opis |
user_impersonation
|
personifikacja konta użytkownika
|
Przykłady
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"
}
}
}
}
Definicje
Nazwa |
Opis |
AuthenticationMode
|
Tryb uwierzytelniania. Prawidłowe tryby to ConnectionString , Msi i "UserToken".
|
AvroSerialization
|
Opisuje sposób serializacji danych wejściowych lub serializacji danych podczas zapisywania ich w danych wyjściowych w formacie Avro.
|
AzureDataLakeStoreOutputDataSource
|
Opisuje wyjściowe źródło danych usługi Azure Data Lake Store.
|
AzureFunctionOutputDataSource
|
Definiuje metadane elementu AzureFunctionOutputDataSource
|
AzureSqlDatabaseOutputDataSource
|
Opisuje Azure SQL wyjściowe źródło danych bazy danych.
|
AzureSynapseOutputDataSource
|
Opisuje Azure Synapse wyjściowe źródło danych.
|
AzureTableOutputDataSource
|
Opisuje źródło danych wyjściowych tabeli platformy Azure.
|
BlobOutputDataSource
|
Opisuje źródło danych wyjściowych obiektu blob.
|
CsvSerialization
|
Opisuje sposób serializacji danych wejściowych lub serializacji danych podczas zapisywania ich w danych wyjściowych w formacie CSV.
|
DiagnosticCondition
|
Warunek mający zastosowanie do zasobu lub ogólnego zadania, który gwarantuje uwagę klienta.
|
Diagnostics
|
Opisuje warunki mające zastosowanie do danych wejściowych, wyjściowych lub ogólnego zadania, które uzasadniają uwagę klienta.
|
DocumentDbOutputDataSource
|
Opisuje źródło danych wyjściowych usługi DocumentDB.
|
Encoding
|
Określa kodowanie danych przychodzących w przypadku danych wejściowych i kodowanie danych wychodzących w przypadku danych wyjściowych.
|
Error
|
Reprezentacja typowych błędów.
|
EventHubOutputDataSource
|
Opisuje wyjściowe źródło danych centrum zdarzeń.
|
EventHubV2OutputDataSource
|
Opisuje wyjściowe źródło danych centrum zdarzeń.
|
EventSerializationType
|
Wskazuje typ serializacji używanej przez dane wejściowe lub wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).
|
GatewayMessageBusOutputDataSource
|
Opisuje źródło danych wyjściowych magistrali komunikatów bramy.
|
JsonOutputSerializationFormat
|
Określa format JSON, w który będą zapisywane dane wyjściowe. Obecnie obsługiwane wartości to "lineSeparated", co wskazuje, że dane wyjściowe będą formatowane przez każdy obiekt JSON oddzielony przez nowy wiersz i tablicę wskazującą, że dane wyjściowe będą formatowane jako tablica obiektów JSON.
|
JsonSerialization
|
Opisuje sposób serializacji danych wejściowych lub serializacji danych podczas zapisywania ich w danych wyjściowych w formacie JSON.
|
Output
|
Obiekt wyjściowy zawierający wszystkie informacje skojarzone z nazwanymi danymi wyjściowymi. Wszystkie dane wyjściowe są zawarte w zadaniu przesyłania strumieniowego.
|
ParquetSerialization
|
Opisuje sposób serializacji danych wejściowych lub serializacji danych podczas zapisywania ich w danych wyjściowych w formacie Parquet.
|
PowerBIOutputDataSource
|
Opisuje źródło danych wyjściowych usługi Power BI.
|
ServiceBusQueueOutputDataSource
|
Opisuje źródło danych wyjściowych kolejki usługi Service Bus.
|
ServiceBusTopicOutputDataSource
|
Opisuje źródło danych wyjściowych tematu usługi Service Bus.
|
StorageAccount
|
Właściwości skojarzone z kontem usługi Azure Storage
|
AuthenticationMode
Tryb uwierzytelniania. Prawidłowe tryby to ConnectionString
, Msi
i "UserToken".
Nazwa |
Typ |
Opis |
ConnectionString
|
string
|
|
Msi
|
string
|
|
UserToken
|
string
|
|
AvroSerialization
Opisuje sposób serializacji danych wejściowych lub serializacji danych podczas zapisywania ich w danych wyjściowych w formacie Avro.
Nazwa |
Typ |
Opis |
type
|
string:
Avro
|
Wskazuje typ serializacji używanej przez dane wejściowe lub wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).
|
AzureDataLakeStoreOutputDataSource
Opisuje wyjściowe źródło danych usługi Azure Data Lake Store.
Nazwa |
Typ |
Wartość domyślna |
Opis |
properties.accountName
|
string
|
|
Nazwa konta usługi Azure Data Lake Store. Wymagane w żądaniach PUT (CreateOrReplace).
|
properties.authenticationMode
|
AuthenticationMode
|
ConnectionString
|
Tryb uwierzytelniania.
|
properties.dateFormat
|
string
|
|
Format daty. Gdziekolwiek {date} pojawia się w filePathPrefix, wartość tej właściwości jest używana jako format daty.
|
properties.filePathPrefix
|
string
|
|
Lokalizacja pliku, do którego powinny zostać zapisane dane wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).
|
properties.refreshToken
|
string
|
|
Token odświeżania, którego można użyć do uzyskania prawidłowego tokenu dostępu, którego następnie można użyć do uwierzytelniania w źródle danych. Prawidłowy token odświeżania można obecnie uzyskać tylko za pośrednictwem witryny Azure Portal. Zaleca się umieszczenie w tym miejscu fikcyjnej wartości ciągu podczas tworzenia źródła danych, a następnie przejście do witryny Azure Portal w celu uwierzytelnienia źródła danych, które zaktualizuje tę właściwość przy użyciu prawidłowego tokenu odświeżania. Wymagane w żądaniach PUT (CreateOrReplace).
|
properties.tenantId
|
string
|
|
Identyfikator dzierżawy użytkownika używany do uzyskiwania tokenu odświeżania. Wymagane w żądaniach PUT (CreateOrReplace).
|
properties.timeFormat
|
string
|
|
Format godziny. Gdziekolwiek {time} pojawia się w filePathPrefix, wartość tej właściwości jest używana jako format czasu.
|
properties.tokenUserDisplayName
|
string
|
|
Nazwa wyświetlana użytkownika, który został użyty do uzyskania tokenu odświeżania. Użyj tej właściwości, aby zapamiętać, którego użytkownika użyto do uzyskania tokenu odświeżania.
|
properties.tokenUserPrincipalName
|
string
|
|
Główna nazwa użytkownika (UPN) użytkownika, który został użyty do uzyskania tokenu odświeżania. Użyj tej właściwości, aby zapamiętać, którego użytkownika użyto do uzyskania tokenu odświeżania.
|
type
|
string:
Microsoft.DataLake/Accounts
|
|
Wskazuje typ danych wyjściowych źródła danych, w których zostaną zapisane dane wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).
|
AzureFunctionOutputDataSource
Definiuje metadane elementu AzureFunctionOutputDataSource
Nazwa |
Typ |
Opis |
properties.apiKey
|
string
|
Jeśli chcesz użyć funkcji platformy Azure z innej subskrypcji, możesz to zrobić, podając klucz dostępu do funkcji.
|
properties.functionAppName
|
string
|
Nazwa aplikacji Azure Functions.
|
properties.functionName
|
string
|
Nazwa funkcji w aplikacji Azure Functions.
|
properties.maxBatchCount
|
number
|
Właściwość umożliwiająca określenie maksymalnej liczby zdarzeń w każdej partii wysyłanej do Azure Functions. Wartość domyślna to 100.
|
properties.maxBatchSize
|
number
|
Właściwość, która umożliwia ustawienie maksymalnego rozmiaru dla każdej partii wyjściowej wysyłanej do funkcji platformy Azure. Jednostka wejściowa jest wyrażona w bajtach. Domyślnie ta wartość to 262 144 bajtów (256 KB).
|
type
|
string:
Microsoft.AzureFunction
|
Wskazuje typ danych wyjściowych źródła danych, w których zostaną zapisane dane wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).
|
AzureSqlDatabaseOutputDataSource
Opisuje Azure SQL wyjściowe źródło danych bazy danych.
Nazwa |
Typ |
Wartość domyślna |
Opis |
properties.authenticationMode
|
AuthenticationMode
|
ConnectionString
|
Tryb uwierzytelniania.
|
properties.database
|
string
|
|
Nazwa bazy danych Azure SQL. Wymagane w żądaniach PUT (CreateOrReplace).
|
properties.maxBatchCount
|
number
|
|
Maksymalna liczba partii do zapisu w bazie danych Sql. Wartość domyślna to 10 000. Opcjonalnie w żądaniach PUT.
|
properties.maxWriterCount
|
number
|
|
Maksymalna liczba składników zapisywania, obecnie dostępne są tylko 1(pojedynczy moduł zapisujący) i 0 (na podstawie partycji zapytania). Opcjonalnie w żądaniach PUT.
|
properties.password
|
string
|
|
Hasło, które będzie używane do nawiązywania połączenia z bazą danych Azure SQL. Wymagane w żądaniach PUT (CreateOrReplace).
|
properties.server
|
string
|
|
Nazwa serwera SQL zawierającego bazę danych Azure SQL. Wymagane w żądaniach PUT (CreateOrReplace).
|
properties.table
|
string
|
|
Nazwa tabeli w bazie danych Azure SQL. Wymagane w żądaniach PUT (CreateOrReplace).
|
properties.user
|
string
|
|
Nazwa użytkownika, która będzie używana do nawiązywania połączenia z bazą danych Azure SQL. Wymagane w żądaniach PUT (CreateOrReplace).
|
type
|
string:
Microsoft.Sql/Server/Database
|
|
Wskazuje typ danych wyjściowych źródła danych, w których zostaną zapisane dane wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).
|
AzureSynapseOutputDataSource
Opisuje Azure Synapse wyjściowe źródło danych.
Nazwa |
Typ |
Opis |
properties.database
|
string
|
Nazwa bazy danych Azure SQL. Wymagane w żądaniach PUT (CreateOrReplace).
|
properties.password
|
string
|
Hasło, które będzie używane do nawiązywania połączenia z bazą danych Azure SQL. Wymagane w żądaniach PUT (CreateOrReplace).
|
properties.server
|
string
|
Nazwa serwera SQL zawierającego bazę danych Azure SQL. Wymagane w żądaniach PUT (CreateOrReplace).
|
properties.table
|
string
|
Nazwa tabeli w bazie danych Azure SQL. Wymagane w żądaniach PUT (CreateOrReplace).
|
properties.user
|
string
|
Nazwa użytkownika, która będzie używana do nawiązywania połączenia z bazą danych Azure SQL. Wymagane w żądaniach PUT (CreateOrReplace).
|
type
|
string:
Microsoft.Sql/Server/DataWarehouse
|
Wskazuje typ danych wyjściowych źródła danych, w których zostaną zapisane dane wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).
|
AzureTableOutputDataSource
Opisuje źródło danych wyjściowych tabeli platformy Azure.
Nazwa |
Typ |
Opis |
properties.accountKey
|
string
|
Klucz konta dla konta usługi Azure Storage. Wymagane w żądaniach PUT (CreateOrReplace).
|
properties.accountName
|
string
|
Nazwa konta usługi Azure Storage. Wymagane w żądaniach PUT (CreateOrReplace).
|
properties.batchSize
|
integer
|
Liczba wierszy do zapisania w tabeli platformy Azure jednocześnie.
|
properties.columnsToRemove
|
string[]
|
Jeśli zostanie określony, każdy element w tablicy jest nazwą kolumny do usunięcia (jeśli istnieje) z wyjściowych jednostek zdarzeń.
|
properties.partitionKey
|
string
|
Ten element wskazuje nazwę kolumny z instrukcji SELECT w zapytaniu, które będzie używane jako klucz partycji dla tabeli platformy Azure. Wymagane w żądaniach PUT (CreateOrReplace).
|
properties.rowKey
|
string
|
Ten element wskazuje nazwę kolumny z instrukcji SELECT w zapytaniu, które będzie używane jako klucz wiersza dla tabeli platformy Azure. Wymagane w żądaniach PUT (CreateOrReplace).
|
properties.table
|
string
|
Nazwa tabeli platformy Azure. Wymagane w żądaniach PUT (CreateOrReplace).
|
type
|
string:
Microsoft.Storage/Table
|
Wskazuje typ danych wyjściowych źródła danych, w których zostaną zapisane dane wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).
|
BlobOutputDataSource
Opisuje źródło danych wyjściowych obiektu blob.
Nazwa |
Typ |
Wartość domyślna |
Opis |
properties.authenticationMode
|
AuthenticationMode
|
ConnectionString
|
Tryb uwierzytelniania.
|
properties.blobPathPrefix
|
string
|
|
Prefiks ścieżki obiektu blob.
|
properties.container
|
string
|
|
Nazwa kontenera w ramach skojarzonego konta magazynu. Ten kontener zawiera obiekty blob do odczytu lub zapisu. Wymagane w żądaniach PUT (CreateOrReplace).
|
properties.dateFormat
|
string
|
|
Format daty. Gdziekolwiek {date} pojawia się w pathPattern, wartość tej właściwości jest używana jako format daty.
|
properties.pathPattern
|
string
|
|
Wzorzec ścieżki obiektu blob. Nie jest wyrażeniem regularnym. Reprezentuje wzorzec, względem którego nazwy obiektów blob będą dopasowywane w celu określenia, czy powinny one być uwzględniane jako dane wejściowe lub wyjściowe zadania. Zobacz https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-input lub https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output , aby uzyskać bardziej szczegółowe wyjaśnienie i przykład.
|
properties.storageAccounts
|
StorageAccount[]
|
|
Lista co najmniej jednego konta usługi Azure Storage. Wymagane w żądaniach PUT (CreateOrReplace).
|
properties.timeFormat
|
string
|
|
Format godziny. Gdziekolwiek {time} pojawia się w pathPattern, wartość tej właściwości jest używana jako format czasu.
|
type
|
string:
Microsoft.Storage/Blob
|
|
Wskazuje typ danych wyjściowych źródła danych, w których zostaną zapisane dane wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).
|
CsvSerialization
Opisuje sposób serializacji danych wejściowych lub serializacji danych podczas zapisywania ich w danych wyjściowych w formacie CSV.
DiagnosticCondition
Warunek mający zastosowanie do zasobu lub ogólnego zadania, który gwarantuje uwagę klienta.
Nazwa |
Typ |
Opis |
code
|
string
|
Nieprzezroczysty kod diagnostyczny.
|
message
|
string
|
Czytelny dla człowieka komunikat opisujący szczegółowo warunek. Zlokalizowane w Accept-Language żądania klienta.
|
since
|
string
|
Sygnatura czasowa UTC rozpoczęcia warunku. Klienci powinni mieć możliwość znalezienia odpowiedniego zdarzenia w dzienniku operacji w tym czasie.
|
Diagnostics
Opisuje warunki mające zastosowanie do danych wejściowych, wyjściowych lub ogólnego zadania, które uzasadniają uwagę klienta.
Nazwa |
Typ |
Opis |
conditions
|
DiagnosticCondition[]
|
Kolekcja zera lub większej liczby warunków mających zastosowanie do zasobu lub ogólnego zadania, które uzasadniają uwagę klienta.
|
DocumentDbOutputDataSource
Opisuje źródło danych wyjściowych usługi DocumentDB.
Nazwa |
Typ |
Opis |
properties.accountId
|
string
|
Nazwa lub identyfikator konta usługi DocumentDB. Wymagane w żądaniach PUT (CreateOrReplace).
|
properties.accountKey
|
string
|
Klucz konta dla konta usługi DocumentDB. Wymagane w żądaniach PUT (CreateOrReplace).
|
properties.collectionNamePattern
|
string
|
Wzorzec nazwy kolekcji do użycia. Format nazwy kolekcji można utworzyć przy użyciu opcjonalnego tokenu {partition}, w którym partycje zaczynają się od 0. Aby uzyskać więcej informacji, https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output zobacz sekcję usługi DocumentDB. Wymagane w żądaniach PUT (CreateOrReplace).
|
properties.database
|
string
|
Nazwa bazy danych DocumentDB. Wymagane w żądaniach PUT (CreateOrReplace).
|
properties.documentId
|
string
|
Nazwa pola w zdarzeniach wyjściowych używanych do określania klucza podstawowego, na którym opierają się operacje wstawiania lub aktualizacji.
|
properties.partitionKey
|
string
|
Nazwa pola w zdarzeniach wyjściowych używanych do określania klucza do partycjonowania danych wyjściowych między kolekcjami. Jeśli element "collectionNamePattern" zawiera token {partition}, ta właściwość jest wymagana do określenia.
|
type
|
string:
Microsoft.Storage/DocumentDB
|
Wskazuje typ danych wyjściowych źródła danych, w których zostaną zapisane dane wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).
|
Encoding
Określa kodowanie danych przychodzących w przypadku danych wejściowych i kodowanie danych wychodzących w przypadku danych wyjściowych.
Nazwa |
Typ |
Opis |
UTF8
|
string
|
|
Error
Reprezentacja typowych błędów.
Nazwa |
Typ |
Opis |
error
|
Error
|
Właściwości definicji błędu.
|
EventHubOutputDataSource
Opisuje wyjściowe źródło danych centrum zdarzeń.
Nazwa |
Typ |
Wartość domyślna |
Opis |
authenticationMode
|
AuthenticationMode
|
ConnectionString
|
Tryb uwierzytelniania.
|
properties.eventHubName
|
string
|
|
Nazwa centrum zdarzeń. Wymagane w żądaniach PUT (CreateOrReplace).
|
properties.partitionKey
|
string
|
|
Klucz/kolumna używana do określania partycji do wysyłania danych zdarzenia.
|
properties.propertyColumns
|
string[]
|
|
Właściwości skojarzone z tym danymi wyjściowymi centrum zdarzeń.
|
serviceBusNamespace
|
string
|
|
Przestrzeń nazw skojarzona z żądanym centrum zdarzeń, kolejką usługi Service Bus, tematem usługi Service Bus itp. Wymagane w żądaniach PUT (CreateOrReplace).
|
sharedAccessPolicyKey
|
string
|
|
Klucz zasad dostępu współdzielonego dla określonych zasad dostępu współdzielonego. Wymagane w żądaniach PUT (CreateOrReplace).
|
sharedAccessPolicyName
|
string
|
|
Nazwa zasad dostępu współdzielonego dla centrum zdarzeń, kolejki usługi Service Bus, tematu usługi Service Bus itp. Wymagane w żądaniach PUT (CreateOrReplace).
|
type
|
string:
Microsoft.ServiceBus/EventHub
|
|
Wskazuje typ danych wyjściowych źródła danych, w których zostaną zapisane dane wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).
|
EventHubV2OutputDataSource
Opisuje wyjściowe źródło danych centrum zdarzeń.
Nazwa |
Typ |
Wartość domyślna |
Opis |
authenticationMode
|
AuthenticationMode
|
ConnectionString
|
Tryb uwierzytelniania.
|
properties.eventHubName
|
string
|
|
Nazwa centrum zdarzeń. Wymagane w żądaniach PUT (CreateOrReplace).
|
properties.partitionKey
|
string
|
|
Klucz/kolumna używana do określania partycji do wysyłania danych zdarzenia.
|
properties.propertyColumns
|
string[]
|
|
Właściwości skojarzone z tym danymi wyjściowymi centrum zdarzeń.
|
serviceBusNamespace
|
string
|
|
Przestrzeń nazw skojarzona z żądanym centrum zdarzeń, kolejką usługi Service Bus, tematem usługi Service Bus itp. Wymagane w żądaniach PUT (CreateOrReplace).
|
sharedAccessPolicyKey
|
string
|
|
Klucz zasad dostępu współdzielonego dla określonych zasad dostępu współdzielonego. Wymagane w żądaniach PUT (CreateOrReplace).
|
sharedAccessPolicyName
|
string
|
|
Nazwa zasad dostępu współdzielonego dla centrum zdarzeń, kolejki usługi Service Bus, tematu usługi Service Bus itp. Wymagane w żądaniach PUT (CreateOrReplace).
|
type
|
string:
Microsoft.EventHub/EventHub
|
|
Wskazuje typ danych wyjściowych źródła danych, w których zostaną zapisane dane wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).
|
EventSerializationType
Wskazuje typ serializacji używanej przez dane wejściowe lub wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).
Nazwa |
Typ |
Opis |
Avro
|
string
|
|
Csv
|
string
|
|
Json
|
string
|
|
Parquet
|
string
|
|
GatewayMessageBusOutputDataSource
Opisuje źródło danych wyjściowych magistrali komunikatów bramy.
Nazwa |
Typ |
Opis |
properties.topic
|
string
|
Nazwa tematu usługi Service Bus.
|
type
|
string:
GatewayMessageBus
|
Wskazuje typ danych wyjściowych źródła danych, w których zostaną zapisane dane wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).
|
Określa format JSON, w który będą zapisywane dane wyjściowe. Obecnie obsługiwane wartości to "lineSeparated", co wskazuje, że dane wyjściowe będą formatowane przez każdy obiekt JSON oddzielony przez nowy wiersz i tablicę wskazującą, że dane wyjściowe będą formatowane jako tablica obiektów JSON.
Nazwa |
Typ |
Opis |
Array
|
string
|
|
LineSeparated
|
string
|
|
JsonSerialization
Opisuje sposób serializacji danych wejściowych lub serializacji danych podczas zapisywania ich w danych wyjściowych w formacie JSON.
Nazwa |
Typ |
Opis |
properties.encoding
|
Encoding
|
Określa kodowanie danych przychodzących w przypadku danych wejściowych i kodowanie danych wychodzących w przypadku danych wyjściowych. Wymagane w żądaniach PUT (CreateOrReplace).
|
properties.format
|
JsonOutputSerializationFormat
|
Ta właściwość dotyczy tylko serializacji danych wyjściowych w formacie JSON. Nie ma zastosowania do danych wejściowych. Ta właściwość określa format JSON, w ramach których zostaną zapisane dane wyjściowe. Obecnie obsługiwane wartości to "lineSeparated", co wskazuje, że dane wyjściowe będą formatowane przez każdy obiekt JSON oddzielony przez nowy wiersz i tablicę wskazującą, że dane wyjściowe będą formatowane jako tablica obiektów JSON. Wartość domyślna to "lineSeparated", jeśli pozostawiono wartość null.
|
type
|
string:
Json
|
Wskazuje typ serializacji używanej przez dane wejściowe lub wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).
|
Output
Obiekt wyjściowy zawierający wszystkie informacje skojarzone z nazwanymi danymi wyjściowymi. Wszystkie dane wyjściowe są zawarte w zadaniu przesyłania strumieniowego.
Nazwa |
Typ |
Opis |
id
|
string
|
Identyfikator zasobu
|
name
|
string
|
Nazwa zasobu
|
properties.datasource
|
OutputDataSource:
|
Opisuje źródło danych, do którego zostaną zapisane dane wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).
|
properties.diagnostics
|
Diagnostics
|
Opisuje warunki mające zastosowanie do danych wejściowych, wyjściowych lub ogólnego zadania, które uzasadniają uwagę klienta.
|
properties.etag
|
string
|
Bieżący tag jednostki dla danych wyjściowych. Jest to nieprzezroczystych ciągów. Można go użyć do wykrywania, czy zasób zmienił się między żądaniami. Można go również używać w nagłówkach If-Match lub If-None-Match na potrzeby operacji zapisu w celu optymistycznej współbieżności.
|
properties.serialization
|
Serialization:
|
Opisuje, jak dane z danych wejściowych są serializowane lub jak dane są serializowane podczas zapisywania w danych wyjściowych. Wymagane w żądaniach PUT (CreateOrReplace).
|
properties.sizeWindow
|
integer
|
Okno rozmiaru ograniczające dane wyjściowe usługi Stream Analytics.
|
properties.timeWindow
|
string
|
Przedział czasu filtrowania danych wyjściowych zadania usługi Stream Analytics.
|
type
|
string
|
Typ zasobu
|
ParquetSerialization
Opisuje sposób serializacji danych wejściowych lub serializacji danych podczas zapisywania ich w danych wyjściowych w formacie Parquet.
Nazwa |
Typ |
Opis |
type
|
string:
Parquet
|
Wskazuje typ serializacji używanej przez dane wejściowe lub wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).
|
PowerBIOutputDataSource
Opisuje źródło danych wyjściowych usługi Power BI.
Nazwa |
Typ |
Wartość domyślna |
Opis |
properties.authenticationMode
|
AuthenticationMode
|
ConnectionString
|
Tryb uwierzytelniania.
|
properties.dataset
|
string
|
|
Nazwa zestawu danych usługi Power BI. Wymagane w żądaniach PUT (CreateOrReplace).
|
properties.groupId
|
string
|
|
Identyfikator grupy usługi Power BI.
|
properties.groupName
|
string
|
|
Nazwa grupy usługi Power BI. Użyj tej właściwości, aby zapamiętać, który identyfikator grupy usługi Power BI został użyty.
|
properties.refreshToken
|
string
|
|
Token odświeżania, którego można użyć do uzyskania prawidłowego tokenu dostępu, którego następnie można użyć do uwierzytelniania w źródle danych. Prawidłowy token odświeżania można obecnie uzyskać tylko za pośrednictwem witryny Azure Portal. Zaleca się umieszczenie w tym miejscu fikcyjnej wartości ciągu podczas tworzenia źródła danych, a następnie przejście do witryny Azure Portal w celu uwierzytelnienia źródła danych, które zaktualizuje tę właściwość przy użyciu prawidłowego tokenu odświeżania. Wymagane w żądaniach PUT (CreateOrReplace).
|
properties.table
|
string
|
|
Nazwa tabeli usługi Power BI w określonym zestawie danych. Wymagane w żądaniach PUT (CreateOrReplace).
|
properties.tokenUserDisplayName
|
string
|
|
Nazwa wyświetlana użytkownika, który został użyty do uzyskania tokenu odświeżania. Użyj tej właściwości, aby zapamiętać, którego użytkownika użyto do uzyskania tokenu odświeżania.
|
properties.tokenUserPrincipalName
|
string
|
|
Główna nazwa użytkownika (UPN) użytkownika, który został użyty do uzyskania tokenu odświeżania. Użyj tej właściwości, aby zapamiętać, którego użytkownika użyto do uzyskania tokenu odświeżania.
|
type
|
string:
PowerBI
|
|
Wskazuje typ danych wyjściowych źródła danych, w których zostaną zapisane dane wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).
|
ServiceBusQueueOutputDataSource
Opisuje źródło danych wyjściowych kolejki usługi Service Bus.
Nazwa |
Typ |
Wartość domyślna |
Opis |
properties.authenticationMode
|
AuthenticationMode
|
ConnectionString
|
Tryb uwierzytelniania.
|
properties.propertyColumns
|
string[]
|
|
Tablica ciągów nazw kolumn wyjściowych, które mają być dołączone do komunikatów usługi Service Bus jako właściwości niestandardowe.
|
properties.queueName
|
string
|
|
Nazwa kolejki usługi Service Bus. Wymagane w żądaniach PUT (CreateOrReplace).
|
properties.serviceBusNamespace
|
string
|
|
Przestrzeń nazw skojarzona z żądanym centrum zdarzeń, kolejką usługi Service Bus, tematem usługi Service Bus itp. Wymagane w żądaniach PUT (CreateOrReplace).
|
properties.sharedAccessPolicyKey
|
string
|
|
Klucz zasad dostępu współdzielonego dla określonych zasad dostępu współdzielonego. Wymagane w żądaniach PUT (CreateOrReplace).
|
properties.sharedAccessPolicyName
|
string
|
|
Nazwa zasad dostępu współdzielonego dla centrum zdarzeń, kolejki usługi Service Bus, tematu usługi Service Bus itp. Wymagane w żądaniach PUT (CreateOrReplace).
|
properties.systemPropertyColumns
|
object
|
|
Właściwości systemowe skojarzone z kolejką usługi Service Bus. Obsługiwane są następujące właściwości systemowe: ReplyToSessionId, ContentType, To, Subject, CorrelationId, TimeToLive, PartitionKey, SessionId, ScheduledEnqueueTime, MessageId, ReplyTo, Label, ScheduledEnqueueTimeUtc.
|
type
|
string:
Microsoft.ServiceBus/Queue
|
|
Wskazuje typ danych wyjściowych źródła danych, w których zostaną zapisane dane wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).
|
ServiceBusTopicOutputDataSource
Opisuje źródło danych wyjściowych tematu usługi Service Bus.
Nazwa |
Typ |
Wartość domyślna |
Opis |
properties.authenticationMode
|
AuthenticationMode
|
ConnectionString
|
Tryb uwierzytelniania.
|
properties.propertyColumns
|
string[]
|
|
Tablica ciągów nazw kolumn wyjściowych, które mają być dołączone do komunikatów usługi Service Bus jako właściwości niestandardowe.
|
properties.serviceBusNamespace
|
string
|
|
Przestrzeń nazw skojarzona z żądanym centrum zdarzeń, kolejką usługi Service Bus, tematem usługi Service Bus itp. Wymagane w żądaniach PUT (CreateOrReplace).
|
properties.sharedAccessPolicyKey
|
string
|
|
Klucz zasad dostępu współdzielonego dla określonych zasad dostępu współdzielonego. Wymagane w żądaniach PUT (CreateOrReplace).
|
properties.sharedAccessPolicyName
|
string
|
|
Nazwa zasad dostępu współdzielonego dla centrum zdarzeń, kolejki usługi Service Bus, tematu usługi Service Bus itp. Wymagane w żądaniach PUT (CreateOrReplace).
|
properties.systemPropertyColumns
|
object
|
|
Właściwości systemowe skojarzone z danymi wyjściowymi tematu usługi Service Bus. Obsługiwane są następujące właściwości systemowe: ReplyToSessionId, ContentType, To, Subject, CorrelationId, TimeToLive, PartitionKey, SessionId, ScheduledEnqueueTime, MessageId, ReplyTo, Label, ScheduledEnqueueTimeUtc.
|
properties.topicName
|
string
|
|
Nazwa tematu usługi Service Bus. Wymagane w żądaniach PUT (CreateOrReplace).
|
type
|
string:
Microsoft.ServiceBus/Topic
|
|
Wskazuje typ danych wyjściowych źródła danych, w których zostaną zapisane dane wyjściowe. Wymagane w żądaniach PUT (CreateOrReplace).
|
StorageAccount
Właściwości skojarzone z kontem usługi Azure Storage
Nazwa |
Typ |
Opis |
accountKey
|
string
|
Klucz konta dla konta usługi Azure Storage. Wymagane w żądaniach PUT (CreateOrReplace).
|
accountName
|
string
|
Nazwa konta usługi Azure Storage. Wymagane w żądaniach PUT (CreateOrReplace).
|