Output
data class OutputMssqlArgs(val authenticationMode: Output<String>? = null, val database: Output<String>? = null, val maxBatchCount: Output<Double>? = null, val maxWriterCount: Output<Double>? = null, val name: Output<String>? = null, val password: Output<String>? = null, val resourceGroupName: Output<String>? = null, val server: Output<String>? = null, val streamAnalyticsJobName: Output<String>? = null, val table: Output<String>? = null, val user: Output<String>? = null) : ConvertibleToJava<OutputMssqlArgs>
Manages a Stream Analytics Output to Microsoft SQL Server Database.
Example Usage
import * as pulumi from "@pulumi/pulumi";
import * as azure from "@pulumi/azure";
import * as azurerm from "@pulumi/azurerm";
const exampleResourceGroup = new azure.core.ResourceGroup("example", {
name: "rg-example",
location: "West Europe",
});
const example = azure.streamanalytics.getJobOutput({
name: "example-job",
resourceGroupName: exampleResourceGroup.name,
});
const exampleSqlServer = new azurerm.index.SqlServer("example", {
name: "example-server",
resourceGroupName: exampleResourceGroup.name,
location: exampleResourceGroup.location,
version: "12.0",
administratorLogin: "dbadmin",
administratorLoginPassword: "example-password",
});
const exampleSqlDatabase = new azurerm.index.SqlDatabase("example", {
name: "exampledb",
resourceGroupName: exampleResourceGroup.name,
location: exampleResourceGroup.location,
serverName: exampleSqlServer.name,
requestedServiceObjectiveName: "S0",
collation: "SQL_LATIN1_GENERAL_CP1_CI_AS",
maxSizeBytes: "268435456000",
createMode: "Default",
});
const exampleOutputMssql = new azure.streamanalytics.OutputMssql("example", {
name: "example-output-sql",
streamAnalyticsJobName: example.apply(example => example.name),
resourceGroupName: example.apply(example => example.resourceGroupName),
server: exampleSqlServer.fullyQualifiedDomainName,
user: exampleSqlServer.administratorLogin,
password: exampleSqlServer.administratorLoginPassword,
database: exampleSqlDatabase.name,
table: "ExampleTable",
});Content copied to clipboard
import pulumi
import pulumi_azure as azure
import pulumi_azurerm as azurerm
example_resource_group = azure.core.ResourceGroup("example",
name="rg-example",
location="West Europe")
example = azure.streamanalytics.get_job_output(name="example-job",
resource_group_name=example_resource_group.name)
example_sql_server = azurerm.index.SqlServer("example",
name=example-server,
resource_group_name=example_resource_group.name,
location=example_resource_group.location,
version=12.0,
administrator_login=dbadmin,
administrator_login_password=example-password)
example_sql_database = azurerm.index.SqlDatabase("example",
name=exampledb,
resource_group_name=example_resource_group.name,
location=example_resource_group.location,
server_name=example_sql_server.name,
requested_service_objective_name=S0,
collation=SQL_LATIN1_GENERAL_CP1_CI_AS,
max_size_bytes=268435456000,
create_mode=Default)
example_output_mssql = azure.streamanalytics.OutputMssql("example",
name="example-output-sql",
stream_analytics_job_name=example.name,
resource_group_name=example.resource_group_name,
server=example_sql_server["fullyQualifiedDomainName"],
user=example_sql_server["administratorLogin"],
password=example_sql_server["administratorLoginPassword"],
database=example_sql_database["name"],
table="ExampleTable")Content copied to clipboard
using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Azure = Pulumi.Azure;
using Azurerm = Pulumi.Azurerm;
return await Deployment.RunAsync(() =>
{
var exampleResourceGroup = new Azure.Core.ResourceGroup("example", new()
{
Name = "rg-example",
Location = "West Europe",
});
var example = Azure.StreamAnalytics.GetJob.Invoke(new()
{
Name = "example-job",
ResourceGroupName = exampleResourceGroup.Name,
});
var exampleSqlServer = new Azurerm.Index.SqlServer("example", new()
{
Name = "example-server",
ResourceGroupName = exampleResourceGroup.Name,
Location = exampleResourceGroup.Location,
Version = "12.0",
AdministratorLogin = "dbadmin",
AdministratorLoginPassword = "example-password",
});
var exampleSqlDatabase = new Azurerm.Index.SqlDatabase("example", new()
{
Name = "exampledb",
ResourceGroupName = exampleResourceGroup.Name,
Location = exampleResourceGroup.Location,
ServerName = exampleSqlServer.Name,
RequestedServiceObjectiveName = "S0",
Collation = "SQL_LATIN1_GENERAL_CP1_CI_AS",
MaxSizeBytes = "268435456000",
CreateMode = "Default",
});
var exampleOutputMssql = new Azure.StreamAnalytics.OutputMssql("example", new()
{
Name = "example-output-sql",
StreamAnalyticsJobName = example.Apply(getJobResult => getJobResult.Name),
ResourceGroupName = example.Apply(getJobResult => getJobResult.ResourceGroupName),
Server = exampleSqlServer.FullyQualifiedDomainName,
User = exampleSqlServer.AdministratorLogin,
Password = exampleSqlServer.AdministratorLoginPassword,
Database = exampleSqlDatabase.Name,
Table = "ExampleTable",
});
});Content copied to clipboard
package main
import (
"github.com/pulumi/pulumi-azure/sdk/v6/go/azure/core"
"github.com/pulumi/pulumi-azure/sdk/v6/go/azure/streamanalytics"
"github.com/pulumi/pulumi-azurerm/sdk/go/azurerm"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
pulumi.Run(func(ctx *pulumi.Context) error {
exampleResourceGroup, err := core.NewResourceGroup(ctx, "example", &core.ResourceGroupArgs{
Name: pulumi.String("rg-example"),
Location: pulumi.String("West Europe"),
})
if err != nil {
return err
}
example := streamanalytics.LookupJobOutput(ctx, streamanalytics.GetJobOutputArgs{
Name: pulumi.String("example-job"),
ResourceGroupName: exampleResourceGroup.Name,
}, nil)
exampleSqlServer, err := azurerm.NewSqlServer(ctx, "example", &azurerm.SqlServerArgs{
Name: "example-server",
ResourceGroupName: exampleResourceGroup.Name,
Location: exampleResourceGroup.Location,
Version: "12.0",
AdministratorLogin: "dbadmin",
AdministratorLoginPassword: "example-password",
})
if err != nil {
return err
}
exampleSqlDatabase, err := azurerm.NewSqlDatabase(ctx, "example", &azurerm.SqlDatabaseArgs{
Name: "exampledb",
ResourceGroupName: exampleResourceGroup.Name,
Location: exampleResourceGroup.Location,
ServerName: exampleSqlServer.Name,
RequestedServiceObjectiveName: "S0",
Collation: "SQL_LATIN1_GENERAL_CP1_CI_AS",
MaxSizeBytes: "268435456000",
CreateMode: "Default",
})
if err != nil {
return err
}
_, err = streamanalytics.NewOutputMssql(ctx, "example", &streamanalytics.OutputMssqlArgs{
Name: pulumi.String("example-output-sql"),
StreamAnalyticsJobName: pulumi.String(example.ApplyT(func(example streamanalytics.GetJobResult) (*string, error) {
return &example.Name, nil
}).(pulumi.StringPtrOutput)),
ResourceGroupName: pulumi.String(example.ApplyT(func(example streamanalytics.GetJobResult) (*string, error) {
return &example.ResourceGroupName, nil
}).(pulumi.StringPtrOutput)),
Server: exampleSqlServer.FullyQualifiedDomainName,
User: exampleSqlServer.AdministratorLogin,
Password: exampleSqlServer.AdministratorLoginPassword,
Database: exampleSqlDatabase.Name,
Table: pulumi.String("ExampleTable"),
})
if err != nil {
return err
}
return nil
})
}Content copied to clipboard
package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.azure.core.ResourceGroup;
import com.pulumi.azure.core.ResourceGroupArgs;
import com.pulumi.azure.streamanalytics.StreamanalyticsFunctions;
import com.pulumi.azure.streamanalytics.inputs.GetJobArgs;
import com.pulumi.azurerm.sqlServer;
import com.pulumi.azurerm.SqlServerArgs;
import com.pulumi.azurerm.sqlDatabase;
import com.pulumi.azurerm.SqlDatabaseArgs;
import com.pulumi.azure.streamanalytics.OutputMssql;
import com.pulumi.azure.streamanalytics.OutputMssqlArgs;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;
public class App {
public static void main(String[] args) {
Pulumi.run(App::stack);
}
public static void stack(Context ctx) {
var exampleResourceGroup = new ResourceGroup("exampleResourceGroup", ResourceGroupArgs.builder()
.name("rg-example")
.location("West Europe")
.build());
final var example = StreamanalyticsFunctions.getJob(GetJobArgs.builder()
.name("example-job")
.resourceGroupName(exampleResourceGroup.name())
.build());
var exampleSqlServer = new SqlServer("exampleSqlServer", SqlServerArgs.builder()
.name("example-server")
.resourceGroupName(exampleResourceGroup.name())
.location(exampleResourceGroup.location())
.version("12.0")
.administratorLogin("dbadmin")
.administratorLoginPassword("example-password")
.build());
var exampleSqlDatabase = new SqlDatabase("exampleSqlDatabase", SqlDatabaseArgs.builder()
.name("exampledb")
.resourceGroupName(exampleResourceGroup.name())
.location(exampleResourceGroup.location())
.serverName(exampleSqlServer.name())
.requestedServiceObjectiveName("S0")
.collation("SQL_LATIN1_GENERAL_CP1_CI_AS")
.maxSizeBytes("268435456000")
.createMode("Default")
.build());
var exampleOutputMssql = new OutputMssql("exampleOutputMssql", OutputMssqlArgs.builder()
.name("example-output-sql")
.streamAnalyticsJobName(example.applyValue(getJobResult -> getJobResult).applyValue(example -> example.applyValue(getJobResult -> getJobResult.name())))
.resourceGroupName(example.applyValue(getJobResult -> getJobResult).applyValue(example -> example.applyValue(getJobResult -> getJobResult.resourceGroupName())))
.server(exampleSqlServer.fullyQualifiedDomainName())
.user(exampleSqlServer.administratorLogin())
.password(exampleSqlServer.administratorLoginPassword())
.database(exampleSqlDatabase.name())
.table("ExampleTable")
.build());
}
}Content copied to clipboard
resources:
exampleResourceGroup:
type: azure:core:ResourceGroup
name: example
properties:
name: rg-example
location: West Europe
exampleSqlServer:
type: azurerm:sqlServer
name: example
properties:
name: example-server
resourceGroupName: ${exampleResourceGroup.name}
location: ${exampleResourceGroup.location}
version: '12.0'
administratorLogin: dbadmin
administratorLoginPassword: example-password
exampleSqlDatabase:
type: azurerm:sqlDatabase
name: example
properties:
name: exampledb
resourceGroupName: ${exampleResourceGroup.name}
location: ${exampleResourceGroup.location}
serverName: ${exampleSqlServer.name}
requestedServiceObjectiveName: S0
collation: SQL_LATIN1_GENERAL_CP1_CI_AS
maxSizeBytes: '268435456000'
createMode: Default
exampleOutputMssql:
type: azure:streamanalytics:OutputMssql
name: example
properties:
name: example-output-sql
streamAnalyticsJobName: ${example.name}
resourceGroupName: ${example.resourceGroupName}
server: ${exampleSqlServer.fullyQualifiedDomainName}
user: ${exampleSqlServer.administratorLogin}
password: ${exampleSqlServer.administratorLoginPassword}
database: ${exampleSqlDatabase.name}
table: ExampleTable
variables:
example:
fn::invoke:
function: azure:streamanalytics:getJob
arguments:
name: example-job
resourceGroupName: ${exampleResourceGroup.name}Content copied to clipboard
Import
Stream Analytics Outputs to Microsoft SQL Server Database can be imported using the resource id, e.g.
$ pulumi import azure:streamanalytics/outputMssql:OutputMssql example /subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/group1/providers/Microsoft.StreamAnalytics/streamingJobs/job1/outputs/output1Content copied to clipboard
Constructors
Link copied to clipboard
constructor(authenticationMode: Output<String>? = null, database: Output<String>? = null, maxBatchCount: Output<Double>? = null, maxWriterCount: Output<Double>? = null, name: Output<String>? = null, password: Output<String>? = null, resourceGroupName: Output<String>? = null, server: Output<String>? = null, streamAnalyticsJobName: Output<String>? = null, table: Output<String>? = null, user: Output<String>? = null)
Properties
Link copied to clipboard
The authentication mode for the Stream Output. Possible values are Msi and ConnectionString. Defaults to ConnectionString.
Link copied to clipboard
The max batch count to write to the SQL Database. Defaults to 10000. Possible values are between 1 and 1073741824.
Link copied to clipboard
The max writer count for the SQL Database. Defaults to 1. Possible values are 0 which bases the writer count on the query partition and 1 which corresponds to a single writer.
Link copied to clipboard
The name of the Resource Group where the Stream Analytics Job exists. Changing this forces a new resource to be created.
Link copied to clipboard
The name of the Stream Analytics Job. Changing this forces a new resource to be created.