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

We recommend using Azure Native.

Azure v6.22.0 published on Tuesday, Apr 1, 2025 by Pulumi
pulumi/pulumi-azure

azure.streamanalytics.Job

Explore with Pulumi AI

We recommend using Azure Native.

Azure v6.22.0 published on Tuesday, Apr 1, 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]
`,
});
Copy
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]
""")
Copy
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
	})
}
Copy
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]
",
    });

});
Copy
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());

    }
}
Copy
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]
Copy

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 This property is required. string
The unique name of the resource.
args This property is required. JobArgs
The arguments to resource properties.
opts CustomResourceOptions
Bag of options to control resource's behavior.
resource_name This property is required. str
The unique name of the resource.
args This property is required. 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 This property is required. string
The unique name of the resource.
args This property is required. JobArgs
The arguments to resource properties.
opts ResourceOption
Bag of options to control resource's behavior.
name This property is required. string
The unique name of the resource.
args This property is required. JobArgs
The arguments to resource properties.
opts CustomResourceOptions
Bag of options to control resource's behavior.
name This property is required. String
The unique name of the resource.
args This property is required. 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",
});
Copy
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"),
})
Copy
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());
Copy
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")
Copy
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",
});
Copy
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
Copy

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
This property is required.
Changes to this property will trigger replacement.
string
The name of the Resource Group where the Stream Analytics Job should exist. Changing this forces a new resource to be created.
TransformationQuery This property is required. 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.

Note: content_storage_policy must be set to JobStorageAccount when specifying job_storage_account.

Location Changes to this property will trigger replacement. string
The Azure Region in which the Resource Group exists. Changing this forces a new resource to be created.
Name Changes to this property will trigger replacement. 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 Changes to this property will trigger replacement. 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
This property is required.
Changes to this property will trigger replacement.
string
The name of the Resource Group where the Stream Analytics Job should exist. Changing this forces a new resource to be created.
TransformationQuery This property is required. 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.

Note: content_storage_policy must be set to JobStorageAccount when specifying job_storage_account.

Location Changes to this property will trigger replacement. string
The Azure Region in which the Resource Group exists. Changing this forces a new resource to be created.
Name Changes to this property will trigger replacement. 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 Changes to this property will trigger replacement. 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
This property is required.
Changes to this property will trigger replacement.
String
The name of the Resource Group where the Stream Analytics Job should exist. Changing this forces a new resource to be created.
transformationQuery This property is required. 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.

Note: content_storage_policy must be set to JobStorageAccount when specifying job_storage_account.

location Changes to this property will trigger replacement. String
The Azure Region in which the Resource Group exists. Changing this forces a new resource to be created.
name Changes to this property will trigger replacement. 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 Changes to this property will trigger replacement. 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
This property is required.
Changes to this property will trigger replacement.
string
The name of the Resource Group where the Stream Analytics Job should exist. Changing this forces a new resource to be created.
transformationQuery This property is required. 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.

Note: content_storage_policy must be set to JobStorageAccount when specifying job_storage_account.

location Changes to this property will trigger replacement. string
The Azure Region in which the Resource Group exists. Changing this forces a new resource to be created.
name Changes to this property will trigger replacement. 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 Changes to this property will trigger replacement. 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
This property is required.
Changes to this property will trigger replacement.
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 This property is required. 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.

Note: content_storage_policy must be set to JobStorageAccount when specifying job_storage_account.

location Changes to this property will trigger replacement. str
The Azure Region in which the Resource Group exists. Changing this forces a new resource to be created.
name Changes to this property will trigger replacement. 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 Changes to this property will trigger replacement. 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
This property is required.
Changes to this property will trigger replacement.
String
The name of the Resource Group where the Stream Analytics Job should exist. Changing this forces a new resource to be created.
transformationQuery This property is required. 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.

Note: content_storage_policy must be set to JobStorageAccount when specifying job_storage_account.

location Changes to this property will trigger replacement. String
The Azure Region in which the Resource Group exists. Changing this forces a new resource to be created.
name Changes to this property will trigger replacement. 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 Changes to this property will trigger replacement. 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 This property is required.
The unique name of the resulting resource.
id This property is required.
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 This property is required.
The unique name of the resulting resource.
id This property is required.
The unique provider ID of the resource to lookup.
name This property is required.
The unique name of the resulting resource.
id This property is required.
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 This property is required.
The unique name of the resulting resource.
id This property is required.
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 This property is required.
The unique name of the resulting resource.
id This property is required.
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.

Note: content_storage_policy must be set to JobStorageAccount when specifying job_storage_account.

Location Changes to this property will trigger replacement. string
The Azure Region in which the Resource Group exists. Changing this forces a new resource to be created.
Name Changes to this property will trigger replacement. 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 Changes to this property will trigger replacement. 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 Changes to this property will trigger replacement. 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.

Note: content_storage_policy must be set to JobStorageAccount when specifying job_storage_account.

Location Changes to this property will trigger replacement. string
The Azure Region in which the Resource Group exists. Changing this forces a new resource to be created.
Name Changes to this property will trigger replacement. 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 Changes to this property will trigger replacement. 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 Changes to this property will trigger replacement. 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.

Note: content_storage_policy must be set to JobStorageAccount when specifying job_storage_account.

location Changes to this property will trigger replacement. String
The Azure Region in which the Resource Group exists. Changing this forces a new resource to be created.
name Changes to this property will trigger replacement. 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 Changes to this property will trigger replacement. 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 Changes to this property will trigger replacement. 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.

Note: content_storage_policy must be set to JobStorageAccount when specifying job_storage_account.

location Changes to this property will trigger replacement. string
The Azure Region in which the Resource Group exists. Changing this forces a new resource to be created.
name Changes to this property will trigger replacement. 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 Changes to this property will trigger replacement. 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 Changes to this property will trigger replacement. 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.

Note: content_storage_policy must be set to JobStorageAccount when specifying job_storage_account.

location Changes to this property will trigger replacement. str
The Azure Region in which the Resource Group exists. Changing this forces a new resource to be created.
name Changes to this property will trigger replacement. 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 Changes to this property will trigger replacement. 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 Changes to this property will trigger replacement. 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.

Note: content_storage_policy must be set to JobStorageAccount when specifying job_storage_account.

location Changes to this property will trigger replacement. String
The Azure Region in which the Resource Group exists. Changing this forces a new resource to be created.
name Changes to this property will trigger replacement. 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 Changes to this property will trigger replacement. 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 Changes to this property will trigger replacement. 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 This property is required. 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 This property is required. 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 This property is required. 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 This property is required. 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 This property is required. 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 This property is required. 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 This property is required. string
The account key for the Azure storage account.
AccountName This property is required. 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 This property is required. string
The account key for the Azure storage account.
AccountName This property is required. 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 This property is required. String
The account key for the Azure storage account.
accountName This property is required. 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 This property is required. string
The account key for the Azure storage account.
accountName This property is required. 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 This property is required. str
The account key for the Azure storage account.
account_name This property is required. 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 This property is required. String
The account key for the Azure storage account.
accountName This property is required. 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
Copy

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.

We recommend using Azure Native.

Azure v6.22.0 published on Tuesday, Apr 1, 2025 by Pulumi
pulumi/pulumi-azure