pulumi-azure-kotlin/com.pulumi.azure.streamanalytics.kotlin/ReferenceInputMssqlArgs

ReferenceInputMssqlArgs

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

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()
            .location("West Europe")
            .build());
        final var exampleJob = StreamanalyticsFunctions.getJob(GetJobArgs.builder()
            .name("example-job")
            .resourceGroupName(exampleResourceGroup.name())
            .build());
        var exampleServer = new Server("exampleServer", ServerArgs.builder()
            .resourceGroupName(exampleResourceGroup.name())
            .location(exampleResourceGroup.location())
            .version("12.0")
            .administratorLogin("admin")
            .administratorLoginPassword("password")
            .build());
        var exampleDatabase = new Database("exampleDatabase", DatabaseArgs.builder()
            .serverId(exampleServer.id())
            .build());
        var exampleReferenceInputMssql = new ReferenceInputMssql("exampleReferenceInputMssql", ReferenceInputMssqlArgs.builder()
            .resourceGroupName(exampleJob.applyValue(getJobResult -> getJobResult).applyValue(exampleJob -> exampleJob.applyValue(getJobResult -> getJobResult.resourceGroupName())))
            .streamAnalyticsJobName(exampleJob.applyValue(getJobResult -> getJobResult).applyValue(exampleJob -> exampleJob.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

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/input1
Content copied to clipboard

Constructors

Link copied to clipboard
fun ReferenceInputMssqlArgs(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)

Functions

Link copied to clipboard
open override fun toJava(): ReferenceInputMssqlArgs

Properties

Link copied to clipboard
val database: Output<String>? = null

The MS SQL database name where the reference data exists.

Link copied to clipboard
val deltaSnapshotQuery: Output<String>? = null

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
val fullSnapshotQuery: Output<String>? = null

The query used to retrieve the reference data from the MS SQL database.

Link copied to clipboard
val name: Output<String>? = null

The name of the Reference Input MS SQL data. Changing this forces a new resource to be created.

Link copied to clipboard
val password: Output<String>? = null

The password to connect to the MS SQL database.

Link copied to clipboard
val refreshIntervalDuration: Output<String>? = null

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
val refreshType: Output<String>? = null

Defines whether and how the reference data should be refreshed. Accepted values are Static, RefreshPeriodicallyWithFull and RefreshPeriodicallyWithDelta.

Link copied to clipboard
val resourceGroupName: Output<String>? = null

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
val server: Output<String>? = null

The fully qualified domain name of the MS SQL server.

Link copied to clipboard
val streamAnalyticsJobName: Output<String>? = null

The name of the Stream Analytics Job. Changing this forces a new resource to be created.

Link copied to clipboard
val table: Output<String>? = null

The name of the table in the Azure SQL database.

Link copied to clipboard
val username: Output<String>? = null

The username to connect to the MS SQL database.