Class Job

Manages a Stream Analytics Job.

Example Usage

using Pulumi;
using Azure = Pulumi.Azure;

class MyStack : Stack
{
public MyStack()
{
    var exampleResourceGroup = new Azure.Core.ResourceGroup("exampleResourceGroup", new Azure.Core.ResourceGroupArgs
    {
        Location = "West Europe",
    });
    var exampleJob = new Azure.StreamAnalytics.Job("exampleJob", new Azure.StreamAnalytics.JobArgs
    {
        ResourceGroupName = exampleResourceGroup.Name,
        Location = exampleResourceGroup.Location,
        CompatibilityLevel = "1.1",
        DataLocale = "en-GB",
        EventsLateArrivalMaxDelayInSeconds = 60,
        EventsOutOfOrderMaxDelayInSeconds = 50,
        EventsOutOfOrderPolicy = "Adjust",
        OutputErrorPolicy = "Drop",
        StreamingUnits = 3,
        Tags = 
        {
            { "environment", "Example" },
        },
        TransformationQuery = @"    SELECT *
INTO [YourOutputAlias]
FROM [YourInputAlias]
",
    });
}

}

Inheritance

System.Object

Resource

CustomResource

Job

Inherited Members

CustomResource.Id

Resource.GetResourceType()

Resource.GetResourceName()

Resource.Urn

System.Object.Equals(System.Object)

System.Object.Equals(System.Object, System.Object)

System.Object.GetHashCode()

System.Object.GetType()

System.Object.MemberwiseClone()

System.Object.ReferenceEquals(System.Object, System.Object)

System.Object.ToString()

Namespace: Pulumi.Azure.StreamAnalytics

Assembly: Pulumi.Azure.dll

Syntax

public class Job : CustomResource

Constructors

Job(String, JobArgs, CustomResourceOptions)

Create a Job resource with the given unique name, arguments, and options.

Declaration

public Job(string name, JobArgs args, CustomResourceOptions options = null)

Parameters

Type	Name	Description
System.String	name	The unique name of the resource
JobArgs	args	The arguments used to populate this resource's properties
CustomResourceOptions	options	A bag of options that control this resource's behavior

Properties

CompatibilityLevel

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

Declaration

public Output<string> CompatibilityLevel { get; }

Property Value

Type	Description
Output<System.String>

DataLocale

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

Declaration

public Output<string> DataLocale { get; }

Property Value

Type	Description
Output<System.String>

EventsLateArrivalMaxDelayInSeconds

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.

Declaration

public Output<int?> EventsLateArrivalMaxDelayInSeconds { get; }

Property Value

Type	Description
Output<System.Nullable<System.Int32>>

EventsOutOfOrderMaxDelayInSeconds

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.

Declaration

public Output<int?> EventsOutOfOrderMaxDelayInSeconds { get; }

Property Value

Type	Description
Output<System.Nullable<System.Int32>>

EventsOutOfOrderPolicy

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.

Declaration

public Output<string> EventsOutOfOrderPolicy { get; }

Property Value

Type	Description
Output<System.String>

JobId

The Job ID assigned by the Stream Analytics Job.

Declaration

public Output<string> JobId { get; }

Property Value

Type	Description
Output<System.String>

Location

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

Declaration

public Output<string> Location { get; }

Property Value

Type	Description
Output<System.String>

Name

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

Declaration

public Output<string> Name { get; }

Property Value

Type	Description
Output<System.String>

OutputErrorPolicy

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.

Declaration

public Output<string> OutputErrorPolicy { get; }

Property Value

Type	Description
Output<System.String>

ResourceGroupName

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

Declaration

public Output<string> ResourceGroupName { get; }

Property Value

Type	Description
Output<System.String>

StreamingUnits

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

Declaration

public Output<int> StreamingUnits { get; }

Property Value

Type	Description
Output<System.Int32>

Tags

A mapping of tags assigned to the resource.

Declaration

public Output<ImmutableDictionary<string, string>> Tags { get; }

Property Value

Type	Description
Output<System.Collections.Immutable.ImmutableDictionary<System.String, System.String>>

TransformationQuery

Specifies the query that will be run in the streaming job, written in Stream Analytics Query Language (SAQL).

Declaration

public Output<string> TransformationQuery { get; }

Property Value

Type	Description
Output<System.String>

Methods

Get(String, Input<String>, JobState, CustomResourceOptions)

Get an existing Job resource's state with the given name, ID, and optional extra properties used to qualify the lookup.

Declaration

public static Job Get(string name, Input<string> id, JobState state = null, CustomResourceOptions options = null)

Parameters

Type	Name	Description
System.String	name	The unique name of the resulting resource.
Input<System.String>	id	The unique provider ID of the resource to lookup.
JobState	state	Any extra arguments used during the lookup.
CustomResourceOptions	options	A bag of options that control this resource's behavior

Returns

Type	Description
Job