Reference
data class ReferenceInputMssqlArgs(val database: Output<String>? = null, val deltaSnapshotQuery: Output<String>? = null, val fullSnapshotQuery: Output<String>? = null, val name: Output<String>? = null, val password: Output<String>? = null, val refreshIntervalDuration: Output<String>? = null, val refreshType: Output<String>? = null, val resourceGroupName: Output<String>? = null, val server: Output<String>? = null, val streamAnalyticsJobName: Output<String>? = null, val table: Output<String>? = null, val username: Output<String>? = null) : ConvertibleToJava<ReferenceInputMssqlArgs>
Manages a Stream Analytics Reference Input from MS SQL. Reference data (also known as a lookup table) is a finite data set that is static or slowly changing in nature, used to perform a lookup or to correlate with your data stream. Learn more here.
Example Usage
import * as pulumi from "@pulumi/pulumi";
import * as azure from "@pulumi/azure";
const exampleResourceGroup = new azure.core.ResourceGroup("example", {
name: "example-resources",
location: "West Europe",
});
const example = azure.streamanalytics.getJobOutput({
name: "example-job",
resourceGroupName: exampleResourceGroup.name,
});
const exampleServer = new azure.mssql.Server("example", {
name: "example-sqlserver",
resourceGroupName: exampleResourceGroup.name,
location: exampleResourceGroup.location,
version: "12.0",
administratorLogin: "admin",
administratorLoginPassword: "password",
});
const exampleDatabase = new azure.mssql.Database("example", {
name: "example-db",
serverId: exampleServer.id,
});
const exampleReferenceInputMssql = new azure.streamanalytics.ReferenceInputMssql("example", {
name: "example-reference-input",
resourceGroupName: example.apply(example => example.resourceGroupName),
streamAnalyticsJobName: example.apply(example => example.name),
server: exampleServer.fullyQualifiedDomainName,
database: exampleDatabase.name,
username: "exampleuser",
password: "examplepassword",
refreshType: "RefreshPeriodicallyWithFull",
refreshIntervalDuration: "00:20:00",
fullSnapshotQuery: ` SELECT *
INTO [YourOutputAlias]
FROM [YourInputAlias]
`,
});Content copied to clipboard
import pulumi
import pulumi_azure as azure
example_resource_group = azure.core.ResourceGroup("example",
name="example-resources",
location="West Europe")
example = azure.streamanalytics.get_job_output(name="example-job",
resource_group_name=example_resource_group.name)
example_server = azure.mssql.Server("example",
name="example-sqlserver",
resource_group_name=example_resource_group.name,
location=example_resource_group.location,
version="12.0",
administrator_login="admin",
administrator_login_password="password")
example_database = azure.mssql.Database("example",
name="example-db",
server_id=example_server.id)
example_reference_input_mssql = azure.streamanalytics.ReferenceInputMssql("example",
name="example-reference-input",
resource_group_name=example.resource_group_name,
stream_analytics_job_name=example.name,
server=example_server.fully_qualified_domain_name,
database=example_database.name,
username="exampleuser",
password="examplepassword",
refresh_type="RefreshPeriodicallyWithFull",
refresh_interval_duration="00:20:00",
full_snapshot_query=""" SELECT *
INTO [YourOutputAlias]
FROM [YourInputAlias]
""")Content copied to clipboard
using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Azure = Pulumi.Azure;
return await Deployment.RunAsync(() =>
{
var exampleResourceGroup = new Azure.Core.ResourceGroup("example", new()
{
Name = "example-resources",
Location = "West Europe",
});
var example = Azure.StreamAnalytics.GetJob.Invoke(new()
{
Name = "example-job",
ResourceGroupName = exampleResourceGroup.Name,
});
var exampleServer = new Azure.MSSql.Server("example", new()
{
Name = "example-sqlserver",
ResourceGroupName = exampleResourceGroup.Name,
Location = exampleResourceGroup.Location,
Version = "12.0",
AdministratorLogin = "admin",
AdministratorLoginPassword = "password",
});
var exampleDatabase = new Azure.MSSql.Database("example", new()
{
Name = "example-db",
ServerId = exampleServer.Id,
});
var exampleReferenceInputMssql = new Azure.StreamAnalytics.ReferenceInputMssql("example", new()
{
Name = "example-reference-input",
ResourceGroupName = example.Apply(getJobResult => getJobResult.ResourceGroupName),
StreamAnalyticsJobName = example.Apply(getJobResult => getJobResult.Name),
Server = exampleServer.FullyQualifiedDomainName,
Database = exampleDatabase.Name,
Username = "exampleuser",
Password = "examplepassword",
RefreshType = "RefreshPeriodicallyWithFull",
RefreshIntervalDuration = "00:20:00",
FullSnapshotQuery = @" SELECT *
INTO [YourOutputAlias]
FROM [YourInputAlias]
",
});
});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/mssql"
"github.com/pulumi/pulumi-azure/sdk/v6/go/azure/streamanalytics"
"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("example-resources"),
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)
exampleServer, err := mssql.NewServer(ctx, "example", &mssql.ServerArgs{
Name: pulumi.String("example-sqlserver"),
ResourceGroupName: exampleResourceGroup.Name,
Location: exampleResourceGroup.Location,
Version: pulumi.String("12.0"),
AdministratorLogin: pulumi.String("admin"),
AdministratorLoginPassword: pulumi.String("password"),
})
if err != nil {
return err
}
exampleDatabase, err := mssql.NewDatabase(ctx, "example", &mssql.DatabaseArgs{
Name: pulumi.String("example-db"),
ServerId: exampleServer.ID(),
})
if err != nil {
return err
}
_, err = streamanalytics.NewReferenceInputMssql(ctx, "example", &streamanalytics.ReferenceInputMssqlArgs{
Name: pulumi.String("example-reference-input"),
ResourceGroupName: pulumi.String(example.ApplyT(func(example streamanalytics.GetJobResult) (*string, error) {
return &example.ResourceGroupName, nil
}).(pulumi.StringPtrOutput)),
StreamAnalyticsJobName: pulumi.String(example.ApplyT(func(example streamanalytics.GetJobResult) (*string, error) {
return &example.Name, nil
}).(pulumi.StringPtrOutput)),
Server: exampleServer.FullyQualifiedDomainName,
Database: exampleDatabase.Name,
Username: pulumi.String("exampleuser"),
Password: pulumi.String("examplepassword"),
RefreshType: pulumi.String("RefreshPeriodicallyWithFull"),
RefreshIntervalDuration: pulumi.String("00:20:00"),
FullSnapshotQuery: pulumi.String(" SELECT *\n INTO [YourOutputAlias]\n FROM [YourInputAlias]\n"),
})
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.azure.mssql.Server;
import com.pulumi.azure.mssql.ServerArgs;
import com.pulumi.azure.mssql.Database;
import com.pulumi.azure.mssql.DatabaseArgs;
import com.pulumi.azure.streamanalytics.ReferenceInputMssql;
import com.pulumi.azure.streamanalytics.ReferenceInputMssqlArgs;
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("example-resources")
.location("West Europe")
.build());
final var example = StreamanalyticsFunctions.getJob(GetJobArgs.builder()
.name("example-job")
.resourceGroupName(exampleResourceGroup.name())
.build());
var exampleServer = new Server("exampleServer", ServerArgs.builder()
.name("example-sqlserver")
.resourceGroupName(exampleResourceGroup.name())
.location(exampleResourceGroup.location())
.version("12.0")
.administratorLogin("admin")
.administratorLoginPassword("password")
.build());
var exampleDatabase = new Database("exampleDatabase", DatabaseArgs.builder()
.name("example-db")
.serverId(exampleServer.id())
.build());
var exampleReferenceInputMssql = new ReferenceInputMssql("exampleReferenceInputMssql", ReferenceInputMssqlArgs.builder()
.name("example-reference-input")
.resourceGroupName(example.applyValue(getJobResult -> getJobResult).applyValue(example -> example.applyValue(getJobResult -> getJobResult.resourceGroupName())))
.streamAnalyticsJobName(example.applyValue(getJobResult -> getJobResult).applyValue(example -> example.applyValue(getJobResult -> getJobResult.name())))
.server(exampleServer.fullyQualifiedDomainName())
.database(exampleDatabase.name())
.username("exampleuser")
.password("examplepassword")
.refreshType("RefreshPeriodicallyWithFull")
.refreshIntervalDuration("00:20:00")
.fullSnapshotQuery("""
SELECT *
INTO [YourOutputAlias]
FROM [YourInputAlias]
""")
.build());
}
}Content copied to clipboard
resources:
exampleResourceGroup:
type: azure:core:ResourceGroup
name: example
properties:
name: example-resources
location: West Europe
exampleServer:
type: azure:mssql:Server
name: example
properties:
name: example-sqlserver
resourceGroupName: ${exampleResourceGroup.name}
location: ${exampleResourceGroup.location}
version: '12.0'
administratorLogin: admin
administratorLoginPassword: password
exampleDatabase:
type: azure:mssql:Database
name: example
properties:
name: example-db
serverId: ${exampleServer.id}
exampleReferenceInputMssql:
type: azure:streamanalytics:ReferenceInputMssql
name: example
properties:
name: example-reference-input
resourceGroupName: ${example.resourceGroupName}
streamAnalyticsJobName: ${example.name}
server: ${exampleServer.fullyQualifiedDomainName}
database: ${exampleDatabase.name}
username: exampleuser
password: examplepassword
refreshType: RefreshPeriodicallyWithFull
refreshIntervalDuration: 00:20:00
fullSnapshotQuery: |2
SELECT *
INTO [YourOutputAlias]
FROM [YourInputAlias]
variables:
example:
fn::invoke:
function: azure:streamanalytics:getJob
arguments:
name: example-job
resourceGroupName: ${exampleResourceGroup.name}Content copied to clipboard
Import
Stream Analytics can be imported using the resource id, e.g.
$ pulumi import azure:streamanalytics/referenceInputMssql:ReferenceInputMssql example /subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/group1/providers/Microsoft.StreamAnalytics/streamingJobs/job1/inputs/input1Content copied to clipboard
Constructors
Link copied to clipboard
constructor(database: Output<String>? = null, deltaSnapshotQuery: Output<String>? = null, fullSnapshotQuery: Output<String>? = null, name: Output<String>? = null, password: Output<String>? = null, refreshIntervalDuration: Output<String>? = null, refreshType: Output<String>? = null, resourceGroupName: Output<String>? = null, server: Output<String>? = null, streamAnalyticsJobName: Output<String>? = null, table: Output<String>? = null, username: Output<String>? = null)
Properties
Link copied to clipboard
The query used to retrieve incremental changes in the reference data from the MS SQL database. Cannot be set when refresh_type is Static.
Link copied to clipboard
The query used to retrieve the reference data from the MS SQL database.
Link copied to clipboard
The frequency in hh:mm:ss with which the reference data should be retrieved from the MS SQL database e.g. 00:20:00 for every 20 minutes. Must be set when refresh_type is RefreshPeriodicallyWithFull or RefreshPeriodicallyWithDelta.
Link copied to clipboard
Defines whether and how the reference data should be refreshed. Accepted values are Static, RefreshPeriodicallyWithFull and RefreshPeriodicallyWithDelta.
Link copied to clipboard
The name of the Resource Group where the Stream Analytics Job should exist. 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.