azure.streamanalytics.ReferenceInputMssql

using Pulumi;
using Azure = Pulumi.Azure;

class MyStack : Stack
{
    public MyStack()
    {
        var exampleResourceGroup = Output.Create(Azure.Core.GetResourceGroup.InvokeAsync(new Azure.Core.GetResourceGroupArgs
        {
            Name = "example-resources",
        }));
        var exampleJob = Output.Create(Azure.StreamAnalytics.GetJob.InvokeAsync(new Azure.StreamAnalytics.GetJobArgs
        {
            Name = "example-job",
            ResourceGroupName = azurerm_resource_group.Example.Name,
        }));
        var exampleServer = new Azure.MSSql.Server("exampleServer", new Azure.MSSql.ServerArgs
        {
            ResourceGroupName = azurerm_resource_group.Example.Name,
            Location = azurerm_resource_group.Example.Location,
            Version = "12.0",
            AdministratorLogin = "admin",
            AdministratorLoginPassword = "password",
        });
        var exampleDatabase = new Azure.MSSql.Database("exampleDatabase", new Azure.MSSql.DatabaseArgs
        {
            ServerId = exampleServer.Id,
        });
        var exampleReferenceInputMssql = new Azure.StreamAnalytics.ReferenceInputMssql("exampleReferenceInputMssql", new Azure.StreamAnalytics.ReferenceInputMssqlArgs
        {
            ResourceGroupName = azurerm_stream_analytics_job.Example.Resource_group_name,
            StreamAnalyticsJobName = azurerm_stream_analytics_job.Example.Name,
            Server = exampleServer.FullyQualifiedDomainName,
            Database = exampleDatabase.Name,
            Username = "exampleuser",
            Password = "examplepassword",
            RefreshType = "RefreshPeriodicallyWithFull",
            RefreshIntervalDuration = "00:20:00",
            FullSnapshotQuery = @"    SELECT *
    INTO [YourOutputAlias]
    FROM [YourInputAlias]
",
        });
    }

}

package main

import (
	"fmt"

	"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/core"
	"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/mssql"
	"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/streamanalytics"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := core.LookupResourceGroup(ctx, &core.LookupResourceGroupArgs{
			Name: "example-resources",
		}, nil)
		if err != nil {
			return err
		}
		_, err = streamanalytics.LookupJob(ctx, &streamanalytics.LookupJobArgs{
			Name:              "example-job",
			ResourceGroupName: azurerm_resource_group.Example.Name,
		}, nil)
		if err != nil {
			return err
		}
		exampleServer, err := mssql.NewServer(ctx, "exampleServer", &mssql.ServerArgs{
			ResourceGroupName:          pulumi.Any(azurerm_resource_group.Example.Name),
			Location:                   pulumi.Any(azurerm_resource_group.Example.Location),
			Version:                    pulumi.String("12.0"),
			AdministratorLogin:         pulumi.String("admin"),
			AdministratorLoginPassword: pulumi.String("password"),
		})
		if err != nil {
			return err
		}
		exampleDatabase, err := mssql.NewDatabase(ctx, "exampleDatabase", &mssql.DatabaseArgs{
			ServerId: exampleServer.ID(),
		})
		if err != nil {
			return err
		}
		_, err = streamanalytics.NewReferenceInputMssql(ctx, "exampleReferenceInputMssql", &streamanalytics.ReferenceInputMssqlArgs{
			ResourceGroupName:       pulumi.Any(azurerm_stream_analytics_job.Example.Resource_group_name),
			StreamAnalyticsJobName:  pulumi.Any(azurerm_stream_analytics_job.Example.Name),
			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(fmt.Sprintf("%v%v%v", "    SELECT *\n", "    INTO [YourOutputAlias]\n", "    FROM [YourInputAlias]\n")),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

import * as pulumi from "@pulumi/pulumi";
import * as azure from "@pulumi/azure";

const exampleResourceGroup = azure.core.getResourceGroup({
    name: "example-resources",
});
const exampleJob = azure.streamanalytics.getJob({
    name: "example-job",
    resourceGroupName: azurerm_resource_group.example.name,
});
const exampleServer = new azure.mssql.Server("exampleServer", {
    resourceGroupName: azurerm_resource_group.example.name,
    location: azurerm_resource_group.example.location,
    version: "12.0",
    administratorLogin: "admin",
    administratorLoginPassword: "password",
});
const exampleDatabase = new azure.mssql.Database("exampleDatabase", {serverId: exampleServer.id});
const exampleReferenceInputMssql = new azure.streamanalytics.ReferenceInputMssql("exampleReferenceInputMssql", {
    resourceGroupName: azurerm_stream_analytics_job.example.resource_group_name,
    streamAnalyticsJobName: azurerm_stream_analytics_job.example.name,
    server: exampleServer.fullyQualifiedDomainName,
    database: exampleDatabase.name,
    username: "exampleuser",
    password: "examplepassword",
    refreshType: "RefreshPeriodicallyWithFull",
    refreshIntervalDuration: "00:20:00",
    fullSnapshotQuery: `    SELECT *
    INTO [YourOutputAlias]
    FROM [YourInputAlias]
`,
});

import pulumi
import pulumi_azure as azure

example_resource_group = azure.core.get_resource_group(name="example-resources")
example_job = azure.streamanalytics.get_job(name="example-job",
    resource_group_name=azurerm_resource_group["example"]["name"])
example_server = azure.mssql.Server("exampleServer",
    resource_group_name=azurerm_resource_group["example"]["name"],
    location=azurerm_resource_group["example"]["location"],
    version="12.0",
    administrator_login="admin",
    administrator_login_password="password")
example_database = azure.mssql.Database("exampleDatabase", server_id=example_server.id)
example_reference_input_mssql = azure.streamanalytics.ReferenceInputMssql("exampleReferenceInputMssql",
    resource_group_name=azurerm_stream_analytics_job["example"]["resource_group_name"],
    stream_analytics_job_name=azurerm_stream_analytics_job["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]
""")