Docs Home Pulumi IaC Pulumi ESC Pulumi Cloud Packages Tutorials
  1. Packages
  2. Azure Classic
  3. API Docs
  4. streamanalytics
  5. Job

We recommend using Azure Native.

Azure v6.21.0 published on Friday, Mar 7, 2025 by Pulumi
pulumi/pulumi-azure

azure.streamanalytics.Job

Explore with Pulumi AI

azure logo

We recommend using Azure Native.

Azure v6.21.0 published on Friday, Mar 7, 2025 by Pulumi
pulumi/pulumi-azure

    Manages a Stream Analytics Job.

    Example Usage

    import * as pulumi from "@pulumi/pulumi";
import * as azure from "@pulumi/azure";

const example = new azure.core.ResourceGroup("example", {
    name: "example-resources",
    location: "West Europe",
});
const exampleJob = new azure.streamanalytics.Job("example", {
    name: "example-job",
    resourceGroupName: example.name,
    location: example.location,
    compatibilityLevel: "1.2",
    dataLocale: "en-GB",
    eventsLateArrivalMaxDelayInSeconds: 60,
    eventsOutOfOrderMaxDelayInSeconds: 50,
    eventsOutOfOrderPolicy: "Adjust",
    outputErrorPolicy: "Drop",
    streamingUnits: 3,
    skuName: "StandardV2",
    tags: {
        environment: "Example",
    },
    transformationQuery: `    SELECT *
    INTO [YourOutputAlias]
    FROM [YourInputAlias]
`,
});

    import pulumi
import pulumi_azure as azure

example = azure.core.ResourceGroup("example",
    name="example-resources",
    location="West Europe")
example_job = azure.streamanalytics.Job("example",
    name="example-job",
    resource_group_name=example.name,
    location=example.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,
    sku_name="StandardV2",
    tags={
        "environment": "Example",
    },
    transformation_query="""    SELECT *
    INTO [YourOutputAlias]
    FROM [YourInputAlias]
""")

    package main

