1. Docs
  2. Reference
  3. API
  4. Azure
  5. streamanalytics
  6. Job

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]
",
        });
    }

}

package main

import (
    "fmt"

    "github.com/pulumi/pulumi-azure/sdk/v3/go/azure/core"
    "github.com/pulumi/pulumi-azure/sdk/v3/go/azure/streamanalytics"
    "github.com/pulumi/pulumi/sdk/v2/go/pulumi"
)

func main() {
    pulumi.Run(func(ctx *pulumi.Context) error {
        exampleResourceGroup, err := core.NewResourceGroup(ctx, "exampleResourceGroup", &core.ResourceGroupArgs{
            Location: pulumi.String("West Europe"),
        })
        if err != nil {
            return err
        }
        _, err = streamanalytics.NewJob(ctx, "exampleJob", &streamanalytics.JobArgs{
            ResourceGroupName:                  exampleResourceGroup.Name,
            Location:                           exampleResourceGroup.Location,
            CompatibilityLevel:                 pulumi.String("1.1"),
            DataLocale:                         pulumi.String("en-GB"),
            EventsLateArrivalMaxDelayInSeconds: pulumi.Int(60),
            EventsOutOfOrderMaxDelayInSeconds:  pulumi.Int(50),
            EventsOutOfOrderPolicy:             pulumi.String("Adjust"),
            OutputErrorPolicy:                  pulumi.String("Drop"),
            StreamingUnits:                     pulumi.Int(3),
            Tags: pulumi.Map{
                "environment": pulumi.String("Example"),
            },
            TransformationQuery: pulumi.String(fmt.Sprintf("%v%v%v", "    SELECT *\n", "    INTO [YourOutputAlias]\n", "    FROM [YourInputAlias]\n")),
        })
        if err != nil {
            return err
        }
        return nil
    })
}
import pulumi
import pulumi_azure as azure

example_resource_group = azure.core.ResourceGroup("exampleResourceGroup", location="West Europe")
example_job = azure.streamanalytics.Job("exampleJob",
    resource_group_name=example_resource_group.name,
    location=example_resource_group.location,
    compatibility_level="1.1",
    data_locale="en-GB",
    events_late_arrival_max_delay_in_seconds=60,
    events_out_of_order_max_delay_in_seconds=50,
    events_out_of_order_policy="Adjust",
    output_error_policy="Drop",
    streaming_units=3,
    tags={
        "environment": "Example",
    },
    transformation_query="""    SELECT *
    INTO [YourOutputAlias]
    FROM [YourInputAlias]
""")
import * as pulumi from "@pulumi/pulumi";
import * as azure from "@pulumi/azure";

