出力を作成するか、既存のストリーミング ジョブの下にある既存の出力を置き換えます。
PUT https://management.azure.com/subscriptions/{subscriptionId}/resourcegroups/{resourceGroupName}/providers/Microsoft.StreamAnalytics/streamingjobs/{jobName}/outputs/{outputName}?api-version=2020-03-01
URI パラメーター
名前 |
/ |
必須 |
型 |
説明 |
jobName
|
path |
True
|
string
|
ストリーミング ジョブの名前。
|
outputName
|
path |
True
|
string
|
出力の名前。
|
resourceGroupName
|
path |
True
|
string
|
リソース グループの名前。 名前の大文字と小文字は区別されます。
Regex pattern: ^[-\w\._\(\)]+$
|
subscriptionId
|
path |
True
|
string
|
ターゲット サブスクリプションの ID。
|
api-version
|
query |
True
|
string
|
この操作に使用する API バージョン。
|
名前 |
必須 |
型 |
説明 |
If-Match
|
|
string
|
出力の ETag。 現在の出力を常に上書きするには、この値を省略します。 同時変更が誤って上書きされないように、最後に表示された ETag 値を指定します。
|
If-None-Match
|
|
string
|
新しい出力を作成できるようにするが、既存の出力を更新できないようにするには、'*' に設定します。 その他の値を指定すると、412 の事前条件失敗応答が発生します。
|
要求本文
名前 |
型 |
説明 |
name
|
string
|
リソース名
|
properties.datasource
|
OutputDataSource:
|
出力の書き込み先となるデータ ソースについて説明します。 PUT (CreateOrReplace) 要求で必要です。
|
properties.serialization
|
Serialization:
|
入力からのデータをシリアル化する方法、または出力に書き込むときにデータをシリアル化する方法について説明します。 PUT (CreateOrReplace) 要求で必要です。
|
properties.sizeWindow
|
integer
|
Stream Analytics の出力を制限するサイズ ウィンドウ。
|
properties.timeWindow
|
string
|
Stream Analytics ジョブ出力をフィルター処理するための時間枠。
|
応答
名前 |
型 |
説明 |
200 OK
|
Output
|
出力が正常に作成または置換されました。
Headers
ETag: string
|
201 Created
|
Output
|
出力が正常に作成または置換されました。
Headers
ETag: string
|
Other Status Codes
|
Error
|
エラー。
|
セキュリティ
azure_auth
Azure Active Directory OAuth2 フロー
Type:
oauth2
Flow:
implicit
Authorization URL:
https://login.microsoftonline.com/common/oauth2/authorize
Scopes
名前 |
説明 |
user_impersonation
|
ユーザー アカウントの借用
|
例
Create a blob output with CSV serialization
Sample Request
PUT 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": {
"storageAccounts": [
{
"accountName": "someAccountName",
"accountKey": "accountKey=="
}
],
"container": "state",
"pathPattern": "{date}/{time}",
"dateFormat": "yyyy/MM/dd",
"timeFormat": "HH"
}
},
"serialization": {
"type": "Csv",
"properties": {
"fieldDelimiter": ",",
"encoding": "UTF8"
}
}
}
}
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.StorageAccount;
import java.util.Arrays;
/** Samples for Outputs CreateOrReplace. */
public final class Main {
/*
* x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Create_Blob_CSV.json
*/
/**
* Sample code: Create a blob output with CSV serialization.
*
* @param manager Entry point to StreamAnalyticsManager.
*/
public static void createABlobOutputWithCSVSerialization(
com.azure.resourcemanager.streamanalytics.StreamAnalyticsManager manager) {
manager
.outputs()
.define("output1623")
.withExistingStreamingjob("sjrg5023", "sj900")
.withDatasource(
new BlobOutputDataSource()
.withStorageAccounts(
Arrays
.asList(
new StorageAccount().withAccountName("someAccountName").withAccountKey("accountKey==")))
.withContainer("state")
.withPathPattern("{date}/{time}")
.withDateFormat("yyyy/MM/dd")
.withTimeFormat("HH"))
.withSerialization(new CsvSerialization().withFieldDelimiter(",").withEncoding(Encoding.UTF8))
.create();
}
}
To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue
package armstreamanalytics_test
import (
"context"
"log"
"github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/streamanalytics/armstreamanalytics"
)
// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/d55b8005f05b040b852c15e74a0f3e36494a15e1/specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Create_Blob_CSV.json
func ExampleOutputsClient_CreateOrReplace_createABlobOutputWithCsvSerialization() {
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().CreateOrReplace(ctx, "sjrg5023", "sj900", "output1623", armstreamanalytics.Output{
Properties: &armstreamanalytics.OutputProperties{
Datasource: &armstreamanalytics.BlobOutputDataSource{
Type: to.Ptr("Microsoft.Storage/Blob"),
Properties: &armstreamanalytics.BlobOutputDataSourceProperties{
Container: to.Ptr("state"),
DateFormat: to.Ptr("yyyy/MM/dd"),
PathPattern: to.Ptr("{date}/{time}"),
StorageAccounts: []*armstreamanalytics.StorageAccount{
{
AccountKey: to.Ptr("accountKey=="),
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(","),
},
},
},
}, &armstreamanalytics.OutputsClientCreateOrReplaceOptions{IfMatch: nil,
IfNoneMatch: nil,
})
if err != nil {
log.Fatalf("failed to finish the request: %v", err)
}
// You could use response here. We use blank identifier for just demo purposes.
_ = res
// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
// res.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("state"),
// 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 Creates an output or replaces an already existing output under an existing streaming job.
*
* @summary Creates an output or replaces an already existing output under an existing streaming job.
* x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Create_Blob_CSV.json
*/
async function createABlobOutputWithCsvSerialization() {
const subscriptionId = "56b5e0a9-b645-407d-99b0-c64f86013e3d";
const resourceGroupName = "sjrg5023";
const jobName = "sj900";
const outputName = "output1623";
const output = {
datasource: {
type: "Microsoft.Storage/Blob",
container: "state",
dateFormat: "yyyy/MM/dd",
pathPattern: "{date}/{time}",
storageAccounts: [{ accountKey: "accountKey==", accountName: "someAccountName" }],
timeFormat: "HH",
},
serialization: { type: "Csv", encoding: "UTF8", fieldDelimiter: "," },
};
const credential = new DefaultAzureCredential();
const client = new StreamAnalyticsManagementClient(credential, subscriptionId);
const result = await client.outputs.createOrReplace(
resourceGroupName,
jobName,
outputName,
output
);
console.log(result);
}
createABlobOutputWithCsvSerialization().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: 5433fd97-d133-46e3-8588-5fe1f1599ee0
{
"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": "state",
"pathPattern": "{date}/{time}",
"dateFormat": "yyyy/MM/dd",
"timeFormat": "HH"
}
},
"serialization": {
"type": "Csv",
"properties": {
"fieldDelimiter": ",",
"encoding": "UTF8"
}
}
}
}
ETag: 5433fd97-d133-46e3-8588-5fe1f1599ee0
{
"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": "state",
"pathPattern": "{date}/{time}",
"dateFormat": "yyyy/MM/dd",
"timeFormat": "HH"
}
},
"serialization": {
"type": "Csv",
"properties": {
"fieldDelimiter": ",",
"encoding": "UTF8"
}
}
}
}
Create a DocumentDB output
Sample Request
PUT 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": {
"accountId": "someAccountId",
"accountKey": "accountKey==",
"database": "db01",
"collectionNamePattern": "collection",
"partitionKey": "key",
"documentId": "documentId"
}
}
}
}
import com.azure.resourcemanager.streamanalytics.models.DocumentDbOutputDataSource;
/** Samples for Outputs CreateOrReplace. */
public final class Main {
/*
* x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Create_DocumentDB.json
*/
/**
* Sample code: Create a DocumentDB output.
*
* @param manager Entry point to StreamAnalyticsManager.
*/
public static void createADocumentDBOutput(
com.azure.resourcemanager.streamanalytics.StreamAnalyticsManager manager) {
manager
.outputs()
.define("output3022")
.withExistingStreamingjob("sjrg7983", "sj2331")
.withDatasource(
new DocumentDbOutputDataSource()
.withAccountId("someAccountId")
.withAccountKey("accountKey==")
.withDatabase("db01")
.withCollectionNamePattern("collection")
.withPartitionKey("key")
.withDocumentId("documentId"))
.create();
}
}
To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue
package armstreamanalytics_test
import (
"context"
"log"
"github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/streamanalytics/armstreamanalytics"
)
// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/d55b8005f05b040b852c15e74a0f3e36494a15e1/specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Create_DocumentDB.json
func ExampleOutputsClient_CreateOrReplace_createADocumentDbOutput() {
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().CreateOrReplace(ctx, "sjrg7983", "sj2331", "output3022", armstreamanalytics.Output{
Properties: &armstreamanalytics.OutputProperties{
Datasource: &armstreamanalytics.DocumentDbOutputDataSource{
Type: to.Ptr("Microsoft.Storage/DocumentDB"),
Properties: &armstreamanalytics.DocumentDbOutputDataSourceProperties{
AccountID: to.Ptr("someAccountId"),
AccountKey: to.Ptr("accountKey=="),
CollectionNamePattern: to.Ptr("collection"),
Database: to.Ptr("db01"),
DocumentID: to.Ptr("documentId"),
PartitionKey: to.Ptr("key"),
},
},
},
}, &armstreamanalytics.OutputsClientCreateOrReplaceOptions{IfMatch: nil,
IfNoneMatch: nil,
})
if err != nil {
log.Fatalf("failed to finish the request: %v", err)
}
// You could use response here. We use blank identifier for just demo purposes.
_ = res
// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
// res.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("key"),
// },
// },
// },
// }
}
To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue
const { StreamAnalyticsManagementClient } = require("@azure/arm-streamanalytics");
const { DefaultAzureCredential } = require("@azure/identity");
/**
* This sample demonstrates how to Creates an output or replaces an already existing output under an existing streaming job.
*
* @summary Creates an output or replaces an already existing output under an existing streaming job.
* x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Create_DocumentDB.json
*/
async function createADocumentDbOutput() {
const subscriptionId = "56b5e0a9-b645-407d-99b0-c64f86013e3d";
const resourceGroupName = "sjrg7983";
const jobName = "sj2331";
const outputName = "output3022";
const output = {
datasource: {
type: "Microsoft.Storage/DocumentDB",
accountId: "someAccountId",
accountKey: "accountKey==",
collectionNamePattern: "collection",
database: "db01",
documentId: "documentId",
partitionKey: "key",
},
};
const credential = new DefaultAzureCredential();
const client = new StreamAnalyticsManagementClient(credential, subscriptionId);
const result = await client.outputs.createOrReplace(
resourceGroupName,
jobName,
outputName,
output
);
console.log(result);
}
createADocumentDbOutput().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: ccf8b864-259e-43c5-a628-ba10858b2c07
{
"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": "key",
"documentId": "documentId"
}
}
}
}
ETag: ccf8b864-259e-43c5-a628-ba10858b2c07
{
"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": "key",
"documentId": "documentId"
}
}
}
}
Create a Gateway Message Bus output
Sample Request
PUT 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": "GatewayMessageBus",
"properties": {
"topic": "EdgeTopic1"
}
}
}
}
Sample Response
ETag: ccf8b864-259e-43c5-a628-ba10858b2c07
{
"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": "GatewayMessageBus",
"properties": {
"topic": "EdgeTopic1"
}
}
}
}
ETag: ccf8b864-259e-43c5-a628-ba10858b2c07
{
"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": "GatewayMessageBus",
"properties": {
"topic": "EdgeTopic1"
}
}
}
}
Create a Power BI output
Sample Request
PUT 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": "someDataset",
"table": "someTable",
"refreshToken": "someRefreshToken==",
"tokenUserPrincipalName": "bobsmith@contoso.com",
"tokenUserDisplayName": "Bob Smith",
"groupId": "ac40305e-3e8d-43ac-8161-c33799f43e95",
"groupName": "MyPowerBIGroup"
}
}
}
}
import com.azure.resourcemanager.streamanalytics.models.PowerBIOutputDataSource;
/** Samples for Outputs CreateOrReplace. */
public final class Main {
/*
* x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Create_PowerBI.json
*/
/**
* Sample code: Create a Power BI output.
*
* @param manager Entry point to StreamAnalyticsManager.
*/
public static void createAPowerBIOutput(com.azure.resourcemanager.streamanalytics.StreamAnalyticsManager manager) {
manager
.outputs()
.define("output3022")
.withExistingStreamingjob("sjrg7983", "sj2331")
.withDatasource(
new PowerBIOutputDataSource()
.withDataset("someDataset")
.withTable("someTable")
.withGroupId("ac40305e-3e8d-43ac-8161-c33799f43e95")
.withGroupName("MyPowerBIGroup")
.withRefreshToken("someRefreshToken==")
.withTokenUserPrincipalName("bobsmith@contoso.com")
.withTokenUserDisplayName("Bob Smith"))
.create();
}
}
To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue
package armstreamanalytics_test
import (
"context"
"log"
"github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/streamanalytics/armstreamanalytics"
)
// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/d55b8005f05b040b852c15e74a0f3e36494a15e1/specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Create_PowerBI.json
func ExampleOutputsClient_CreateOrReplace_createAPowerBiOutput() {
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().CreateOrReplace(ctx, "sjrg7983", "sj2331", "output3022", armstreamanalytics.Output{
Properties: &armstreamanalytics.OutputProperties{
Datasource: &armstreamanalytics.PowerBIOutputDataSource{
Type: to.Ptr("PowerBI"),
Properties: &armstreamanalytics.PowerBIOutputDataSourceProperties{
RefreshToken: to.Ptr("someRefreshToken=="),
TokenUserDisplayName: to.Ptr("Bob Smith"),
TokenUserPrincipalName: to.Ptr("bobsmith@contoso.com"),
Dataset: to.Ptr("someDataset"),
GroupID: to.Ptr("ac40305e-3e8d-43ac-8161-c33799f43e95"),
GroupName: to.Ptr("MyPowerBIGroup"),
Table: to.Ptr("someTable"),
},
},
},
}, &armstreamanalytics.OutputsClientCreateOrReplaceOptions{IfMatch: nil,
IfNoneMatch: nil,
})
if err != nil {
log.Fatalf("failed to finish the request: %v", err)
}
// You could use response here. We use blank identifier for just demo purposes.
_ = res
// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
// res.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("someDataset"),
// 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 Creates an output or replaces an already existing output under an existing streaming job.
*
* @summary Creates an output or replaces an already existing output under an existing streaming job.
* x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Create_PowerBI.json
*/
async function createAPowerBiOutput() {
const subscriptionId = "56b5e0a9-b645-407d-99b0-c64f86013e3d";
const resourceGroupName = "sjrg7983";
const jobName = "sj2331";
const outputName = "output3022";
const output = {
datasource: {
type: "PowerBI",
dataset: "someDataset",
groupId: "ac40305e-3e8d-43ac-8161-c33799f43e95",
groupName: "MyPowerBIGroup",
refreshToken: "someRefreshToken==",
table: "someTable",
tokenUserDisplayName: "Bob Smith",
tokenUserPrincipalName: "bobsmith@contoso.com",
},
};
const credential = new DefaultAzureCredential();
const client = new StreamAnalyticsManagementClient(credential, subscriptionId);
const result = await client.outputs.createOrReplace(
resourceGroupName,
jobName,
outputName,
output
);
console.log(result);
}
createAPowerBiOutput().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: ccf8b864-259e-43c5-a628-ba10858b2c07
{
"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": "someDataset",
"table": "someTable",
"tokenUserPrincipalName": "bobsmith@contoso.com",
"tokenUserDisplayName": "Bob Smith",
"groupId": "ac40305e-3e8d-43ac-8161-c33799f43e95",
"groupName": "MyPowerBIGroup"
}
}
}
}
ETag: ccf8b864-259e-43c5-a628-ba10858b2c07
{
"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": "someDataset",
"table": "someTable",
"tokenUserPrincipalName": "bobsmith@contoso.com",
"tokenUserDisplayName": "Bob Smith",
"groupId": "ac40305e-3e8d-43ac-8161-c33799f43e95",
"groupName": "MyPowerBIGroup"
}
}
}
}
Create a Service Bus Queue output with Avro serialization
Sample Request
PUT 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": {
"serviceBusNamespace": "sdktest",
"sharedAccessPolicyName": "RootManageSharedAccessKey",
"sharedAccessPolicyKey": "sharedAccessPolicyKey=",
"queueName": "sdkqueue",
"propertyColumns": [
"column1",
"column2"
],
"systemPropertyColumns": {
"MessageId": "col3",
"PartitionKey": "col4"
}
}
},
"serialization": {
"type": "Avro"
}
}
}
import com.azure.core.management.serializer.SerializerFactory;
import com.azure.core.util.serializer.SerializerEncoding;
import com.azure.resourcemanager.streamanalytics.models.AvroSerialization;
import com.azure.resourcemanager.streamanalytics.models.ServiceBusQueueOutputDataSource;
import java.io.IOException;
import java.util.Arrays;
/** Samples for Outputs CreateOrReplace. */
public final class Main {
/*
* x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Create_ServiceBusQueue_Avro.json
*/
/**
* Sample code: Create a Service Bus Queue output with Avro serialization.
*
* @param manager Entry point to StreamAnalyticsManager.
*/
public static void createAServiceBusQueueOutputWithAvroSerialization(
com.azure.resourcemanager.streamanalytics.StreamAnalyticsManager manager) throws IOException {
manager
.outputs()
.define("output3456")
.withExistingStreamingjob("sjrg3410", "sj5095")
.withDatasource(
new ServiceBusQueueOutputDataSource()
.withQueueName("sdkqueue")
.withPropertyColumns(Arrays.asList("column1", "column2"))
.withSystemPropertyColumns(
SerializerFactory
.createDefaultManagementSerializerAdapter()
.deserialize(
"{\"MessageId\":\"col3\",\"PartitionKey\":\"col4\"}",
Object.class,
SerializerEncoding.JSON))
.withServiceBusNamespace("sdktest")
.withSharedAccessPolicyName("RootManageSharedAccessKey")
.withSharedAccessPolicyKey("sharedAccessPolicyKey="))
.withSerialization(new AvroSerialization())
.create();
}
}
To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue
package armstreamanalytics_test
import (
"context"
"log"
"github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/streamanalytics/armstreamanalytics"
)
// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/d55b8005f05b040b852c15e74a0f3e36494a15e1/specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Create_ServiceBusQueue_Avro.json
func ExampleOutputsClient_CreateOrReplace_createAServiceBusQueueOutputWithAvroSerialization() {
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().CreateOrReplace(ctx, "sjrg3410", "sj5095", "output3456", armstreamanalytics.Output{
Properties: &armstreamanalytics.OutputProperties{
Datasource: &armstreamanalytics.ServiceBusQueueOutputDataSource{
Type: to.Ptr("Microsoft.ServiceBus/Queue"),
Properties: &armstreamanalytics.ServiceBusQueueOutputDataSourceProperties{
ServiceBusNamespace: to.Ptr("sdktest"),
SharedAccessPolicyKey: to.Ptr("sharedAccessPolicyKey="),
SharedAccessPolicyName: to.Ptr("RootManageSharedAccessKey"),
PropertyColumns: []*string{
to.Ptr("column1"),
to.Ptr("column2")},
QueueName: to.Ptr("sdkqueue"),
SystemPropertyColumns: map[string]any{
"MessageId": "col3",
"PartitionKey": "col4",
},
},
},
Serialization: &armstreamanalytics.AvroSerialization{
Type: to.Ptr(armstreamanalytics.EventSerializationTypeAvro),
},
},
}, &armstreamanalytics.OutputsClientCreateOrReplaceOptions{IfMatch: nil,
IfNoneMatch: nil,
})
if err != nil {
log.Fatalf("failed to finish the request: %v", err)
}
// You could use response here. We use blank identifier for just demo purposes.
_ = res
// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
// res.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("sdkqueue"),
// },
// },
// Serialization: &armstreamanalytics.AvroSerialization{
// Type: to.Ptr(armstreamanalytics.EventSerializationTypeAvro),
// Properties: map[string]any{
// },
// },
// },
// }
}
To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue
const { StreamAnalyticsManagementClient } = require("@azure/arm-streamanalytics");
const { DefaultAzureCredential } = require("@azure/identity");
/**
* This sample demonstrates how to Creates an output or replaces an already existing output under an existing streaming job.
*
* @summary Creates an output or replaces an already existing output under an existing streaming job.
* x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Create_ServiceBusQueue_Avro.json
*/
async function createAServiceBusQueueOutputWithAvroSerialization() {
const subscriptionId = "56b5e0a9-b645-407d-99b0-c64f86013e3d";
const resourceGroupName = "sjrg3410";
const jobName = "sj5095";
const outputName = "output3456";
const output = {
datasource: {
type: "Microsoft.ServiceBus/Queue",
propertyColumns: ["column1", "column2"],
queueName: "sdkqueue",
serviceBusNamespace: "sdktest",
sharedAccessPolicyKey: "sharedAccessPolicyKey=",
sharedAccessPolicyName: "RootManageSharedAccessKey",
systemPropertyColumns: { MessageId: "col3", PartitionKey: "col4" },
},
serialization: { type: "Avro" },
};
const credential = new DefaultAzureCredential();
const client = new StreamAnalyticsManagementClient(credential, subscriptionId);
const result = await client.outputs.createOrReplace(
resourceGroupName,
jobName,
outputName,
output
);
console.log(result);
}
createAServiceBusQueueOutputWithAvroSerialization().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: 2f68c1ec-2080-43cb-93ec-4bcd3b7f9dbe
{
"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": "sdkqueue",
"propertyColumns": [
"column1",
"column2"
],
"serviceBusNamespace": "sdktest",
"sharedAccessPolicyName": "RootManageSharedAccessKey"
}
},
"serialization": {
"type": "Avro",
"properties": {}
}
}
}
ETag: 2f68c1ec-2080-43cb-93ec-4bcd3b7f9dbe
{
"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": "sdkqueue",
"propertyColumns": [
"column1",
"column2"
],
"serviceBusNamespace": "sdktest",
"sharedAccessPolicyName": "RootManageSharedAccessKey"
}
},
"serialization": {
"type": "Avro",
"properties": {}
}
}
}
Create a Service Bus Topic output with CSV serialization
Sample Request
PUT 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": {
"serviceBusNamespace": "sdktest",
"sharedAccessPolicyName": "RootManageSharedAccessKey",
"sharedAccessPolicyKey": "sharedAccessPolicyKey=",
"topicName": "sdktopic",
"propertyColumns": [
"column1",
"column2"
]
}
},
"serialization": {
"type": "Csv",
"properties": {
"fieldDelimiter": ",",
"encoding": "UTF8"
}
}
}
}
import com.azure.resourcemanager.streamanalytics.models.CsvSerialization;
import com.azure.resourcemanager.streamanalytics.models.Encoding;
import com.azure.resourcemanager.streamanalytics.models.ServiceBusTopicOutputDataSource;
import java.util.Arrays;
/** Samples for Outputs CreateOrReplace. */
public final class Main {
/*
* x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Create_ServiceBusTopic_CSV.json
*/
/**
* Sample code: Create a Service Bus Topic output with CSV serialization.
*
* @param manager Entry point to StreamAnalyticsManager.
*/
public static void createAServiceBusTopicOutputWithCSVSerialization(
com.azure.resourcemanager.streamanalytics.StreamAnalyticsManager manager) {
manager
.outputs()
.define("output7886")
.withExistingStreamingjob("sjrg6450", "sj7094")
.withDatasource(
new ServiceBusTopicOutputDataSource()
.withTopicName("sdktopic")
.withPropertyColumns(Arrays.asList("column1", "column2"))
.withServiceBusNamespace("sdktest")
.withSharedAccessPolicyName("RootManageSharedAccessKey")
.withSharedAccessPolicyKey("sharedAccessPolicyKey="))
.withSerialization(new CsvSerialization().withFieldDelimiter(",").withEncoding(Encoding.UTF8))
.create();
}
}
To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue
package armstreamanalytics_test
import (
"context"
"log"
"github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/streamanalytics/armstreamanalytics"
)
// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/d55b8005f05b040b852c15e74a0f3e36494a15e1/specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Create_ServiceBusTopic_CSV.json
func ExampleOutputsClient_CreateOrReplace_createAServiceBusTopicOutputWithCsvSerialization() {
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().CreateOrReplace(ctx, "sjrg6450", "sj7094", "output7886", armstreamanalytics.Output{
Properties: &armstreamanalytics.OutputProperties{
Datasource: &armstreamanalytics.ServiceBusTopicOutputDataSource{
Type: to.Ptr("Microsoft.ServiceBus/Topic"),
Properties: &armstreamanalytics.ServiceBusTopicOutputDataSourceProperties{
ServiceBusNamespace: to.Ptr("sdktest"),
SharedAccessPolicyKey: to.Ptr("sharedAccessPolicyKey="),
SharedAccessPolicyName: to.Ptr("RootManageSharedAccessKey"),
PropertyColumns: []*string{
to.Ptr("column1"),
to.Ptr("column2")},
TopicName: to.Ptr("sdktopic"),
},
},
Serialization: &armstreamanalytics.CSVSerialization{
Type: to.Ptr(armstreamanalytics.EventSerializationTypeCSV),
Properties: &armstreamanalytics.CSVSerializationProperties{
Encoding: to.Ptr(armstreamanalytics.EncodingUTF8),
FieldDelimiter: to.Ptr(","),
},
},
},
}, &armstreamanalytics.OutputsClientCreateOrReplaceOptions{IfMatch: nil,
IfNoneMatch: nil,
})
if err != nil {
log.Fatalf("failed to finish the request: %v", err)
}
// You could use response here. We use blank identifier for just demo purposes.
_ = res
// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
// res.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("sdktopic"),
// },
// },
// 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 Creates an output or replaces an already existing output under an existing streaming job.
*
* @summary Creates an output or replaces an already existing output under an existing streaming job.
* x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Create_ServiceBusTopic_CSV.json
*/
async function createAServiceBusTopicOutputWithCsvSerialization() {
const subscriptionId = "56b5e0a9-b645-407d-99b0-c64f86013e3d";
const resourceGroupName = "sjrg6450";
const jobName = "sj7094";
const outputName = "output7886";
const output = {
datasource: {
type: "Microsoft.ServiceBus/Topic",
propertyColumns: ["column1", "column2"],
serviceBusNamespace: "sdktest",
sharedAccessPolicyKey: "sharedAccessPolicyKey=",
sharedAccessPolicyName: "RootManageSharedAccessKey",
topicName: "sdktopic",
},
serialization: { type: "Csv", encoding: "UTF8", fieldDelimiter: "," },
};
const credential = new DefaultAzureCredential();
const client = new StreamAnalyticsManagementClient(credential, subscriptionId);
const result = await client.outputs.createOrReplace(
resourceGroupName,
jobName,
outputName,
output
);
console.log(result);
}
createAServiceBusTopicOutputWithCsvSerialization().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: 39259839-e581-4af4-bf68-302e6820e3a0
{
"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": "sdktopic",
"propertyColumns": [
"column1",
"column2"
],
"serviceBusNamespace": "sdktest",
"sharedAccessPolicyName": "RootManageSharedAccessKey"
}
},
"serialization": {
"type": "Csv",
"properties": {
"fieldDelimiter": ",",
"encoding": "UTF8"
}
}
}
}
ETag: 39259839-e581-4af4-bf68-302e6820e3a0
{
"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": "sdktopic",
"propertyColumns": [
"column1",
"column2"
],
"serviceBusNamespace": "sdktest",
"sharedAccessPolicyName": "RootManageSharedAccessKey"
}
},
"serialization": {
"type": "Csv",
"properties": {
"fieldDelimiter": ",",
"encoding": "UTF8"
}
}
}
}
Create an Azure Data Lake Store output with JSON serialization
Sample Request
PUT 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": "someaccount",
"tenantId": "cea4e98b-c798-49e7-8c40-4a2b3beb47dd",
"refreshToken": "someRefreshToken==",
"tokenUserPrincipalName": "bobsmith@contoso.com",
"tokenUserDisplayName": "Bob Smith",
"filePathPrefix": "{date}/{time}",
"dateFormat": "yyyy/MM/dd",
"timeFormat": "HH"
}
},
"serialization": {
"type": "Json",
"properties": {
"encoding": "UTF8",
"format": "Array"
}
}
}
}
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;
/** Samples for Outputs CreateOrReplace. */
public final class Main {
/*
* x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Create_AzureDataLakeStore_JSON.json
*/
/**
* Sample code: Create an Azure Data Lake Store output with JSON serialization.
*
* @param manager Entry point to StreamAnalyticsManager.
*/
public static void createAnAzureDataLakeStoreOutputWithJSONSerialization(
com.azure.resourcemanager.streamanalytics.StreamAnalyticsManager manager) {
manager
.outputs()
.define("output5195")
.withExistingStreamingjob("sjrg6912", "sj3310")
.withDatasource(
new AzureDataLakeStoreOutputDataSource()
.withAccountName("someaccount")
.withTenantId("cea4e98b-c798-49e7-8c40-4a2b3beb47dd")
.withFilePathPrefix("{date}/{time}")
.withDateFormat("yyyy/MM/dd")
.withTimeFormat("HH")
.withRefreshToken("someRefreshToken==")
.withTokenUserPrincipalName("bobsmith@contoso.com")
.withTokenUserDisplayName("Bob Smith"))
.withSerialization(
new JsonSerialization().withEncoding(Encoding.UTF8).withFormat(JsonOutputSerializationFormat.ARRAY))
.create();
}
}
To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue
package armstreamanalytics_test
import (
"context"
"log"
"github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/streamanalytics/armstreamanalytics"
)
// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/d55b8005f05b040b852c15e74a0f3e36494a15e1/specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Create_AzureDataLakeStore_JSON.json
func ExampleOutputsClient_CreateOrReplace_createAnAzureDataLakeStoreOutputWithJsonSerialization() {
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().CreateOrReplace(ctx, "sjrg6912", "sj3310", "output5195", armstreamanalytics.Output{
Properties: &armstreamanalytics.OutputProperties{
Datasource: &armstreamanalytics.AzureDataLakeStoreOutputDataSource{
Type: to.Ptr("Microsoft.DataLake/Accounts"),
Properties: &armstreamanalytics.AzureDataLakeStoreOutputDataSourceProperties{
RefreshToken: to.Ptr("someRefreshToken=="),
TokenUserDisplayName: to.Ptr("Bob Smith"),
TokenUserPrincipalName: to.Ptr("bobsmith@contoso.com"),
AccountName: to.Ptr("someaccount"),
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.JSONOutputSerializationFormatArray),
Encoding: to.Ptr(armstreamanalytics.EncodingUTF8),
},
},
},
}, &armstreamanalytics.OutputsClientCreateOrReplaceOptions{IfMatch: nil,
IfNoneMatch: nil,
})
if err != nil {
log.Fatalf("failed to finish the request: %v", err)
}
// You could use response here. We use blank identifier for just demo purposes.
_ = res
// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
// res.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("someaccount"),
// 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.JSONOutputSerializationFormatArray),
// 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 Creates an output or replaces an already existing output under an existing streaming job.
*
* @summary Creates an output or replaces an already existing output under an existing streaming job.
* x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Create_AzureDataLakeStore_JSON.json
*/
async function createAnAzureDataLakeStoreOutputWithJsonSerialization() {
const subscriptionId = "56b5e0a9-b645-407d-99b0-c64f86013e3d";
const resourceGroupName = "sjrg6912";
const jobName = "sj3310";
const outputName = "output5195";
const output = {
datasource: {
type: "Microsoft.DataLake/Accounts",
accountName: "someaccount",
dateFormat: "yyyy/MM/dd",
filePathPrefix: "{date}/{time}",
refreshToken: "someRefreshToken==",
tenantId: "cea4e98b-c798-49e7-8c40-4a2b3beb47dd",
timeFormat: "HH",
tokenUserDisplayName: "Bob Smith",
tokenUserPrincipalName: "bobsmith@contoso.com",
},
serialization: { type: "Json", format: "Array", encoding: "UTF8" },
};
const credential = new DefaultAzureCredential();
const client = new StreamAnalyticsManagementClient(credential, subscriptionId);
const result = await client.outputs.createOrReplace(
resourceGroupName,
jobName,
outputName,
output
);
console.log(result);
}
createAnAzureDataLakeStoreOutputWithJsonSerialization().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: 5472168f-7317-4241-8b75-0c8d9d0ea804
{
"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": "someaccount",
"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": "Array"
}
}
}
}
ETag: 5472168f-7317-4241-8b75-0c8d9d0ea804
{
"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": "someaccount",
"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": "Array"
}
}
}
}
Create an Azure Data Warehouse output
Sample Request
PUT 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/DataWarehouse",
"properties": {
"table": "test2",
"server": "asatestserver",
"database": "zhayaSQLpool",
"user": "tolladmin",
"password": "password123"
}
}
}
}
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_Create_DataWarehouse.json
func ExampleOutputsClient_CreateOrReplace_createAnAzureDataWarehouseOutput() {
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().CreateOrReplace(ctx, "sjrg", "sjName", "dwOutput", armstreamanalytics.Output{
Properties: &armstreamanalytics.OutputProperties{
Datasource: &armstreamanalytics.AzureSynapseOutputDataSource{
Type: to.Ptr("Microsoft.Sql/Server/DataWarehouse"),
Properties: &armstreamanalytics.AzureSynapseOutputDataSourceProperties{
Database: to.Ptr("zhayaSQLpool"),
Password: to.Ptr("password123"),
Server: to.Ptr("asatestserver"),
Table: to.Ptr("test2"),
User: to.Ptr("tolladmin"),
},
},
},
}, &armstreamanalytics.OutputsClientCreateOrReplaceOptions{IfMatch: nil,
IfNoneMatch: nil,
})
if err != nil {
log.Fatalf("failed to finish the request: %v", err)
}
// You could use response here. We use blank identifier for just demo purposes.
_ = res
// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
// res.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("test2"),
// 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: 731a47c6-ff67-4439-bde6-a2a3da4c1ecf
{
"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": "test2",
"server": "asatestserver",
"database": "zhayaSQLpool",
"user": "tolladmin"
}
}
}
}
ETag: 731a47c6-ff67-4439-bde6-a2a3da4c1ecf
{
"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": "test2",
"server": "asatestserver",
"database": "zhayaSQLpool",
"user": "tolladmin"
}
}
}
}
Create an Azure Function output
Sample Request
PUT 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": {
"functionAppName": "functionappforasaautomation",
"functionName": "HttpTrigger2",
"apiKey": null,
"maxBatchSize": 256,
"maxBatchCount": 100
}
}
}
}
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_Create_AzureFunction.json
func ExampleOutputsClient_CreateOrReplace_createAnAzureFunctionOutput() {
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().CreateOrReplace(ctx, "sjrg", "sjName", "azureFunction1", armstreamanalytics.Output{
Properties: &armstreamanalytics.OutputProperties{
Datasource: &armstreamanalytics.AzureFunctionOutputDataSource{
Type: to.Ptr("Microsoft.AzureFunction"),
Properties: &armstreamanalytics.AzureFunctionOutputDataSourceProperties{
FunctionAppName: to.Ptr("functionappforasaautomation"),
FunctionName: to.Ptr("HttpTrigger2"),
MaxBatchCount: to.Ptr[float32](100),
MaxBatchSize: to.Ptr[float32](256),
},
},
},
}, &armstreamanalytics.OutputsClientCreateOrReplaceOptions{IfMatch: nil,
IfNoneMatch: nil,
})
if err != nil {
log.Fatalf("failed to finish the request: %v", err)
}
// You could use response here. We use blank identifier for just demo purposes.
_ = res
// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
// res.Output = armstreamanalytics.Output{
// Name: to.Ptr("azureFunction1"),
// Type: to.Ptr("Microsoft.StreamAnalytics/streamingjobs/outputs"),
// ID: to.Ptr("/subscriptions/7f31cba8-b597-4129-b158-8f21a7395bd0/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("HttpTrigger2"),
// MaxBatchCount: to.Ptr[float32](100),
// MaxBatchSize: to.Ptr[float32](256),
// },
// },
// Etag: to.Ptr("7b912929-346d-432e-9495-6972dbd63179"),
// },
// }
}
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: 731a47c6-ff67-4439-bde6-a2a3da4c1ecf
{
"id": "/subscriptions/7f31cba8-b597-4129-b158-8f21a7395bd0/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": "HttpTrigger2",
"apiKey": null,
"maxBatchSize": 256,
"maxBatchCount": 100
}
},
"etag": "7b912929-346d-432e-9495-6972dbd63179"
}
}
ETag: 731a47c6-ff67-4439-bde6-a2a3da4c1ecf
{
"id": "/subscriptions/7f31cba8-b597-4129-b158-8f21a7395bd0/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": "HttpTrigger2",
"apiKey": null,
"maxBatchSize": 256,
"maxBatchCount": 100
}
},
"etag": "7b912929-346d-432e-9495-6972dbd63179"
}
}
Create an Azure SQL database output
Sample Request
PUT 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": {
"server": "someServer",
"database": "someDatabase",
"user": "<user>",
"password": "somePassword",
"table": "someTable"
}
}
}
}
import com.azure.resourcemanager.streamanalytics.models.AzureSqlDatabaseOutputDataSource;
/** Samples for Outputs CreateOrReplace. */
public final class Main {
/*
* x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Create_AzureSQL.json
*/
/**
* Sample code: Create an Azure SQL database output.
*
* @param manager Entry point to StreamAnalyticsManager.
*/
public static void createAnAzureSQLDatabaseOutput(
com.azure.resourcemanager.streamanalytics.StreamAnalyticsManager manager) {
manager
.outputs()
.define("output1755")
.withExistingStreamingjob("sjrg2157", "sj6458")
.withDatasource(new AzureSqlDatabaseOutputDataSource())
.create();
}
}
To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue
package armstreamanalytics_test
import (
"context"
"log"
"github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/streamanalytics/armstreamanalytics"
)
// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/d55b8005f05b040b852c15e74a0f3e36494a15e1/specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Create_AzureSQL.json
func ExampleOutputsClient_CreateOrReplace_createAnAzureSqlDatabaseOutput() {
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().CreateOrReplace(ctx, "sjrg2157", "sj6458", "output1755", armstreamanalytics.Output{
Properties: &armstreamanalytics.OutputProperties{
Datasource: &armstreamanalytics.AzureSQLDatabaseOutputDataSource{
Type: to.Ptr("Microsoft.Sql/Server/Database"),
Properties: &armstreamanalytics.AzureSQLDatabaseOutputDataSourceProperties{
Database: to.Ptr("someDatabase"),
Password: to.Ptr("somePassword"),
Server: to.Ptr("someServer"),
Table: to.Ptr("someTable"),
User: to.Ptr("<user>"),
},
},
},
}, &armstreamanalytics.OutputsClientCreateOrReplaceOptions{IfMatch: nil,
IfNoneMatch: nil,
})
if err != nil {
log.Fatalf("failed to finish the request: %v", err)
}
// You could use response here. We use blank identifier for just demo purposes.
_ = res
// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
// res.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("someTable"),
// 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 Creates an output or replaces an already existing output under an existing streaming job.
*
* @summary Creates an output or replaces an already existing output under an existing streaming job.
* x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Create_AzureSQL.json
*/
async function createAnAzureSqlDatabaseOutput() {
const subscriptionId = "56b5e0a9-b645-407d-99b0-c64f86013e3d";
const resourceGroupName = "sjrg2157";
const jobName = "sj6458";
const outputName = "output1755";
const output = {
datasource: {
type: "Microsoft.Sql/Server/Database",
database: "someDatabase",
password: "somePassword",
server: "someServer",
table: "someTable",
user: "<user>",
},
};
const credential = new DefaultAzureCredential();
const client = new StreamAnalyticsManagementClient(credential, subscriptionId);
const result = await client.outputs.createOrReplace(
resourceGroupName,
jobName,
outputName,
output
);
console.log(result);
}
createAnAzureSqlDatabaseOutput().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: 731a47c6-ff67-4439-bde6-a2a3da4c1ecf
{
"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": "someTable",
"user": "someUser"
}
}
}
}
ETag: 731a47c6-ff67-4439-bde6-a2a3da4c1ecf
{
"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": "someTable",
"user": "someUser"
}
}
}
}
Create an Azure Table output
Sample Request
PUT 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": {
"accountName": "someAccountName",
"accountKey": "accountKey==",
"table": "samples",
"partitionKey": "partitionKey",
"rowKey": "rowKey",
"columnsToRemove": [
"column1",
"column2"
],
"batchSize": 25
}
}
}
}
import com.azure.resourcemanager.streamanalytics.models.AzureTableOutputDataSource;
import java.util.Arrays;
/** Samples for Outputs CreateOrReplace. */
public final class Main {
/*
* x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Create_AzureTable.json
*/
/**
* Sample code: Create an Azure Table output.
*
* @param manager Entry point to StreamAnalyticsManager.
*/
public static void createAnAzureTableOutput(
com.azure.resourcemanager.streamanalytics.StreamAnalyticsManager manager) {
manager
.outputs()
.define("output958")
.withExistingStreamingjob("sjrg5176", "sj2790")
.withDatasource(
new AzureTableOutputDataSource()
.withAccountName("someAccountName")
.withAccountKey("accountKey==")
.withTable("samples")
.withPartitionKey("partitionKey")
.withRowKey("rowKey")
.withColumnsToRemove(Arrays.asList("column1", "column2"))
.withBatchSize(25))
.create();
}
}
To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue
package armstreamanalytics_test
import (
"context"
"log"
"github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/streamanalytics/armstreamanalytics"
)
// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/d55b8005f05b040b852c15e74a0f3e36494a15e1/specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Create_AzureTable.json
func ExampleOutputsClient_CreateOrReplace_createAnAzureTableOutput() {
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().CreateOrReplace(ctx, "sjrg5176", "sj2790", "output958", armstreamanalytics.Output{
Properties: &armstreamanalytics.OutputProperties{
Datasource: &armstreamanalytics.AzureTableOutputDataSource{
Type: to.Ptr("Microsoft.Storage/Table"),
Properties: &armstreamanalytics.AzureTableOutputDataSourceProperties{
AccountKey: to.Ptr("accountKey=="),
AccountName: to.Ptr("someAccountName"),
BatchSize: to.Ptr[int32](25),
ColumnsToRemove: []*string{
to.Ptr("column1"),
to.Ptr("column2")},
PartitionKey: to.Ptr("partitionKey"),
RowKey: to.Ptr("rowKey"),
Table: to.Ptr("samples"),
},
},
},
}, &armstreamanalytics.OutputsClientCreateOrReplaceOptions{IfMatch: nil,
IfNoneMatch: nil,
})
if err != nil {
log.Fatalf("failed to finish the request: %v", err)
}
// You could use response here. We use blank identifier for just demo purposes.
_ = res
// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
// res.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("partitionKey"),
// 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 Creates an output or replaces an already existing output under an existing streaming job.
*
* @summary Creates an output or replaces an already existing output under an existing streaming job.
* x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Create_AzureTable.json
*/
async function createAnAzureTableOutput() {
const subscriptionId = "56b5e0a9-b645-407d-99b0-c64f86013e3d";
const resourceGroupName = "sjrg5176";
const jobName = "sj2790";
const outputName = "output958";
const output = {
datasource: {
type: "Microsoft.Storage/Table",
accountKey: "accountKey==",
accountName: "someAccountName",
batchSize: 25,
columnsToRemove: ["column1", "column2"],
partitionKey: "partitionKey",
rowKey: "rowKey",
table: "samples",
},
};
const credential = new DefaultAzureCredential();
const client = new StreamAnalyticsManagementClient(credential, subscriptionId);
const result = await client.outputs.createOrReplace(
resourceGroupName,
jobName,
outputName,
output
);
console.log(result);
}
createAnAzureTableOutput().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: 2409b6d1-c99c-405b-9a14-ea7833637038
{
"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": "partitionKey",
"rowKey": "rowKey",
"columnsToRemove": [
"column1",
"column2"
],
"batchSize": 25
}
}
}
}
ETag: 2409b6d1-c99c-405b-9a14-ea7833637038
{
"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": "partitionKey",
"rowKey": "rowKey",
"columnsToRemove": [
"column1",
"column2"
],
"batchSize": 25
}
}
}
}
Create an Event Hub output with JSON serialization
Sample Request
PUT 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": {
"serviceBusNamespace": "sdktest",
"sharedAccessPolicyName": "RootManageSharedAccessKey",
"sharedAccessPolicyKey": "sharedAccessPolicyKey=",
"eventHubName": "sdkeventhub",
"partitionKey": "partitionKey"
}
},
"serialization": {
"type": "Json",
"properties": {
"encoding": "UTF8",
"format": "Array"
}
}
}
}
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;
/** Samples for Outputs CreateOrReplace. */
public final class Main {
/*
* x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Create_EventHub_JSON.json
*/
/**
* Sample code: Create an Event Hub output with JSON serialization.
*
* @param manager Entry point to StreamAnalyticsManager.
*/
public static void createAnEventHubOutputWithJSONSerialization(
com.azure.resourcemanager.streamanalytics.StreamAnalyticsManager manager) {
manager
.outputs()
.define("output5195")
.withExistingStreamingjob("sjrg6912", "sj3310")
.withDatasource(
new EventHubOutputDataSource()
.withPartitionKey("partitionKey")
.withEventHubName("sdkeventhub")
.withServiceBusNamespace("sdktest")
.withSharedAccessPolicyName("RootManageSharedAccessKey")
.withSharedAccessPolicyKey("sharedAccessPolicyKey="))
.withSerialization(
new JsonSerialization().withEncoding(Encoding.UTF8).withFormat(JsonOutputSerializationFormat.ARRAY))
.create();
}
}
To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue
package armstreamanalytics_test
import (
"context"
"log"
"github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/streamanalytics/armstreamanalytics"
)
// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/d55b8005f05b040b852c15e74a0f3e36494a15e1/specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Create_EventHub_JSON.json
func ExampleOutputsClient_CreateOrReplace_createAnEventHubOutputWithJsonSerialization() {
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().CreateOrReplace(ctx, "sjrg6912", "sj3310", "output5195", armstreamanalytics.Output{
Properties: &armstreamanalytics.OutputProperties{
Datasource: &armstreamanalytics.EventHubOutputDataSource{
Type: to.Ptr("Microsoft.ServiceBus/EventHub"),
Properties: &armstreamanalytics.EventHubOutputDataSourceProperties{
ServiceBusNamespace: to.Ptr("sdktest"),
SharedAccessPolicyKey: to.Ptr("sharedAccessPolicyKey="),
SharedAccessPolicyName: to.Ptr("RootManageSharedAccessKey"),
EventHubName: to.Ptr("sdkeventhub"),
PartitionKey: to.Ptr("partitionKey"),
},
},
Serialization: &armstreamanalytics.JSONSerialization{
Type: to.Ptr(armstreamanalytics.EventSerializationTypeJSON),
Properties: &armstreamanalytics.JSONSerializationProperties{
Format: to.Ptr(armstreamanalytics.JSONOutputSerializationFormatArray),
Encoding: to.Ptr(armstreamanalytics.EncodingUTF8),
},
},
},
}, &armstreamanalytics.OutputsClientCreateOrReplaceOptions{IfMatch: nil,
IfNoneMatch: nil,
})
if err != nil {
log.Fatalf("failed to finish the request: %v", err)
}
// You could use response here. We use blank identifier for just demo purposes.
_ = res
// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
// res.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("partitionKey"),
// },
// },
// Serialization: &armstreamanalytics.JSONSerialization{
// Type: to.Ptr(armstreamanalytics.EventSerializationTypeJSON),
// Properties: &armstreamanalytics.JSONSerializationProperties{
// Format: to.Ptr(armstreamanalytics.JSONOutputSerializationFormatArray),
// 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 Creates an output or replaces an already existing output under an existing streaming job.
*
* @summary Creates an output or replaces an already existing output under an existing streaming job.
* x-ms-original-file: specification/streamanalytics/resource-manager/Microsoft.StreamAnalytics/stable/2020-03-01/examples/Output_Create_EventHub_JSON.json
*/
async function createAnEventHubOutputWithJsonSerialization() {
const subscriptionId = "56b5e0a9-b645-407d-99b0-c64f86013e3d";
const resourceGroupName = "sjrg6912";
const jobName = "sj3310";
const outputName = "output5195";
const output = {
datasource: {
type: "Microsoft.ServiceBus/EventHub",
eventHubName: "sdkeventhub",
partitionKey: "partitionKey",
serviceBusNamespace: "sdktest",
sharedAccessPolicyKey: "sharedAccessPolicyKey=",
sharedAccessPolicyName: "RootManageSharedAccessKey",
},
serialization: { type: "Json", format: "Array", encoding: "UTF8" },
};
const credential = new DefaultAzureCredential();
const client = new StreamAnalyticsManagementClient(credential, subscriptionId);
const result = await client.outputs.createOrReplace(
resourceGroupName,
jobName,
outputName,
output
);
console.log(result);
}
createAnEventHubOutputWithJsonSerialization().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: 5472168f-7317-4241-8b75-0c8d9d0ea804
{
"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": "partitionKey",
"serviceBusNamespace": "sdktest",
"sharedAccessPolicyName": "RootManageSharedAccessKey"
}
},
"serialization": {
"type": "Json",
"properties": {
"encoding": "UTF8",
"format": "Array"
}
}
}
}
ETag: 5472168f-7317-4241-8b75-0c8d9d0ea804
{
"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": "partitionKey",
"serviceBusNamespace": "sdktest",
"sharedAccessPolicyName": "RootManageSharedAccessKey"
}
},
"serialization": {
"type": "Json",
"properties": {
"encoding": "UTF8",
"format": "Array"
}
}
}
}
定義
AuthenticationMode
認証モード。 有効なモードは、 ConnectionString
、 Msi
および 'UserToken' です。
名前 |
型 |
説明 |
ConnectionString
|
string
|
|
Msi
|
string
|
|
UserToken
|
string
|
|
AvroSerialization
入力からのデータをシリアル化する方法、または Avro 形式で出力に書き込むときにデータをシリアル化する方法について説明します。
名前 |
型 |
説明 |
type
|
string:
Avro
|
入力または出力で使用されるシリアル化の種類を示します。 PUT (CreateOrReplace) 要求で必要です。
|
AzureDataLakeStoreOutputDataSource
Azure Data Lake Store の出力データ ソースについて説明します。
名前 |
型 |
既定値 |
説明 |
properties.accountName
|
string
|
|
Azure Data Lake Store アカウントの名前。 PUT (CreateOrReplace) 要求で必要です。
|
properties.authenticationMode
|
AuthenticationMode
|
ConnectionString
|
認証モード。
|
properties.dateFormat
|
string
|
|
日付の形式。 {date} が filePathPrefix 内のどこに表示される場合でも、代わりにこのプロパティの値が日付形式として使用されます。
|
properties.filePathPrefix
|
string
|
|
出力の書き込み先となるファイルの場所。 PUT (CreateOrReplace) 要求で必要です。
|
properties.refreshToken
|
string
|
|
データ ソースで認証するために使用できる有効なアクセス トークンを取得するために使用できる更新トークン。 現在、有効な更新トークンは Azure Portal 経由でのみ取得できます。 データ ソースを作成し、Azure Portal に移動してデータ ソースを認証するときに、有効な更新トークンでこのプロパティを更新するダミー文字列値をここに配置することをお勧めします。 PUT (CreateOrReplace) 要求で必要です。
|
properties.tenantId
|
string
|
|
更新トークンの取得に使用されるユーザーのテナント ID。 PUT (CreateOrReplace) 要求で必要です。
|
properties.timeFormat
|
string
|
|
時刻の形式。 {time} が filePathPrefix に表示される場合は、このプロパティの値が代わりに時刻形式として使用されます。
|
properties.tokenUserDisplayName
|
string
|
|
更新トークンの取得に使用されたユーザーのユーザー表示名。 このプロパティを使用すると、更新トークンを取得するために使用されたユーザーを覚えておくのに役立ちます。
|
properties.tokenUserPrincipalName
|
string
|
|
更新トークンの取得に使用されたユーザーのユーザー プリンシパル名 (UPN)。 このプロパティを使用すると、更新トークンを取得するために使用されたユーザーを覚えておくのに役立ちます。
|
type
|
string:
Microsoft.DataLake/Accounts
|
|
書き込まれるデータ ソース出力の種類を示します。 PUT (CreateOrReplace) 要求で必要です。
|
AzureFunctionOutputDataSource
AzureFunctionOutputDataSource のメタデータを定義します
名前 |
型 |
説明 |
properties.apiKey
|
string
|
別のサブスクリプションの Azure Functions を使用するには、ご自分の関数にアクセスするためのキーを指定します。
|
properties.functionAppName
|
string
|
Azure Functions アプリの名前です。
|
properties.functionName
|
string
|
ご自分の Azure Functions アプリ内にある関数の名前です。
|
properties.maxBatchCount
|
number
|
Azure Functions に送信される各バッチのイベントの最大数を指定できるプロパティです。 既定値は 100 です。
|
properties.maxBatchSize
|
number
|
ご自分の Azure Functions に送信される各出力バッチの最大サイズを設定できるプロパティです。 入力の単位はバイトです。 既定値は 262,144 バイト (256 KB) です。
|
type
|
string:
Microsoft.AzureFunction
|
書き込まれるデータ ソース出力の種類を示します。 PUT (CreateOrReplace) 要求で必要です。
|
AzureSqlDatabaseOutputDataSource
Azure SQL データベース出力データ ソースについて説明します。
名前 |
型 |
既定値 |
説明 |
properties.authenticationMode
|
AuthenticationMode
|
ConnectionString
|
認証モード。
|
properties.database
|
string
|
|
Azure SQL データベースの名前。 PUT (CreateOrReplace) 要求で必要です。
|
properties.maxBatchCount
|
number
|
|
Sql データベースへの書き込みの最大バッチ数。既定値は 10,000 です。 PUT 要求では省略可能。
|
properties.maxWriterCount
|
number
|
|
最大ライター数 (現在は 1 (単一ライター) と 0 (クエリ パーティションに基づく) のみが使用できます。 PUT 要求では省略可能。
|
properties.password
|
string
|
|
Azure SQL データベースへの接続に使用されるパスワード。 PUT (CreateOrReplace) 要求で必要です。
|
properties.server
|
string
|
|
Azure SQL データベースを含む SQL サーバーの名前。 PUT (CreateOrReplace) 要求で必要です。
|
properties.table
|
string
|
|
Azure SQL データベース内のテーブルの名前。 PUT (CreateOrReplace) 要求で必要です。
|
properties.user
|
string
|
|
Azure SQL データベースへの接続に使用するユーザー名。 PUT (CreateOrReplace) 要求で必要です。
|
type
|
string:
Microsoft.Sql/Server/Database
|
|
書き込まれるデータ ソース出力の種類を示します。 PUT (CreateOrReplace) 要求で必要です。
|
AzureSynapseOutputDataSource
Azure Synapse出力データ ソースについて説明します。
名前 |
型 |
説明 |
properties.database
|
string
|
Azure SQL データベースの名前。 PUT (CreateOrReplace) 要求で必要です。
|
properties.password
|
string
|
Azure SQL データベースへの接続に使用されるパスワード。 PUT (CreateOrReplace) 要求で必要です。
|
properties.server
|
string
|
Azure SQL データベースを含む SQL サーバーの名前。 PUT (CreateOrReplace) 要求で必要です。
|
properties.table
|
string
|
Azure SQL データベース内のテーブルの名前。 PUT (CreateOrReplace) 要求で必要です。
|
properties.user
|
string
|
Azure SQL データベースへの接続に使用するユーザー名。 PUT (CreateOrReplace) 要求で必要です。
|
type
|
string:
Microsoft.Sql/Server/DataWarehouse
|
書き込まれるデータ ソース出力の種類を示します。 PUT (CreateOrReplace) 要求で必要です。
|
AzureTableOutputDataSource
Azure Table 出力データ ソースについて説明します。
名前 |
型 |
説明 |
properties.accountKey
|
string
|
Azure Storage アカウントのアカウント キー。 PUT (CreateOrReplace) 要求で必要です。
|
properties.accountName
|
string
|
Azure ストレージ アカウントの名前。 PUT (CreateOrReplace) 要求で必要です。
|
properties.batchSize
|
integer
|
一度に Azure Table に書き込む行数。
|
properties.columnsToRemove
|
string[]
|
指定されている場合、配列の各項目は出力イベント エンティティから (存在する場合) 削除される列の名前になります。
|
properties.partitionKey
|
string
|
この要素は、Azure Table のパーティション キーとして使用されるクエリの SELECT ステートメントの列の名前を示します。 PUT (CreateOrReplace) 要求で必要です。
|
properties.rowKey
|
string
|
この要素は、Azure Table の行キーとして使用されるクエリの SELECT ステートメントの列の名前を示します。 PUT (CreateOrReplace) 要求で必要です。
|
properties.table
|
string
|
Azure テーブルの名前。 PUT (CreateOrReplace) 要求で必要です。
|
type
|
string:
Microsoft.Storage/Table
|
書き込まれるデータ ソース出力の種類を示します。 PUT (CreateOrReplace) 要求で必要です。
|
BlobOutputDataSource
BLOB 出力データ ソースについて説明します。
CsvSerialization
入力からのデータをシリアル化する方法、または CSV 形式で出力に書き込むときにデータをシリアル化する方法について説明します。
DiagnosticCondition
顧客の注意を必要とするリソースまたはジョブ全体に適用される条件。
名前 |
型 |
説明 |
code
|
string
|
不透明な診断コード。
|
message
|
string
|
条件を詳しく説明する人間が判読できるメッセージ。 クライアント要求の Accept-Language にローカライズされます。
|
since
|
string
|
条件が開始されたときの UTC タイムスタンプ。 この時点で、お客様は ops ログで対応するイベントを見つけることができます。
|
Diagnostics
入力、出力、またはジョブ全体に適用できる、顧客の注意を必要とする条件について説明します。
DocumentDbOutputDataSource
DocumentDB 出力データ ソースについて説明します。
名前 |
型 |
説明 |
properties.accountId
|
string
|
DocumentDB アカウント名または ID。 PUT (CreateOrReplace) 要求で必要です。
|
properties.accountKey
|
string
|
DocumentDB アカウントのアカウント キー。 PUT (CreateOrReplace) 要求で必要です。
|
properties.collectionNamePattern
|
string
|
使用するコレクションのコレクション名のパターン。 コレクション名の形式は、オプションの {partition} トークンを使用して構成できます。この場合、パーティションは 0 から開始します。 詳細については、 の DocumentDB セクション https://docs.microsoft.com/en-us/rest/api/streamanalytics/stream-analytics-output を参照してください。 PUT (CreateOrReplace) 要求で必要です。
|
properties.database
|
string
|
DocumentDB データベースの名前。 PUT (CreateOrReplace) 要求で必要です。
|
properties.documentId
|
string
|
挿入または更新操作の基準となるプライマリ キーを指定するために使用される、出力イベント内のフィールドの名前。
|
properties.partitionKey
|
string
|
コレクション全体で出力をパーティション分割するためのキーを指定するために使用される、出力イベント内のフィールドの名前。 'collectionNamePattern' に {partition} トークンが含まれている場合は、このプロパティを指定する必要があります。
|
type
|
string:
Microsoft.Storage/DocumentDB
|
書き込まれるデータ ソース出力の種類を示します。 PUT (CreateOrReplace) 要求で必要です。
|
Encoding
入力の場合の受信データのエンコードと、出力の場合の送信データのエンコードを指定します。
Error
一般的なエラー表現。
名前 |
型 |
説明 |
error
|
Error
|
エラー定義のプロパティ。
|
EventHubOutputDataSource
Event Hub 出力データ ソースについて説明します。
名前 |
型 |
既定値 |
説明 |
authenticationMode
|
AuthenticationMode
|
ConnectionString
|
認証モード。
|
properties.eventHubName
|
string
|
|
イベント ハブの名前。 PUT (CreateOrReplace) 要求で必要です。
|
properties.partitionKey
|
string
|
|
イベント データを送信するパーティションを決定するために使用されるキー/列。
|
properties.propertyColumns
|
string[]
|
|
このイベント ハブ出力に関連付けられているプロパティ。
|
serviceBusNamespace
|
string
|
|
目的のイベント ハブ、Service Bus キュー、Service Bus トピックなどに関連付けられている名前空間。PUT (CreateOrReplace) 要求で必要です。
|
sharedAccessPolicyKey
|
string
|
|
指定した共有アクセス ポリシーの共有アクセス ポリシー キー。 PUT (CreateOrReplace) 要求で必要です。
|
sharedAccessPolicyName
|
string
|
|
イベント ハブ、Service Bus キュー、Service Bus トピックなどの共有アクセス ポリシー名。PUT (CreateOrReplace) 要求で必要です。
|
type
|
string:
Microsoft.ServiceBus/EventHub
|
|
書き込まれるデータ ソース出力の種類を示します。 PUT (CreateOrReplace) 要求で必要です。
|
EventHubV2OutputDataSource
Event Hub 出力データ ソースについて説明します。
名前 |
型 |
既定値 |
説明 |
authenticationMode
|
AuthenticationMode
|
ConnectionString
|
認証モード。
|
properties.eventHubName
|
string
|
|
イベント ハブの名前。 PUT (CreateOrReplace) 要求で必要です。
|
properties.partitionKey
|
string
|
|
イベント データを送信するパーティションを決定するために使用されるキー/列。
|
properties.propertyColumns
|
string[]
|
|
このイベント ハブ出力に関連付けられているプロパティ。
|
serviceBusNamespace
|
string
|
|
目的のイベント ハブ、Service Bus キュー、Service Bus トピックなどに関連付けられている名前空間。PUT (CreateOrReplace) 要求で必要です。
|
sharedAccessPolicyKey
|
string
|
|
指定した共有アクセス ポリシーの共有アクセス ポリシー キー。 PUT (CreateOrReplace) 要求で必要です。
|
sharedAccessPolicyName
|
string
|
|
イベント ハブ、Service Bus キュー、Service Bus トピックなどの共有アクセス ポリシー名。PUT (CreateOrReplace) 要求で必要です。
|
type
|
string:
Microsoft.EventHub/EventHub
|
|
書き込まれるデータ ソース出力の種類を示します。 PUT (CreateOrReplace) 要求で必要です。
|
EventSerializationType
入力または出力で使用されるシリアル化の種類を示します。 PUT (CreateOrReplace) 要求で必要です。
名前 |
型 |
説明 |
Avro
|
string
|
|
Csv
|
string
|
|
Json
|
string
|
|
Parquet
|
string
|
|
GatewayMessageBusOutputDataSource
ゲートウェイ メッセージ バス出力データ ソースについて説明します。
名前 |
型 |
説明 |
properties.topic
|
string
|
Service Bus トピックの名前。
|
type
|
string:
GatewayMessageBus
|
書き込まれるデータ ソース出力の種類を示します。 PUT (CreateOrReplace) 要求で必要です。
|
出力が書き込まれる JSON の形式を指定します。 現在サポートされている値は、出力が新しい行で区切られた各 JSON オブジェクトを使用して書式設定されることを示す 'lineSeparated' と、出力が JSON オブジェクトの配列として書式設定されることを示す 'array' です。
名前 |
型 |
説明 |
Array
|
string
|
|
LineSeparated
|
string
|
|
JsonSerialization
入力からのデータをシリアル化する方法、または JSON 形式で出力に書き込むときにデータをシリアル化する方法について説明します。
名前 |
型 |
説明 |
properties.encoding
|
Encoding
|
入力の場合の受信データのエンコードと、出力の場合の送信データのエンコードを指定します。 PUT (CreateOrReplace) 要求で必要です。
|
properties.format
|
JsonOutputSerializationFormat
|
このプロパティは、出力の JSON シリアル化にのみ適用されます。 入力には適用されません。 このプロパティは、出力が書き込まれる JSON の形式を指定します。 現在サポートされている値は、出力が新しい行で区切られた各 JSON オブジェクトを使用して書式設定されることを示す 'lineSeparated' と、出力が JSON オブジェクトの配列として書式設定されることを示す 'array' です。 左 null の場合、既定値は 'lineSeparated' です。
|
type
|
string:
Json
|
入力または出力で使用されるシリアル化の種類を示します。 PUT (CreateOrReplace) 要求で必要です。
|
Output
名前付き出力に関連付けられているすべての情報を含む出力オブジェクト。 すべての出力はストリーミング ジョブの下に含まれます。
名前 |
型 |
説明 |
id
|
string
|
リソース ID
|
name
|
string
|
リソース名
|
properties.datasource
|
OutputDataSource:
|
出力の書き込み先となるデータ ソースについて説明します。 PUT (CreateOrReplace) 要求で必要です。
|
properties.diagnostics
|
Diagnostics
|
入力、出力、またはジョブ全体に適用できる、顧客の注意を必要とする条件について説明します。
|
properties.etag
|
string
|
出力の現在のエンティティ タグ。 これは不透明な文字列です。 これを使用して、要求間でリソースが変更されたかどうかを検出できます。 また、オプティミスティック コンカレンシーの書き込み操作に対して、If-Match ヘッダーまたは If-None-Match ヘッダーで使用することもできます。
|
properties.serialization
|
Serialization:
|
入力からのデータをシリアル化する方法、または出力に書き込むときにデータをシリアル化する方法について説明します。 PUT (CreateOrReplace) 要求で必要です。
|
properties.sizeWindow
|
integer
|
Stream Analytics の出力を制限するサイズ ウィンドウ。
|
properties.timeWindow
|
string
|
Stream Analytics ジョブ出力をフィルター処理するための時間枠。
|
type
|
string
|
リソースの種類
|
ParquetSerialization
入力からのデータをシリアル化する方法、または Parquet 形式で出力に書き込むときにデータをシリアル化する方法について説明します。
名前 |
型 |
説明 |
type
|
string:
Parquet
|
入力または出力で使用されるシリアル化の種類を示します。 PUT (CreateOrReplace) 要求で必要です。
|
PowerBIOutputDataSource
Power BI 出力データ ソースについて説明します。
名前 |
型 |
既定値 |
説明 |
properties.authenticationMode
|
AuthenticationMode
|
ConnectionString
|
認証モード。
|
properties.dataset
|
string
|
|
Power BI データセットの名前。 PUT (CreateOrReplace) 要求で必要です。
|
properties.groupId
|
string
|
|
Power BI グループの ID。
|
properties.groupName
|
string
|
|
Power BI グループの名前。 このプロパティを使用すると、使用された特定の Power BI グループ ID を覚えておくのに役立ちます。
|
properties.refreshToken
|
string
|
|
データ ソースで認証するために使用できる有効なアクセス トークンを取得するために使用できる更新トークン。 現在、有効な更新トークンは Azure Portal 経由でのみ取得できます。 データ ソースを作成し、Azure Portal に移動してデータ ソースを認証するときに、有効な更新トークンでこのプロパティを更新するダミー文字列値をここに配置することをお勧めします。 PUT (CreateOrReplace) 要求で必要です。
|
properties.table
|
string
|
|
指定したデータセットの下にある Power BI テーブルの名前。 PUT (CreateOrReplace) 要求で必要です。
|
properties.tokenUserDisplayName
|
string
|
|
更新トークンの取得に使用されたユーザーのユーザー表示名。 このプロパティを使用すると、更新トークンを取得するために使用されたユーザーを覚えておくのに役立ちます。
|
properties.tokenUserPrincipalName
|
string
|
|
更新トークンの取得に使用されたユーザーのユーザー プリンシパル名 (UPN)。 このプロパティを使用すると、更新トークンを取得するために使用されたユーザーを覚えておくのに役立ちます。
|
type
|
string:
PowerBI
|
|
書き込まれるデータ ソース出力の種類を示します。 PUT (CreateOrReplace) 要求で必要です。
|
ServiceBusQueueOutputDataSource
Service Bus キューの出力データ ソースについて説明します。
名前 |
型 |
既定値 |
説明 |
properties.authenticationMode
|
AuthenticationMode
|
ConnectionString
|
認証モード。
|
properties.propertyColumns
|
string[]
|
|
Service Bus メッセージにカスタム プロパティとしてアタッチする出力列の名前の文字列配列。
|
properties.queueName
|
string
|
|
Service Bus キューの名前。 PUT (CreateOrReplace) 要求で必要です。
|
properties.serviceBusNamespace
|
string
|
|
目的のイベント ハブ、Service Bus キュー、Service Bus トピックなどに関連付けられている名前空間。PUT (CreateOrReplace) 要求で必要です。
|
properties.sharedAccessPolicyKey
|
string
|
|
指定した共有アクセス ポリシーの共有アクセス ポリシー キー。 PUT (CreateOrReplace) 要求で必要です。
|
properties.sharedAccessPolicyName
|
string
|
|
イベント ハブ、Service Bus キュー、Service Bus トピックなどの共有アクセス ポリシー名。PUT (CreateOrReplace) 要求で必要です。
|
properties.systemPropertyColumns
|
object
|
|
Service Bus キューに関連付けられているシステム プロパティ。 次のシステム プロパティがサポートされています: ReplyToSessionId、ContentType、To、Subject、CorrelationId、TimeToLive、PartitionKey、SessionId、ScheduledEnqueueTime、MessageId、ReplyTo、Label、ScheduledEnqueueTimeUtc。
|
type
|
string:
Microsoft.ServiceBus/Queue
|
|
書き込まれるデータ ソース出力の種類を示します。 PUT (CreateOrReplace) 要求で必要です。
|
ServiceBusTopicOutputDataSource
Service Bus トピック出力データ ソースについて説明します。
名前 |
型 |
既定値 |
説明 |
properties.authenticationMode
|
AuthenticationMode
|
ConnectionString
|
認証モード。
|
properties.propertyColumns
|
string[]
|
|
Service Bus メッセージにカスタム プロパティとしてアタッチする出力列の名前の文字列配列。
|
properties.serviceBusNamespace
|
string
|
|
目的のイベント ハブ、Service Bus キュー、Service Bus トピックなどに関連付けられている名前空間。PUT (CreateOrReplace) 要求で必要です。
|
properties.sharedAccessPolicyKey
|
string
|
|
指定した共有アクセス ポリシーの共有アクセス ポリシー キー。 PUT (CreateOrReplace) 要求で必要です。
|
properties.sharedAccessPolicyName
|
string
|
|
イベント ハブ、Service Bus キュー、Service Bus トピックなどの共有アクセス ポリシー名。PUT (CreateOrReplace) 要求で必要です。
|
properties.systemPropertyColumns
|
object
|
|
Service Bus トピック出力に関連付けられているシステム プロパティ。 次のシステム プロパティがサポートされています: ReplyToSessionId、ContentType、To、Subject、CorrelationId、TimeToLive、PartitionKey、SessionId、ScheduledEnqueueTime、MessageId、ReplyTo、Label、ScheduledEnqueueTimeUtc。
|
properties.topicName
|
string
|
|
Service Bus トピックの名前。 PUT (CreateOrReplace) 要求で必要です。
|
type
|
string:
Microsoft.ServiceBus/Topic
|
|
書き込まれるデータ ソース出力の種類を示します。 PUT (CreateOrReplace) 要求で必要です。
|
StorageAccount
Azure Storage アカウントに関連付けられているプロパティ
名前 |
型 |
説明 |
accountKey
|
string
|
Azure Storage アカウントのアカウント キー。 PUT (CreateOrReplace) 要求で必要です。
|
accountName
|
string
|
Azure ストレージ アカウントの名前。 PUT (CreateOrReplace) 要求で必要です。
|