1. Packages
  2. Azure Classic
  3. API Docs
  4. streamanalytics
  5. Job

We recommend using Azure Native.

Viewing docs for Azure v4.42.0 (Older version)
published on Monday, Mar 9, 2026 by Pulumi
Go to latest version
Schema (JSON)
pulumi/pulumi-azure

azure.streamanalytics.Job

azure logo

We recommend using Azure Native.

Viewing docs for Azure v4.42.0 (Older version)
published on Monday, Mar 9, 2026 by Pulumi
Go to latest version
Schema (JSON)
pulumi/pulumi-azure

    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.2",
            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/v4/go/azure/core"
	"github.com/pulumi/pulumi-azure/sdk/v4/go/azure/streamanalytics"
	"github.com/pulumi/pulumi/sdk/v3/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.2"),
			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.StringMap{
				"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
	})
}

    Example coming soon!

    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.2",
    dataLocale: "en-GB",
    eventsLateArrivalMaxDelayInSeconds: 60,
    eventsOutOfOrderMaxDelayInSeconds: 50,
    eventsOutOfOrderPolicy: "Adjust",
    outputErrorPolicy: "Drop",
    streamingUnits: 3,
    tags: {
        environment: "Example",
    },
    transformationQuery: `    SELECT *
    INTO [YourOutputAlias]
    FROM [YourInputAlias]
`,
});

    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.2",
    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]