import (
	"github.com/pulumi/pulumi-azure/sdk/v6/go/azure/core"
	"github.com/pulumi/pulumi-azure/sdk/v6/go/azure/streamanalytics"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		example, err := core.NewResourceGroup(ctx, "example", &core.ResourceGroupArgs{
			Name:     pulumi.String("example-resources"),
			Location: pulumi.String("West Europe"),
		})
		if err != nil {
			return err
		}
		_, err = streamanalytics.NewJob(ctx, "example", &streamanalytics.JobArgs{
			Name:                               pulumi.String("example-job"),
			ResourceGroupName:                  example.Name,
			Location:                           example.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),
			SkuName:                            pulumi.String("StandardV2"),
			Tags: pulumi.StringMap{
				"environment": pulumi.String("Example"),
			},
			TransformationQuery: pulumi.String("    SELECT *\n    INTO [YourOutputAlias]\n    FROM [YourInputAlias]\n"),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

    using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Azure = Pulumi.Azure;

return await Deployment.RunAsync(() => 
{
    var example = new Azure.Core.ResourceGroup("example", new()
    {
        Name = "example-resources",
        Location = "West Europe",
    });

    var exampleJob = new Azure.StreamAnalytics.Job("example", new()
    {
        Name = "example-job",
        ResourceGroupName = example.Name,
        Location = example.Location,
        CompatibilityLevel = "1.2",
        DataLocale = "en-GB",
        EventsLateArrivalMaxDelayInSeconds = 60,
        EventsOutOfOrderMaxDelayInSeconds = 50,
        EventsOutOfOrderPolicy = "Adjust",
        OutputErrorPolicy = "Drop",
        StreamingUnits = 3,
        SkuName = "StandardV2",
        Tags = 
        {
            { "environment", "Example" },
        },
        TransformationQuery = @"    SELECT *
    INTO [YourOutputAlias]
    FROM [YourInputAlias]
",
    });

});

    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 example = new ResourceGroup("example", ResourceGroupArgs.builder()
            .name("example-resources")
            .location("West Europe")
            .build());

        var exampleJob = new Job("exampleJob", JobArgs.builder()
            .name("example-job")
            .resourceGroupName(example.name())
            .location(example.location())
            .compatibilityLevel("1.2")
            .dataLocale("en-GB")
            .eventsLateArrivalMaxDelayInSeconds(60)
            .eventsOutOfOrderMaxDelayInSeconds(50)
            .eventsOutOfOrderPolicy("Adjust")
            .outputErrorPolicy("Drop")
            .streamingUnits(3)
            .skuName("StandardV2")
            .tags(Map.of("environment", "Example"))
            .transformationQuery("""
    SELECT *
    INTO [YourOutputAlias]
    FROM [YourInputAlias]
            """)
            .build());

    }
}

    resources:
  example:
    type: azure:core:ResourceGroup
    properties:
      name: example-resources
      location: West Europe
  exampleJob:
    type: azure:streamanalytics:Job
    name: example
    properties:
      name: example-job
      resourceGroupName: ${example.name}
      location: ${example.location}
      compatibilityLevel: '1.2'
      dataLocale: en-GB
      eventsLateArrivalMaxDelayInSeconds: 60
      eventsOutOfOrderMaxDelayInSeconds: 50
      eventsOutOfOrderPolicy: Adjust
      outputErrorPolicy: Drop
      streamingUnits: 3
      skuName: StandardV2
      tags:
        environment: Example
      transformationQuery: |2
            SELECT *
            INTO [YourOutputAlias]
            FROM [YourInputAlias]

    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,
        location: Optional[str] = None,
        name: Optional[str] = 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_storage_accounts: Optional[Sequence[JobJobStorageAccountArgs]] = None,
        compatibility_level: Optional[str] = None,
        events_late_arrival_max_delay_in_seconds: Optional[int] = None,
        output_error_policy: Optional[str] = None,
        data_locale: Optional[str] = None,
        sku_name: Optional[str] = None,
        stream_analytics_cluster_id: Optional[str] = None,
        streaming_units: Optional[int] = None,
        tags: Optional[Mapping[str, str]] = None,
        content_storage_policy: Optional[str] = None,
        type: 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",
    Location = "string",
    Name = "string",
    EventsOutOfOrderMaxDelayInSeconds = 0,
    EventsOutOfOrderPolicy = "string",
    Identity = new Azure.StreamAnalytics.Inputs.JobIdentityArgs
    {
        Type = "string",
        IdentityIds = new[]
        {
            "string",
        },
        PrincipalId = "string",
        TenantId = "string",
    },
    JobStorageAccounts = new[]
    {
        new Azure.StreamAnalytics.Inputs.JobJobStorageAccountArgs
        {
            AccountKey = "string",
            AccountName = "string",
            AuthenticationMode = "string",
        },
    },
    CompatibilityLevel = "string",
    EventsLateArrivalMaxDelayInSeconds = 0,
    OutputErrorPolicy = "string",
    DataLocale = "string",
    SkuName = "string",
    StreamAnalyticsClusterId = "string",
    StreamingUnits = 0,
    Tags = 
    {
        { "string", "string" },
    },
    ContentStoragePolicy = "string",
    Type = "string",
});

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

    var examplejobResourceResourceFromStreamanalyticsjob = new Job("examplejobResourceResourceFromStreamanalyticsjob", JobArgs.builder()
    .resourceGroupName("string")
    .transformationQuery("string")
    .location("string")
    .name("string")
    .eventsOutOfOrderMaxDelayInSeconds(0)
    .eventsOutOfOrderPolicy("string")
    .identity(JobIdentityArgs.builder()
        .type("string")
        .identityIds("string")
        .principalId("string")
        .tenantId("string")
        .build())
    .jobStorageAccounts(JobJobStorageAccountArgs.builder()
        .accountKey("string")
        .accountName("string")
        .authenticationMode("string")
        .build())
    .compatibilityLevel("string")
    .eventsLateArrivalMaxDelayInSeconds(0)
    .outputErrorPolicy("string")
    .dataLocale("string")
    .skuName("string")
    .streamAnalyticsClusterId("string")
    .streamingUnits(0)
    .tags(Map.of("string", "string"))
    .contentStoragePolicy("string")
    .type("string")
    .build());

    examplejob_resource_resource_from_streamanalyticsjob = azure.streamanalytics.Job("examplejobResourceResourceFromStreamanalyticsjob",
    resource_group_name="string",
    transformation_query="string",
    location="string",
    name="string",
    events_out_of_order_max_delay_in_seconds=0,
    events_out_of_order_policy="string",
    identity={
        "type": "string",
        "identity_ids": ["string"],
        "principal_id": "string",
        "tenant_id": "string",
    },
    job_storage_accounts=[{
        "account_key": "string",
        "account_name": "string",
        "authentication_mode": "string",
    }],
    compatibility_level="string",
    events_late_arrival_max_delay_in_seconds=0,
    output_error_policy="string",
    data_locale="string",
    sku_name="string",
    stream_analytics_cluster_id="string",
    streaming_units=0,
    tags={
        "string": "string",
    },
    content_storage_policy="string",
    type="string")

    const examplejobResourceResourceFromStreamanalyticsjob = new azure.streamanalytics.Job("examplejobResourceResourceFromStreamanalyticsjob", {
    resourceGroupName: "string",
    transformationQuery: "string",
    location: "string",
    name: "string",
    eventsOutOfOrderMaxDelayInSeconds: 0,
    eventsOutOfOrderPolicy: "string",
    identity: {
        type: "string",
        identityIds: ["string"],
        principalId: "string",
        tenantId: "string",
    },
    jobStorageAccounts: [{
        accountKey: "string",
        accountName: "string",
        authenticationMode: "string",
    }],
    compatibilityLevel: "string",
    eventsLateArrivalMaxDelayInSeconds: 0,
    outputErrorPolicy: "string",
    dataLocale: "string",
    skuName: "string",
    streamAnalyticsClusterId: "string",
    streamingUnits: 0,
    tags: {
        string: "string",
    },
    contentStoragePolicy: "string",
    type: "string",
});

    type: azure:streamanalytics:Job
