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

OutputSynapseArgs

data class OutputSynapseArgs(val database: Output<String>? = 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<OutputSynapseArgs>

Manages a Stream Analytics Output to an Azure Synapse Analytics Workspace.

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.storage.Account;
import com.pulumi.azure.storage.AccountArgs;
import com.pulumi.azure.storage.DataLakeGen2Filesystem;
import com.pulumi.azure.storage.DataLakeGen2FilesystemArgs;
import com.pulumi.azure.synapse.Workspace;
import com.pulumi.azure.synapse.WorkspaceArgs;
import com.pulumi.azure.synapse.inputs.WorkspaceIdentityArgs;
import com.pulumi.azure.streamanalytics.OutputSynapse;
import com.pulumi.azure.streamanalytics.OutputSynapseArgs;
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 exampleAccount = new Account("exampleAccount", AccountArgs.builder()
            .name("examplestorageacc")
            .resourceGroupName(exampleResourceGroup.name())
            .location(exampleResourceGroup.location())
            .accountTier("Standard")
            .accountReplicationType("LRS")
            .accountKind("StorageV2")
            .isHnsEnabled("true")
            .build());
        var exampleDataLakeGen2Filesystem = new DataLakeGen2Filesystem("exampleDataLakeGen2Filesystem", DataLakeGen2FilesystemArgs.builder()
            .name("example")
            .storageAccountId(exampleAccount.id())
            .build());
        var exampleWorkspace = new Workspace("exampleWorkspace", WorkspaceArgs.builder()
            .name("example")
            .resourceGroupName(exampleResourceGroup.name())
            .location(exampleResourceGroup.location())
            .storageDataLakeGen2FilesystemId(exampleDataLakeGen2Filesystem.id())
            .sqlAdministratorLogin("sqladminuser")
            .sqlAdministratorLoginPassword("H@Sh1CoR3!")
            .identity(WorkspaceIdentityArgs.builder()
                .type("SystemAssigned")
                .build())
            .build());
        var exampleOutputSynapse = new OutputSynapse("exampleOutputSynapse", OutputSynapseArgs.builder()
            .name("example-output-synapse")
            .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(exampleWorkspace.connectivityEndpoints().applyValue(connectivityEndpoints -> connectivityEndpoints.sqlOnDemand()))
            .user(exampleWorkspace.sqlAdministratorLogin())
            .password(exampleWorkspace.sqlAdministratorLoginPassword())
            .database("master")
            .table("ExampleTable")
            .build());
    }
}

Import

A Stream Analytics Output to an Azure Synapse Analytics Workspace can be imported using the resource id, e.g.

$ pulumi import azure:streamanalytics/outputSynapse:OutputSynapse example /subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/group1/providers/Microsoft.StreamAnalytics/streamingJobs/job1/outputs/output1

Constructors

OutputSynapseArgs

fun OutputSynapseArgs(database: Output<String>? = 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)

Functions

toJava

open override fun toJava(): OutputSynapseArgs

Properties

database

val database: Output<String>? = null

The name of the Azure SQL database. Changing this forces a new resource to be created.

name

val name: Output<String>? = null

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

password

val password: Output<String>? = null

The password that will be used to connect to the Azure SQL database.

resourceGroupName

val resourceGroupName: Output<String>? = null

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

server

val server: Output<String>? = null

The name of the SQL server containing the Azure SQL database. Changing this forces a new resource to be created.

streamAnalyticsJobName

val streamAnalyticsJobName: Output<String>? = null

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

table

val table: Output<String>? = null

The name of the table in the Azure SQL database. Changing this forces a new resource to be created.

user

val user: Output<String>? = null

The user name that will be used to connect to the Azure SQL database. Changing this forces a new resource to be created.