""")

    Example coming soon!

    Create Job Resource

    Resources are created with functions called constructors. To learn more about declaring and configuring resources, see Resources.

    Constructor syntax

    new Job(name: string, args: JobArgs, opts?: CustomResourceOptions);
    @overload
def Job(resource_name: str,
        args: JobArgs,
        opts: Optional[ResourceOptions] = None)

@overload
def Job(resource_name: str,
        opts: Optional[ResourceOptions] = None,
        resource_group_name: Optional[str] = None,
        transformation_query: Optional[str] = None,
        streaming_units: Optional[int] = None,
        events_out_of_order_max_delay_in_seconds: Optional[int] = None,
        events_out_of_order_policy: Optional[str] = None,
        identity: Optional[JobIdentityArgs] = None,
        location: Optional[str] = None,
        name: Optional[str] = None,
        output_error_policy: Optional[str] = None,
        compatibility_level: Optional[str] = None,
        stream_analytics_cluster_id: Optional[str] = None,
        events_late_arrival_max_delay_in_seconds: Optional[int] = None,
        tags: Optional[Mapping[str, str]] = None,
        data_locale: Optional[str] = None)
    func NewJob(ctx *Context, name string, args JobArgs, opts ...ResourceOption) (*Job, error)
    public Job(string name, JobArgs args, CustomResourceOptions? opts = null)
    public Job(String name, JobArgs args)
public Job(String name, JobArgs args, CustomResourceOptions options)

    type: azure:streamanalytics:Job
properties: # The arguments to resource properties.
options: # Bag of options to control resource's behavior.

    Parameters

    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.
    args JobArgs
    The arguments to resource properties.
    opts ResourceOptions
    Bag of options to control 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.
    name String
    The unique name of the resource.
    args JobArgs
    The arguments to resource properties.
    options CustomResourceOptions
    Bag of options to control resource's behavior.

    Constructor example

    The following reference example uses placeholder values for all input properties.

    var examplejobResourceResourceFromStreamanalyticsjob = new Azure.StreamAnalytics.Job("examplejobResourceResourceFromStreamanalyticsjob", new()
{
    ResourceGroupName = "string",
    TransformationQuery = "string",
    StreamingUnits = 0,
    EventsOutOfOrderMaxDelayInSeconds = 0,
    EventsOutOfOrderPolicy = "string",
    Identity = new Azure.StreamAnalytics.Inputs.JobIdentityArgs
    {
        Type = "string",
        PrincipalId = "string",
        TenantId = "string",
    },
    Location = "string",
    Name = "string",
    OutputErrorPolicy = "string",
    CompatibilityLevel = "string",
    StreamAnalyticsClusterId = "string",
    EventsLateArrivalMaxDelayInSeconds = 0,
    Tags = 
    {
        { "string", "string" },
    },
    DataLocale = "string",
});

    example, err := streamanalytics.NewJob(ctx, "examplejobResourceResourceFromStreamanalyticsjob", &streamanalytics.JobArgs{
	ResourceGroupName:                 pulumi.String("string"),
	TransformationQuery:               pulumi.String("string"),
	StreamingUnits:                    pulumi.Int(0),
	EventsOutOfOrderMaxDelayInSeconds: pulumi.Int(0),
	EventsOutOfOrderPolicy:            pulumi.String("string"),
	Identity: &streamanalytics.JobIdentityArgs{
		Type:        pulumi.String("string"),
		PrincipalId: pulumi.String("string"),
		TenantId:    pulumi.String("string"),
	},
	Location:                           pulumi.String("string"),
	Name:                               pulumi.String("string"),
	OutputErrorPolicy:                  pulumi.String("string"),
	CompatibilityLevel:                 pulumi.String("string"),
	StreamAnalyticsClusterId:           pulumi.String("string"),
	EventsLateArrivalMaxDelayInSeconds: pulumi.Int(0),
	Tags: pulumi.StringMap{
		"string": pulumi.String("string"),
	},
	DataLocale: pulumi.String("string"),
})

    var examplejobResourceResourceFromStreamanalyticsjob = new com.pulumi.azure.streamanalytics.Job("examplejobResourceResourceFromStreamanalyticsjob", com.pulumi.azure.streamanalytics.JobArgs.builder()
    .resourceGroupName("string")
    .transformationQuery("string")
    .streamingUnits(0)
    .eventsOutOfOrderMaxDelayInSeconds(0)
    .eventsOutOfOrderPolicy("string")
    .identity(JobIdentityArgs.builder()
        .type("string")
        .principalId("string")
        .tenantId("string")
        .build())
    .location("string")
    .name("string")
    .outputErrorPolicy("string")
    .compatibilityLevel("string")
    .streamAnalyticsClusterId("string")
    .eventsLateArrivalMaxDelayInSeconds(0)
    .tags(Map.of("string", "string"))
    .dataLocale("string")
    .build());

    examplejob_resource_resource_from_streamanalyticsjob = azure.streamanalytics.Job("examplejobResourceResourceFromStreamanalyticsjob",
    resource_group_name="string",
    transformation_query="string",
    streaming_units=0,
    events_out_of_order_max_delay_in_seconds=0,
    events_out_of_order_policy="string",
    identity={
        "type": "string",
        "principal_id": "string",
        "tenant_id": "string",
    },
    location="string",
    name="string",
    output_error_policy="string",
    compatibility_level="string",
    stream_analytics_cluster_id="string",
    events_late_arrival_max_delay_in_seconds=0,
    tags={
        "string": "string",
    },
    data_locale="string")

    const examplejobResourceResourceFromStreamanalyticsjob = new azure.streamanalytics.Job("examplejobResourceResourceFromStreamanalyticsjob", {
    resourceGroupName: "string",
    transformationQuery: "string",
    streamingUnits: 0,
    eventsOutOfOrderMaxDelayInSeconds: 0,
    eventsOutOfOrderPolicy: "string",
    identity: {
        type: "string",
        principalId: "string",
        tenantId: "string",
    },
    location: "string",
    name: "string",
    outputErrorPolicy: "string",
    compatibilityLevel: "string",
    streamAnalyticsClusterId: "string",
    eventsLateArrivalMaxDelayInSeconds: 0,
    tags: {
        string: "string",
    },
    dataLocale: "string",
});

    type: azure:streamanalytics:Job
properties:
    compatibilityLevel: string
    dataLocale: string
    eventsLateArrivalMaxDelayInSeconds: 0
    eventsOutOfOrderMaxDelayInSeconds: 0
    eventsOutOfOrderPolicy: string
    identity:
        principalId: string
        tenantId: string
        type: string
    location: string
    name: string
    outputErrorPolicy: string
    resourceGroupName: string
    streamAnalyticsClusterId: string
    streamingUnits: 0
    tags:
        string: string
    transformationQuery: string

    Job Resource Properties

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

    Inputs

    In Python, inputs that are objects can be passed either as argument classes or as dictionary literals.

    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, 1.1 and 1.2.
    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.
    Identity JobIdentity
    An identity block as defined below.
    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.
    StreamAnalyticsClusterId string
    The ID of an existing Stream Analytics Cluster where the Stream Analytics Job should run.
    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, 1.1 and 1.2.
    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.
    Identity JobIdentityArgs
    An identity block as defined below.
    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.
    StreamAnalyticsClusterId string
    The ID of an existing Stream Analytics Cluster where the Stream Analytics Job should run.
    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 Integer
    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, 1.1 and 1.2.
    dataLocale String
    Specifies the Data Locale of the Job, which should be a supported .NET Culture.
    eventsLateArrivalMaxDelayInSeconds Integer
    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 Integer
    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.
    identity JobIdentity
    An identity block as defined below.
    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.
    streamAnalyticsClusterId String
    The ID of an existing Stream Analytics Cluster where the Stream Analytics Job should run.
    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, 1.1 and 1.2.
    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.
    identity JobIdentity
    An identity block as defined below.
    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.
    streamAnalyticsClusterId string
    The ID of an existing Stream Analytics Cluster where the Stream Analytics Job should run.
    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 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.
    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, 1.1 and 1.2.
    data_locale str
    Specifies the Data Locale of the Job, which should be a supported .NET Culture.
    events_late_arrival_max_delay_in_seconds 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.
    events_out_of_order_max_delay_in_seconds 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.
    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.
    identity JobIdentityArgs
    An identity block as defined below.
    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.
    stream_analytics_cluster_id str
    The ID of an existing Stream Analytics Cluster where the Stream Analytics Job should run.
    tags Mapping[str, str]
    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, 1.1 and 1.2.
    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.
    identity Property Map
    An identity block as defined below.
    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.
    streamAnalyticsClusterId String
    The ID of an existing Stream Analytics Cluster where the Stream Analytics Job should run.
    tags Map<String>
    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 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.
    id String
    The provider-assigned unique ID for this managed resource.
    jobId String
    The Job ID assigned by the Stream Analytics Job.

    Look up 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
    @staticmethod
def get(resource_name: str,
        id: str,
        opts: Optional[ResourceOptions] = None,
        compatibility_level: Optional[str] = None,
        data_locale: Optional[str] = None,
        events_late_arrival_max_delay_in_seconds: Optional[int] = None,
        events_out_of_order_max_delay_in_seconds: Optional[int] = None,
        events_out_of_order_policy: Optional[str] = None,
        identity: Optional[JobIdentityArgs] = None,
        job_id: Optional[str] = None,
        location: Optional[str] = None,
        name: Optional[str] = None,
        output_error_policy: Optional[str] = None,
        resource_group_name: Optional[str] = None,
        stream_analytics_cluster_id: Optional[str] = None,
        streaming_units: Optional[int] = None,
        tags: Optional[Mapping[str, str]] = None,
        transformation_query: Optional[str] = None) -> Job
    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)
    public static Job get(String name, Output<String> id, JobState state, CustomResourceOptions options)
    resources:  _:    type: azure:streamanalytics:Job    get:      id: ${id}
    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.
    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, 1.1 and 1.2.
    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.
    Identity JobIdentity
    An identity block as defined below.
    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.
    StreamAnalyticsClusterId string
    The ID of an existing Stream Analytics Cluster where the Stream Analytics Job should run.
    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, 1.1 and 1.2.
    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.
    Identity JobIdentityArgs
    An identity block as defined below.
    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.
    StreamAnalyticsClusterId string
    The ID of an existing Stream Analytics Cluster where the Stream Analytics Job should run.
    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, 1.1 and 1.2.
    dataLocale String
    Specifies the Data Locale of the Job, which should be a supported .NET Culture.
    eventsLateArrivalMaxDelayInSeconds Integer
    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 Integer
    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.
    identity JobIdentity
    An identity block as defined below.
    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.
    streamAnalyticsClusterId String
    The ID of an existing Stream Analytics Cluster where the Stream Analytics Job should run.
    streamingUnits Integer
    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, 1.1 and 1.2.
    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.
    identity JobIdentity
    An identity block as defined below.
    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.
    streamAnalyticsClusterId string
    The ID of an existing Stream Analytics Cluster where the Stream Analytics Job should run.
    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, 1.1 and 1.2.
    data_locale str
    Specifies the Data Locale of the Job, which should be a supported .NET Culture.
    events_late_arrival_max_delay_in_seconds 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.
    events_out_of_order_max_delay_in_seconds 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.
    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.
    identity JobIdentityArgs
    An identity block as defined below.
    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.
    stream_analytics_cluster_id str
    The ID of an existing Stream Analytics Cluster where the Stream Analytics Job should run.
    streaming_units 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 Mapping[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).
    compatibilityLevel 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.
    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.
    identity Property Map
    An identity block as defined below.
    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.
    streamAnalyticsClusterId String
    The ID of an existing Stream Analytics Cluster where the Stream Analytics Job should run.
    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 Map<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).

    Supporting Types

    JobIdentity, JobIdentityArgs

    Type string
    The type of identity used for the Stream Analytics Job. The only possible value is SystemAssigned.
    PrincipalId string
    The ID of the Principal (Client) in Azure Active Directory.
    TenantId string
    The ID of the Azure Active Directory Tenant.
    Type string
    The type of identity used for the Stream Analytics Job. The only possible value is SystemAssigned.
    PrincipalId string
    The ID of the Principal (Client) in Azure Active Directory.
    TenantId string
    The ID of the Azure Active Directory Tenant.
    type String
    The type of identity used for the Stream Analytics Job. The only possible value is SystemAssigned.
    principalId String
    The ID of the Principal (Client) in Azure Active Directory.
    tenantId String
    The ID of the Azure Active Directory Tenant.
    type string
    The type of identity used for the Stream Analytics Job. The only possible value is SystemAssigned.
    principalId string
    The ID of the Principal (Client) in Azure Active Directory.
    tenantId string
    The ID of the Azure Active Directory Tenant.
    type str
    The type of identity used for the Stream Analytics Job. The only possible value is SystemAssigned.
    principal_id str
    The ID of the Principal (Client) in Azure Active Directory.
    tenant_id str
    The ID of the Azure Active Directory Tenant.
    type String
    The type of identity used for the Stream Analytics Job. The only possible value is SystemAssigned.
    principalId String
    The ID of the Principal (Client) in Azure Active Directory.
    tenantId String
    The ID of the Azure Active Directory Tenant.

    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

    To learn more about importing existing cloud resources, see Importing resources.

    Package Details

    Repository
    Azure Classic pulumi/pulumi-azure
    License
    Apache-2.0
    Notes
    This Pulumi package is based on the azurerm Terraform Provider.
    azure logo

    We recommend using Azure Native.

    Viewing docs for Azure v4.42.0 (Older version)
    published on Monday, Mar 9, 2026 by Pulumi
    Go to latest version
    Schema (JSON)
    pulumi/pulumi-azure
      Try Pulumi Cloud free. Your team will thank you.