properties:
    compatibilityLevel: string
    contentStoragePolicy: string
    dataLocale: string
    eventsLateArrivalMaxDelayInSeconds: 0
    eventsOutOfOrderMaxDelayInSeconds: 0
    eventsOutOfOrderPolicy: string
    identity:
        identityIds:
            - string
        principalId: string
        tenantId: string
        type: string
    jobStorageAccounts:
        - accountKey: string
          accountName: string
          authenticationMode: string
    location: string
    name: string
    outputErrorPolicy: string
    resourceGroupName: string
    skuName: string
    streamAnalyticsClusterId: string
    streamingUnits: 0
    tags:
        string: string
    transformationQuery: string
    type: 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.
    TransformationQuery string
    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.

    NOTE: Support for Compatibility Level 1.2 is dependent on a new version of the Stream Analytics API, which being tracked in this issue.

    ContentStoragePolicy string
    The policy for storing stream analytics content. Possible values are JobStorageAccount, SystemAccount. Defaults to SystemAccount.
    DataLocale string
    Specifies the Data Locale of the Job, which should be a supported .NET Culture. Defaults to en-US.
    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 5.
    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 0.
    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.
    JobStorageAccounts List<JobJobStorageAccount>
    The details of the job storage account. A job_storage_account 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.
    SkuName string
    The SKU Name to use for the Stream Analytics Job. Possible values are Standard, StandardV2. Defaults to Standard.
    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. A conversion table for V2 streaming units can be found here

    NOTE: streaming_units must be set when type is Cloud.

    Tags Dictionary<string, string>
    Type string

    The type of the Stream Analytics Job. Possible values are Cloud and Edge. Defaults to Cloud. Changing this forces a new resource to be created.

    NOTE: Edge doesn't support stream_analytics_cluster_id and streaming_units.

    ResourceGroupName string
    The name of the Resource Group where the Stream Analytics Job should exist. Changing this forces a new resource to be created.
    TransformationQuery string
    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.

    NOTE: Support for Compatibility Level 1.2 is dependent on a new version of the Stream Analytics API, which being tracked in this issue.

    ContentStoragePolicy string
    The policy for storing stream analytics content. Possible values are JobStorageAccount, SystemAccount. Defaults to SystemAccount.
    DataLocale string
    Specifies the Data Locale of the Job, which should be a supported .NET Culture. Defaults to en-US.
    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 5.
    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 0.
    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.
    JobStorageAccounts []JobJobStorageAccountArgs
    The details of the job storage account. A job_storage_account 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.
    SkuName string
    The SKU Name to use for the Stream Analytics Job. Possible values are Standard, StandardV2. Defaults to Standard.
    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. A conversion table for V2 streaming units can be found here

    NOTE: streaming_units must be set when type is Cloud.

    Tags map[string]string
    Type string

    The type of the Stream Analytics Job. Possible values are Cloud and Edge. Defaults to Cloud. Changing this forces a new resource to be created.

    NOTE: Edge doesn't support stream_analytics_cluster_id and streaming_units.

    resourceGroupName String
    The name of the Resource Group where the Stream Analytics Job should exist. Changing this forces a new resource to be created.
    transformationQuery String
    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.

    NOTE: Support for Compatibility Level 1.2 is dependent on a new version of the Stream Analytics API, which being tracked in this issue.

    contentStoragePolicy String
    The policy for storing stream analytics content. Possible values are JobStorageAccount, SystemAccount. Defaults to SystemAccount.
    dataLocale String
    Specifies the Data Locale of the Job, which should be a supported .NET Culture. Defaults to en-US.
    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 5.
    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 0.
    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.
    jobStorageAccounts List<JobJobStorageAccount>
    The details of the job storage account. A job_storage_account 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.
    skuName String
    The SKU Name to use for the Stream Analytics Job. Possible values are Standard, StandardV2. Defaults to Standard.
    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. A conversion table for V2 streaming units can be found here

    NOTE: streaming_units must be set when type is Cloud.

    tags Map<String,String>
    type String

    The type of the Stream Analytics Job. Possible values are Cloud and Edge. Defaults to Cloud. Changing this forces a new resource to be created.

    NOTE: Edge doesn't support stream_analytics_cluster_id and streaming_units.

    resourceGroupName string
    The name of the Resource Group where the Stream Analytics Job should exist. Changing this forces a new resource to be created.
    transformationQuery string
    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.

    NOTE: Support for Compatibility Level 1.2 is dependent on a new version of the Stream Analytics API, which being tracked in this issue.

    contentStoragePolicy string
    The policy for storing stream analytics content. Possible values are JobStorageAccount, SystemAccount. Defaults to SystemAccount.
    dataLocale string
    Specifies the Data Locale of the Job, which should be a supported .NET Culture. Defaults to en-US.
    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 5.
    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 0.
    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.
    jobStorageAccounts JobJobStorageAccount[]
    The details of the job storage account. A job_storage_account 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.
    skuName string
    The SKU Name to use for the Stream Analytics Job. Possible values are Standard, StandardV2. Defaults to Standard.
    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. A conversion table for V2 streaming units can be found here

    NOTE: streaming_units must be set when type is Cloud.

    tags {[key: string]: string}
    type string

    The type of the Stream Analytics Job. Possible values are Cloud and Edge. Defaults to Cloud. Changing this forces a new resource to be created.

    NOTE: Edge doesn't support stream_analytics_cluster_id and streaming_units.

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

    NOTE: Support for Compatibility Level 1.2 is dependent on a new version of the Stream Analytics API, which being tracked in this issue.

    content_storage_policy str
    The policy for storing stream analytics content. Possible values are JobStorageAccount, SystemAccount. Defaults to SystemAccount.
    data_locale str
    Specifies the Data Locale of the Job, which should be a supported .NET Culture. Defaults to en-US.
    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 5.
    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 0.
    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_storage_accounts Sequence[JobJobStorageAccountArgs]
    The details of the job storage account. A job_storage_account 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.
    sku_name str
    The SKU Name to use for the Stream Analytics Job. Possible values are Standard, StandardV2. Defaults to Standard.
    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. A conversion table for V2 streaming units can be found here

    NOTE: streaming_units must be set when type is Cloud.

    tags Mapping[str, str]
    type str

    The type of the Stream Analytics Job. Possible values are Cloud and Edge. Defaults to Cloud. Changing this forces a new resource to be created.

    NOTE: Edge doesn't support stream_analytics_cluster_id and streaming_units.

    resourceGroupName String
    The name of the Resource Group where the Stream Analytics Job should exist. Changing this forces a new resource to be created.
    transformationQuery String
    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.

    NOTE: Support for Compatibility Level 1.2 is dependent on a new version of the Stream Analytics API, which being tracked in this issue.

    contentStoragePolicy String
    The policy for storing stream analytics content. Possible values are JobStorageAccount, SystemAccount. Defaults to SystemAccount.
    dataLocale String
    Specifies the Data Locale of the Job, which should be a supported .NET Culture. Defaults to en-US.
    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 5.
    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 0.
    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.
    jobStorageAccounts List<Property Map>
    The details of the job storage account. A job_storage_account 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.
    skuName String
    The SKU Name to use for the Stream Analytics Job. Possible values are Standard, StandardV2. Defaults to Standard.
    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. A conversion table for V2 streaming units can be found here

    NOTE: streaming_units must be set when type is Cloud.

    tags Map<String>
    type String

    The type of the Stream Analytics Job. Possible values are Cloud and Edge. Defaults to Cloud. Changing this forces a new resource to be created.

    NOTE: Edge doesn't support stream_analytics_cluster_id and streaming_units.

    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,
        content_storage_policy: 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,
        job_storage_accounts: Optional[Sequence[JobJobStorageAccountArgs]] = None,
        location: Optional[str] = None,
        name: Optional[str] = None,
        output_error_policy: Optional[str] = None,
        resource_group_name: Optional[str] = None,
        sku_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,
        type: 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.

    NOTE: Support for Compatibility Level 1.2 is dependent on a new version of the Stream Analytics API, which being tracked in this issue.

    ContentStoragePolicy string
    The policy for storing stream analytics content. Possible values are JobStorageAccount, SystemAccount. Defaults to SystemAccount.
    DataLocale string
    Specifies the Data Locale of the Job, which should be a supported .NET Culture. Defaults to en-US.
    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 5.
    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 0.
    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.
    JobStorageAccounts List<JobJobStorageAccount>
    The details of the job storage account. A job_storage_account 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.
    ResourceGroupName string
    The name of the Resource Group where the Stream Analytics Job should exist. Changing this forces a new resource to be created.
    SkuName string
    The SKU Name to use for the Stream Analytics Job. Possible values are Standard, StandardV2. Defaults to Standard.
    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. A conversion table for V2 streaming units can be found here

    NOTE: streaming_units must be set when type is Cloud.

    Tags Dictionary<string, string>
    TransformationQuery string
    Type string

    The type of the Stream Analytics Job. Possible values are Cloud and Edge. Defaults to Cloud. Changing this forces a new resource to be created.

    NOTE: Edge doesn't support stream_analytics_cluster_id and streaming_units.

    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.

    NOTE: Support for Compatibility Level 1.2 is dependent on a new version of the Stream Analytics API, which being tracked in this issue.

    ContentStoragePolicy string
    The policy for storing stream analytics content. Possible values are JobStorageAccount, SystemAccount. Defaults to SystemAccount.
    DataLocale string
    Specifies the Data Locale of the Job, which should be a supported .NET Culture. Defaults to en-US.
    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 5.
    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 0.
    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.
    JobStorageAccounts []JobJobStorageAccountArgs
    The details of the job storage account. A job_storage_account 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.
    ResourceGroupName string
    The name of the Resource Group where the Stream Analytics Job should exist. Changing this forces a new resource to be created.
    SkuName string
    The SKU Name to use for the Stream Analytics Job. Possible values are Standard, StandardV2. Defaults to Standard.
    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. A conversion table for V2 streaming units can be found here

    NOTE: streaming_units must be set when type is Cloud.

    Tags map[string]string
    TransformationQuery string
    Type string

    The type of the Stream Analytics Job. Possible values are Cloud and Edge. Defaults to Cloud. Changing this forces a new resource to be created.

    NOTE: Edge doesn't support stream_analytics_cluster_id and streaming_units.

    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.

    NOTE: Support for Compatibility Level 1.2 is dependent on a new version of the Stream Analytics API, which being tracked in this issue.

    contentStoragePolicy String
    The policy for storing stream analytics content. Possible values are JobStorageAccount, SystemAccount. Defaults to SystemAccount.
    dataLocale String
    Specifies the Data Locale of the Job, which should be a supported .NET Culture. Defaults to en-US.
    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 5.
    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 0.
    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.
    jobStorageAccounts List<JobJobStorageAccount>
    The details of the job storage account. A job_storage_account 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.
    resourceGroupName String
    The name of the Resource Group where the Stream Analytics Job should exist. Changing this forces a new resource to be created.
    skuName String
    The SKU Name to use for the Stream Analytics Job. Possible values are Standard, StandardV2. Defaults to Standard.
    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. A conversion table for V2 streaming units can be found here

    NOTE: streaming_units must be set when type is Cloud.

    tags Map<String,String>
    transformationQuery String
    type String

    The type of the Stream Analytics Job. Possible values are Cloud and Edge. Defaults to Cloud. Changing this forces a new resource to be created.

    NOTE: Edge doesn't support stream_analytics_cluster_id and streaming_units.

    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.

    NOTE: Support for Compatibility Level 1.2 is dependent on a new version of the Stream Analytics API, which being tracked in this issue.

    contentStoragePolicy string
    The policy for storing stream analytics content. Possible values are JobStorageAccount, SystemAccount. Defaults to SystemAccount.
    dataLocale string
    Specifies the Data Locale of the Job, which should be a supported .NET Culture. Defaults to en-US.
    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 5.
    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 0.
    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.
    jobStorageAccounts JobJobStorageAccount[]
    The details of the job storage account. A job_storage_account 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.
    resourceGroupName string
    The name of the Resource Group where the Stream Analytics Job should exist. Changing this forces a new resource to be created.
    skuName string
    The SKU Name to use for the Stream Analytics Job. Possible values are Standard, StandardV2. Defaults to Standard.
    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. A conversion table for V2 streaming units can be found here

    NOTE: streaming_units must be set when type is Cloud.

    tags {[key: string]: string}
    transformationQuery string
    type string

    The type of the Stream Analytics Job. Possible values are Cloud and Edge. Defaults to Cloud. Changing this forces a new resource to be created.

    NOTE: Edge doesn't support stream_analytics_cluster_id and streaming_units.

    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.

    NOTE: Support for Compatibility Level 1.2 is dependent on a new version of the Stream Analytics API, which being tracked in this issue.

    content_storage_policy str
    The policy for storing stream analytics content. Possible values are JobStorageAccount, SystemAccount. Defaults to SystemAccount.
    data_locale str
    Specifies the Data Locale of the Job, which should be a supported .NET Culture. Defaults to en-US.
    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 5.
    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 0.
    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.
    job_storage_accounts Sequence[JobJobStorageAccountArgs]
    The details of the job storage account. A job_storage_account 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.
    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.
    sku_name str
    The SKU Name to use for the Stream Analytics Job. Possible values are Standard, StandardV2. Defaults to Standard.
    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. A conversion table for V2 streaming units can be found here

    NOTE: streaming_units must be set when type is Cloud.

    tags Mapping[str, str]
    transformation_query str
    type str

    The type of the Stream Analytics Job. Possible values are Cloud and Edge. Defaults to Cloud. Changing this forces a new resource to be created.

    NOTE: Edge doesn't support stream_analytics_cluster_id and streaming_units.

    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.

    NOTE: Support for Compatibility Level 1.2 is dependent on a new version of the Stream Analytics API, which being tracked in this issue.

    contentStoragePolicy String
    The policy for storing stream analytics content. Possible values are JobStorageAccount, SystemAccount. Defaults to SystemAccount.
    dataLocale String
    Specifies the Data Locale of the Job, which should be a supported .NET Culture. Defaults to en-US.
    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 5.
    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 0.
    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.
    jobStorageAccounts List<Property Map>
    The details of the job storage account. A job_storage_account 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.
    resourceGroupName String
    The name of the Resource Group where the Stream Analytics Job should exist. Changing this forces a new resource to be created.
    skuName String
    The SKU Name to use for the Stream Analytics Job. Possible values are Standard, StandardV2. Defaults to Standard.
    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. A conversion table for V2 streaming units can be found here

    NOTE: streaming_units must be set when type is Cloud.

    tags Map<String>
    transformationQuery String
    type String

    The type of the Stream Analytics Job. Possible values are Cloud and Edge. Defaults to Cloud. Changing this forces a new resource to be created.

    NOTE: Edge doesn't support stream_analytics_cluster_id and streaming_units.

    Supporting Types

    JobIdentity, JobIdentityArgs

    Type string
    Specifies the type of Managed Service Identity that should be configured on this Stream Analytics Job. Possible values are SystemAssigned and UserAssigned.
    IdentityIds List<string>
    The identity id of the user assigned identity to use when type is UserAssigned
    PrincipalId string
    The Principal ID associated with this Managed Service Identity.
    TenantId string
    The Tenant ID associated with this Managed Service Identity.
    Type string
    Specifies the type of Managed Service Identity that should be configured on this Stream Analytics Job. Possible values are SystemAssigned and UserAssigned.
    IdentityIds []string
    The identity id of the user assigned identity to use when type is UserAssigned
    PrincipalId string
    The Principal ID associated with this Managed Service Identity.
    TenantId string
    The Tenant ID associated with this Managed Service Identity.
    type String
    Specifies the type of Managed Service Identity that should be configured on this Stream Analytics Job. Possible values are SystemAssigned and UserAssigned.
    identityIds List<String>
    The identity id of the user assigned identity to use when type is UserAssigned
    principalId String
    The Principal ID associated with this Managed Service Identity.
    tenantId String
    The Tenant ID associated with this Managed Service Identity.
    type string
    Specifies the type of Managed Service Identity that should be configured on this Stream Analytics Job. Possible values are SystemAssigned and UserAssigned.
    identityIds string[]
    The identity id of the user assigned identity to use when type is UserAssigned
    principalId string
    The Principal ID associated with this Managed Service Identity.
    tenantId string
    The Tenant ID associated with this Managed Service Identity.
    type str
    Specifies the type of Managed Service Identity that should be configured on this Stream Analytics Job. Possible values are SystemAssigned and UserAssigned.
    identity_ids Sequence[str]
    The identity id of the user assigned identity to use when type is UserAssigned
    principal_id str
    The Principal ID associated with this Managed Service Identity.
    tenant_id str
    The Tenant ID associated with this Managed Service Identity.
    type String
    Specifies the type of Managed Service Identity that should be configured on this Stream Analytics Job. Possible values are SystemAssigned and UserAssigned.
    identityIds List<String>
    The identity id of the user assigned identity to use when type is UserAssigned
    principalId String
    The Principal ID associated with this Managed Service Identity.
    tenantId String
    The Tenant ID associated with this Managed Service Identity.

    JobJobStorageAccount, JobJobStorageAccountArgs

    AccountKey string
    The account key for the Azure storage account.
    AccountName string
    The name of the Azure storage account.
    AuthenticationMode string
    The authentication mode of the storage account. The only supported value is ConnectionString. Defaults to ConnectionString.
    AccountKey string
    The account key for the Azure storage account.
    AccountName string
    The name of the Azure storage account.
    AuthenticationMode string
    The authentication mode of the storage account. The only supported value is ConnectionString. Defaults to ConnectionString.
    accountKey String
    The account key for the Azure storage account.
    accountName String
    The name of the Azure storage account.
    authenticationMode String
    The authentication mode of the storage account. The only supported value is ConnectionString. Defaults to ConnectionString.
    accountKey string
    The account key for the Azure storage account.
    accountName string
    The name of the Azure storage account.
    authenticationMode string
    The authentication mode of the storage account. The only supported value is ConnectionString. Defaults to ConnectionString.
    account_key str
    The account key for the Azure storage account.
    account_name str
    The name of the Azure storage account.
    authentication_mode str
    The authentication mode of the storage account. The only supported value is ConnectionString. Defaults to ConnectionString.
    accountKey String
    The account key for the Azure storage account.
    accountName String
    The name of the Azure storage account.
    authenticationMode String
    The authentication mode of the storage account. The only supported value is ConnectionString. Defaults to ConnectionString.

    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.

    Azure v6.21.0 published on Friday, Mar 7, 2025 by Pulumi
    pulumi/pulumi-azure