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

Job

class Job : KotlinCustomResource

Manages a Stream Analytics Job.

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.Job;
import com.pulumi.azure.streamanalytics.JobArgs;
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());
        var exampleJob = new Job("exampleJob", JobArgs.builder()
            .resourceGroupName(exampleResourceGroup.name())
            .location(exampleResourceGroup.location())
            .compatibilityLevel("1.2")
            .dataLocale("en-GB")
            .eventsLateArrivalMaxDelayInSeconds(60)
            .eventsOutOfOrderMaxDelayInSeconds(50)
            .eventsOutOfOrderPolicy("Adjust")
            .outputErrorPolicy("Drop")
            .streamingUnits(3)
            .tags(Map.of("environment", "Example"))
            .transformationQuery("""
    SELECT *
    INTO [YourOutputAlias]
    FROM [YourInputAlias]
            """)
            .build());
    }
}

Import

Stream Analytics Job's can be imported using the resource id, e.g.

$ pulumi import azure:streamanalytics/job:Job example /subscriptions/00000000-0000-0000-0000-000000000000/resourceGroups/group1/providers/Microsoft.StreamAnalytics/streamingJobs/job1

Properties

compatibilityLevel

val compatibilityLevel: Output<String>

Specifies the compatibility level for this job - which controls certain runtime behaviours of the streaming job. Possible values are 1.0, 1.1 and 1.2.

contentStoragePolicy

val contentStoragePolicy: Output<String>?

The policy for storing stream analytics content. Possible values are JobStorageAccount, SystemAccount.

dataLocale

val dataLocale: Output<String>

Specifies the Data Locale of the Job, which should be a supported .NET Culture.

eventsLateArrivalMaxDelayInSeconds

val eventsLateArrivalMaxDelayInSeconds: Output<Int>?

Specifies the maximum tolerable delay in seconds where events arriving late could be included. Supported range is -1 (indefinite) to 1814399 (20d 23h 59m 59s). Default is 0.

eventsOutOfOrderMaxDelayInSeconds

val eventsOutOfOrderMaxDelayInSeconds: Output<Int>?

Specifies the maximum tolerable delay in seconds where out-of-order events can be adjusted to be back in order. Supported range is 0 to 599 (9m 59s). Default is 5.

eventsOutOfOrderPolicy

val eventsOutOfOrderPolicy: Output<String>?

Specifies the policy which should be applied to events which arrive out of order in the input event stream. Possible values are Adjust and Drop. Default is Adjust.

val id: Output<String>

identity

val identity: Output<JobIdentity>?

An identity block as defined below.

jobId

val jobId: Output<String>

The Job ID assigned by the Stream Analytics Job.

jobStorageAccounts

val jobStorageAccounts: Output<List<JobJobStorageAccount>>?

The details of the job storage account. A job_storage_account block as defined below.

location

val location: Output<String>

The Azure Region in which the Resource Group exists. Changing this forces a new resource to be created.

name

val name: Output<String>

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

outputErrorPolicy

val outputErrorPolicy: Output<String>?

Specifies the policy which should be applied to events which arrive at the output and cannot be written to the external storage due to being malformed (such as missing column values, column values of wrong type or size). Possible values are Drop and Stop. Default is Drop.

pulumiChildResources

val pulumiChildResources: Set<KotlinResource>

pulumiResourceName

val pulumiResourceName: String

pulumiResourceType

val pulumiResourceType: String

resourceGroupName

val resourceGroupName: Output<String>

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

streamAnalyticsClusterId

val streamAnalyticsClusterId: Output<String>?

The ID of an existing Stream Analytics Cluster where the Stream Analytics Job should run.

streamingUnits

val streamingUnits: Output<Int>?

Specifies the number of streaming units that the streaming job uses. Supported values are 1, 3, 6 and multiples of 6 up to 120.