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

ReferenceInputBlobArgs

data class ReferenceInputBlobArgs(val authenticationMode: Output<String>? = null, val dateFormat: Output<String>? = null, val name: Output<String>? = null, val pathPattern: Output<String>? = null, val resourceGroupName: Output<String>? = null, val serialization: Output<ReferenceInputBlobSerializationArgs>? = null, val storageAccountKey: Output<String>? = null, val storageAccountName: Output<String>? = null, val storageContainerName: Output<String>? = null, val streamAnalyticsJobName: Output<String>? = null, val timeFormat: Output<String>? = null) : ConvertibleToJava<ReferenceInputBlobArgs>

Manages a Stream Analytics Reference Input Blob. 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.storage.Account;
import com.pulumi.azure.storage.AccountArgs;
import com.pulumi.azure.storage.Container;
import com.pulumi.azure.storage.ContainerArgs;
import com.pulumi.azure.streamanalytics.ReferenceInputBlob;
import com.pulumi.azure.streamanalytics.ReferenceInputBlobArgs;
import com.pulumi.azure.streamanalytics.inputs.ReferenceInputBlobSerializationArgs;
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 exampleAccount = new Account("exampleAccount", AccountArgs.builder()
            .resourceGroupName(exampleResourceGroup.name())
            .location(exampleResourceGroup.location())
            .accountTier("Standard")
            .accountReplicationType("LRS")
            .build());
        var exampleContainer = new Container("exampleContainer", ContainerArgs.builder()
            .storageAccountName(exampleAccount.name())
            .containerAccessType("private")
            .build());
        var test = new ReferenceInputBlob("test", ReferenceInputBlobArgs.builder()
            .streamAnalyticsJobName(exampleJob.applyValue(getJobResult -> getJobResult).applyValue(exampleJob -> exampleJob.applyValue(getJobResult -> getJobResult.name())))
            .resourceGroupName(exampleJob.applyValue(getJobResult -> getJobResult).applyValue(exampleJob -> exampleJob.applyValue(getJobResult -> getJobResult.resourceGroupName())))
            .storageAccountName(exampleAccount.name())
            .storageAccountKey(exampleAccount.primaryAccessKey())
            .storageContainerName(exampleContainer.name())
            .pathPattern("some-random-pattern")
            .dateFormat("yyyy/MM/dd")
            .timeFormat("HH")
            .serialization(ReferenceInputBlobSerializationArgs.builder()
                .type("Json")
                .encoding("UTF8")
                .build())
            .build());
    }
}
Content copied to clipboard

Import

Stream Analytics Reference Input Blob's can be imported using the resource id, e.g.

$ pulumi import azure:streamanalytics/referenceInputBlob:ReferenceInputBlob 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 ReferenceInputBlobArgs(authenticationMode: Output<String>? = null, dateFormat: Output<String>? = null, name: Output<String>? = null, pathPattern: Output<String>? = null, resourceGroupName: Output<String>? = null, serialization: Output<ReferenceInputBlobSerializationArgs>? = null, storageAccountKey: Output<String>? = null, storageAccountName: Output<String>? = null, storageContainerName: Output<String>? = null, streamAnalyticsJobName: Output<String>? = null, timeFormat: Output<String>? = null)

Functions

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

Properties

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

The authentication mode for the Stream Analytics Reference Input. Possible values are Msi and ConnectionString. Defaults to ConnectionString.

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

The date format. Wherever {date} appears in path_pattern, the value of this property is used as the date format instead.

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

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

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

The blob path pattern. Not a regular expression. It represents a pattern against which blob names will be matched to determine whether or not they should be included as input or output to the job.

Link copied to clipboard
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.

Link copied to clipboard
val serialization: Output<ReferenceInputBlobSerializationArgs>? = null

A serialization block as defined below.

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

The Access Key which should be used to connect to this Storage Account. Required if authentication_mode is ConnectionString.

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

The name of the Storage Account that has the blob container with reference data.

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

The name of the Container within the Storage Account.

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

The time format. Wherever {time} appears in path_pattern, the value of this property is used as the time format instead.