const exampleResourceGroup = new azure.core.ResourceGroup("exampleResourceGroup", {location: "West Europe"});
const exampleJob = new azure.streamanalytics.Job("exampleJob", {
    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]
`,
});

Create a Job Resource

new Job(name: string, args: JobArgs, opts?: CustomResourceOptions);
def Job(resource_name, opts=None, compatibility_level=None, data_locale=None, events_late_arrival_max_delay_in_seconds=None, events_out_of_order_max_delay_in_seconds=None, events_out_of_order_policy=None, location=None, name=None, output_error_policy=None, resource_group_name=None, streaming_units=None, tags=None, transformation_query=None, __props__=None);
func NewJob(ctx *Context, name string, args JobArgs, opts ...ResourceOption) (*Job, error)
public Job(string name, JobArgs args, CustomResourceOptions? opts = null)
name string
The unique name of the resource.
args JobArgs
The arguments to resource properties.
opts CustomResourceOptions
Bag of options to control resource's behavior.
resource_name str
The unique name of the resource.
opts ResourceOptions
A bag of options that control this resource's behavior.
ctx Context
Context object for the current deployment.
name string
The unique name of the resource.
args JobArgs
The arguments to resource properties.
opts ResourceOption
Bag of options to control resource's behavior.
name string
The unique name of the resource.
args JobArgs
The arguments to resource properties.
opts CustomResourceOptions
Bag of options to control resource's behavior.

Job Resource Properties

To learn more about resource properties and how to use them, see Inputs and Outputs in the Programming Model docs.

Inputs

The Job resource accepts the following input properties:

ResourceGroupName string

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

StreamingUnits 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.

TransformationQuery string

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

CompatibilityLevel string

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

DataLocale string

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

EventsLateArrivalMaxDelayInSeconds 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 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 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.

Location string

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

Name string

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

OutputErrorPolicy 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.

Tags Dictionary<string, string>

A mapping of tags assigned to the resource.

ResourceGroupName string

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

StreamingUnits 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.

TransformationQuery string

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

CompatibilityLevel string

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

DataLocale string

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

EventsLateArrivalMaxDelayInSeconds 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 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 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.

Location string

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

Name string

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

OutputErrorPolicy 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.

Tags map[string]string

A mapping of tags assigned to the resource.

resourceGroupName string

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

streamingUnits number

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

transformationQuery string

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

compatibilityLevel string

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

dataLocale string

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

eventsLateArrivalMaxDelayInSeconds number

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 number

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 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.

location string

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

name string

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

outputErrorPolicy 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.

tags {[key: string]: string}

A mapping of tags assigned to the resource.

resource_group_name str

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

streaming_units float

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

transformation_query str

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

compatibility_level str

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

data_locale str

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

events_late_arrival_max_delay_in_seconds float

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.

events_out_of_order_max_delay_in_seconds float

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.

events_out_of_order_policy str

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.

location str

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

name str

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

output_error_policy str

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.

tags Dict[str, str]

A mapping of tags assigned to the resource.

Outputs

All input properties are implicitly available as output properties. Additionally, the Job resource produces the following output properties:

Id string
The provider-assigned unique ID for this managed resource.
JobId string

The Job ID assigned by the Stream Analytics Job.

Id string
The provider-assigned unique ID for this managed resource.
JobId string

The Job ID assigned by the Stream Analytics Job.

id string
The provider-assigned unique ID for this managed resource.
jobId string

The Job ID assigned by the Stream Analytics Job.

id str
The provider-assigned unique ID for this managed resource.
job_id str

The Job ID assigned by the Stream Analytics Job.

Look up an Existing Job Resource

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

public static get(name: string, id: Input<ID>, state?: JobState, opts?: CustomResourceOptions): Job
static get(resource_name, id, opts=None, compatibility_level=None, data_locale=None, events_late_arrival_max_delay_in_seconds=None, events_out_of_order_max_delay_in_seconds=None, events_out_of_order_policy=None, job_id=None, location=None, name=None, output_error_policy=None, resource_group_name=None, streaming_units=None, tags=None, transformation_query=None, __props__=None);
func GetJob(ctx *Context, name string, id IDInput, state *JobState, opts ...ResourceOption) (*Job, error)
public static Job Get(string name, Input<string> id, JobState? state, CustomResourceOptions? opts = null)
name
The unique name of the resulting resource.
id
The unique provider ID of the resource to lookup.
state
Any extra arguments used during the lookup.
opts
A bag of options that control this resource's behavior.
resource_name
The unique name of the resulting resource.
id
The unique provider ID of the resource to lookup.
name
The unique name of the resulting resource.
id
The unique provider ID of the resource to lookup.
state
Any extra arguments used during the lookup.
opts
A bag of options that control this resource's behavior.
name
The unique name of the resulting resource.
id
The unique provider ID of the resource to lookup.
state
Any extra arguments used during the lookup.
opts
A bag of options that control this resource's behavior.

The following state arguments are supported:

CompatibilityLevel string

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

DataLocale string

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

EventsLateArrivalMaxDelayInSeconds 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 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 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.

JobId string

The Job ID assigned by the Stream Analytics Job.

Location string

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

Name string

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

OutputErrorPolicy 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.

ResourceGroupName string

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

StreamingUnits 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.

Tags Dictionary<string, string>

A mapping of tags assigned to the resource.

TransformationQuery string

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

CompatibilityLevel string

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

DataLocale string

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

EventsLateArrivalMaxDelayInSeconds 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 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 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.

JobId string

The Job ID assigned by the Stream Analytics Job.

Location string

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

Name string

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

OutputErrorPolicy 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.

ResourceGroupName string

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

StreamingUnits 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.

Tags map[string]string

A mapping of tags assigned to the resource.

TransformationQuery string

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

compatibilityLevel string

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

dataLocale string

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

eventsLateArrivalMaxDelayInSeconds number

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 number

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 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.

jobId string

The Job ID assigned by the Stream Analytics Job.

location string

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

name string

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

outputErrorPolicy 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.

resourceGroupName string

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

streamingUnits number

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

tags {[key: string]: string}

A mapping of tags assigned to the resource.

transformationQuery string

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

compatibility_level str

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

data_locale str

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

events_late_arrival_max_delay_in_seconds float

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.

events_out_of_order_max_delay_in_seconds float

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.

events_out_of_order_policy str

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.

job_id str

The Job ID assigned by the Stream Analytics Job.

location str

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

name str

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

output_error_policy str

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.

resource_group_name str

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

streaming_units float

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

tags Dict[str, str]

A mapping of tags assigned to the resource.

transformation_query str

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

Package Details

Repository
https://github.com/pulumi/pulumi-azure
License
Apache-2.0
Notes
This Pulumi package is based on the azurerm Terraform Provider.