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

We recommend using Azure Native.

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

azure.streamanalytics.getJob

Explore with Pulumi AI

We recommend using Azure Native.

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

Use this data source to access information about an existing Stream Analytics Job.

Example Usage

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

const example = azure.streamanalytics.getJob({
    name: "example-job",
    resourceGroupName: "example-resources",
});
export const jobId = example.then(example => example.jobId);
Copy
import pulumi
import pulumi_azure as azure

example = azure.streamanalytics.get_job(name="example-job",
    resource_group_name="example-resources")
pulumi.export("jobId", example.job_id)
Copy
package main

import (
	"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 := streamanalytics.LookupJob(ctx, &streamanalytics.LookupJobArgs{
			Name:              "example-job",
			ResourceGroupName: "example-resources",
		}, nil)
		if err != nil {
			return err
		}
		ctx.Export("jobId", example.JobId)
		return nil
	})
}
Copy
using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Azure = Pulumi.Azure;

return await Deployment.RunAsync(() => 
{
    var example = Azure.StreamAnalytics.GetJob.Invoke(new()
    {
        Name = "example-job",
        ResourceGroupName = "example-resources",
    });

    return new Dictionary<string, object?>
    {
        ["jobId"] = example.Apply(getJobResult => getJobResult.JobId),
    };
});
Copy
package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.azure.streamanalytics.StreamanalyticsFunctions;
import com.pulumi.azure.streamanalytics.inputs.GetJobArgs;
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) {
        final var example = StreamanalyticsFunctions.getJob(GetJobArgs.builder()
            .name("example-job")
            .resourceGroupName("example-resources")
            .build());

        ctx.export("jobId", example.applyValue(getJobResult -> getJobResult.jobId()));
    }
}
Copy
variables:
  example:
    fn::invoke:
      function: azure:streamanalytics:getJob
      arguments:
        name: example-job
        resourceGroupName: example-resources
outputs:
  jobId: ${example.jobId}
Copy

Using getJob

Two invocation forms are available. The direct form accepts plain arguments and either blocks until the result value is available, or returns a Promise-wrapped result. The output form accepts Input-wrapped arguments and returns an Output-wrapped result.

function getJob(args: GetJobArgs, opts?: InvokeOptions): Promise<GetJobResult>
function getJobOutput(args: GetJobOutputArgs, opts?: InvokeOptions): Output<GetJobResult>
Copy
def get_job(name: Optional[str] = None,
            resource_group_name: Optional[str] = None,
            opts: Optional[InvokeOptions] = None) -> GetJobResult
def get_job_output(name: Optional[pulumi.Input[str]] = None,
            resource_group_name: Optional[pulumi.Input[str]] = None,
            opts: Optional[InvokeOptions] = None) -> Output[GetJobResult]
Copy
func LookupJob(ctx *Context, args *LookupJobArgs, opts ...InvokeOption) (*LookupJobResult, error)
func LookupJobOutput(ctx *Context, args *LookupJobOutputArgs, opts ...InvokeOption) LookupJobResultOutput
Copy

> Note: This function is named LookupJob in the Go SDK.

public static class GetJob 
{
    public static Task<GetJobResult> InvokeAsync(GetJobArgs args, InvokeOptions? opts = null)
    public static Output<GetJobResult> Invoke(GetJobInvokeArgs args, InvokeOptions? opts = null)
}
Copy
public static CompletableFuture<GetJobResult> getJob(GetJobArgs args, InvokeOptions options)
public static Output<GetJobResult> getJob(GetJobArgs args, InvokeOptions options)
Copy
fn::invoke:
  function: azure:streamanalytics/getJob:getJob
  arguments:
    # arguments dictionary
Copy

The following arguments are supported:

Name This property is required. string
Specifies the name of the Stream Analytics Job.
ResourceGroupName This property is required. string
Specifies the name of the resource group the Stream Analytics Job is located in.
Name This property is required. string
Specifies the name of the Stream Analytics Job.
ResourceGroupName This property is required. string
Specifies the name of the resource group the Stream Analytics Job is located in.
name This property is required. String
Specifies the name of the Stream Analytics Job.
resourceGroupName This property is required. String
Specifies the name of the resource group the Stream Analytics Job is located in.
name This property is required. string
Specifies the name of the Stream Analytics Job.
resourceGroupName This property is required. string
Specifies the name of the resource group the Stream Analytics Job is located in.
name This property is required. str
Specifies the name of the Stream Analytics Job.
resource_group_name This property is required. str
Specifies the name of the resource group the Stream Analytics Job is located in.
name This property is required. String
Specifies the name of the Stream Analytics Job.
resourceGroupName This property is required. String
Specifies the name of the resource group the Stream Analytics Job is located in.

getJob Result

The following output properties are available:

CompatibilityLevel string
The compatibility level for this job.
DataLocale string
The Data Locale of the Job.
EventsLateArrivalMaxDelayInSeconds int
The maximum tolerable delay in seconds where events arriving late could be included.
EventsOutOfOrderMaxDelayInSeconds int
The maximum tolerable delay in seconds where out-of-order events can be adjusted to be back in order.
EventsOutOfOrderPolicy string
The policy which should be applied to events which arrive out of order in the input event stream.
Id string
The provider-assigned unique ID for this managed resource.
Identities List<GetJobIdentity>
An identity block as defined below.
JobId string
The Job ID assigned by the Stream Analytics Job.
LastOutputTime string
The time at which the Stream Analytics job last produced an output.
Location string
The Azure location where the Stream Analytics Job exists.
Name string
OutputErrorPolicy string
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).
ResourceGroupName string
SkuName string
The SKU Name to use for the Stream Analytics Job.
StartMode string
The starting mode set for this Stream Analytics Job.
StartTime string
The time at which this Stream Analytics Job was scheduled to start.
StreamingUnits int
The number of streaming units that this Stream Analytics Job uses.
TransformationQuery string
The query that will be run in this Stream Analytics Job, written in Stream Analytics Query Language (SAQL).
CompatibilityLevel string
The compatibility level for this job.
DataLocale string
The Data Locale of the Job.
EventsLateArrivalMaxDelayInSeconds int
The maximum tolerable delay in seconds where events arriving late could be included.
EventsOutOfOrderMaxDelayInSeconds int
The maximum tolerable delay in seconds where out-of-order events can be adjusted to be back in order.
EventsOutOfOrderPolicy string
The policy which should be applied to events which arrive out of order in the input event stream.
Id string
The provider-assigned unique ID for this managed resource.
Identities []GetJobIdentity
An identity block as defined below.
JobId string
The Job ID assigned by the Stream Analytics Job.
LastOutputTime string
The time at which the Stream Analytics job last produced an output.
Location string
The Azure location where the Stream Analytics Job exists.
Name string
OutputErrorPolicy string
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).
ResourceGroupName string
SkuName string
The SKU Name to use for the Stream Analytics Job.
StartMode string
The starting mode set for this Stream Analytics Job.
StartTime string
The time at which this Stream Analytics Job was scheduled to start.
StreamingUnits int
The number of streaming units that this Stream Analytics Job uses.
TransformationQuery string
The query that will be run in this Stream Analytics Job, written in Stream Analytics Query Language (SAQL).
compatibilityLevel String
The compatibility level for this job.
dataLocale String
The Data Locale of the Job.
eventsLateArrivalMaxDelayInSeconds Integer
The maximum tolerable delay in seconds where events arriving late could be included.
eventsOutOfOrderMaxDelayInSeconds Integer
The maximum tolerable delay in seconds where out-of-order events can be adjusted to be back in order.
eventsOutOfOrderPolicy String
The policy which should be applied to events which arrive out of order in the input event stream.
id String
The provider-assigned unique ID for this managed resource.
identities List<GetJobIdentity>
An identity block as defined below.
jobId String
The Job ID assigned by the Stream Analytics Job.
lastOutputTime String
The time at which the Stream Analytics job last produced an output.
location String
The Azure location where the Stream Analytics Job exists.
name String
outputErrorPolicy String
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).
resourceGroupName String
skuName String
The SKU Name to use for the Stream Analytics Job.
startMode String
The starting mode set for this Stream Analytics Job.
startTime String
The time at which this Stream Analytics Job was scheduled to start.
streamingUnits Integer
The number of streaming units that this Stream Analytics Job uses.
transformationQuery String
The query that will be run in this Stream Analytics Job, written in Stream Analytics Query Language (SAQL).
compatibilityLevel string
The compatibility level for this job.
dataLocale string
The Data Locale of the Job.
eventsLateArrivalMaxDelayInSeconds number
The maximum tolerable delay in seconds where events arriving late could be included.
eventsOutOfOrderMaxDelayInSeconds number
The maximum tolerable delay in seconds where out-of-order events can be adjusted to be back in order.
eventsOutOfOrderPolicy string
The policy which should be applied to events which arrive out of order in the input event stream.
id string
The provider-assigned unique ID for this managed resource.
identities GetJobIdentity[]
An identity block as defined below.
jobId string
The Job ID assigned by the Stream Analytics Job.
lastOutputTime string
The time at which the Stream Analytics job last produced an output.
location string
The Azure location where the Stream Analytics Job exists.
name string
outputErrorPolicy string
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).
resourceGroupName string
skuName string
The SKU Name to use for the Stream Analytics Job.
startMode string
The starting mode set for this Stream Analytics Job.
startTime string
The time at which this Stream Analytics Job was scheduled to start.
streamingUnits number
The number of streaming units that this Stream Analytics Job uses.
transformationQuery string
The query that will be run in this Stream Analytics Job, written in Stream Analytics Query Language (SAQL).
compatibility_level str
The compatibility level for this job.
data_locale str
The Data Locale of the Job.
events_late_arrival_max_delay_in_seconds int
The maximum tolerable delay in seconds where events arriving late could be included.
events_out_of_order_max_delay_in_seconds int
The maximum tolerable delay in seconds where out-of-order events can be adjusted to be back in order.
events_out_of_order_policy str
The policy which should be applied to events which arrive out of order in the input event stream.
id str
The provider-assigned unique ID for this managed resource.
identities Sequence[GetJobIdentity]
An identity block as defined below.
job_id str
The Job ID assigned by the Stream Analytics Job.
last_output_time str
The time at which the Stream Analytics job last produced an output.
location str
The Azure location where the Stream Analytics Job exists.
name str
output_error_policy str
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).
resource_group_name str
sku_name str
The SKU Name to use for the Stream Analytics Job.
start_mode str
The starting mode set for this Stream Analytics Job.
start_time str
The time at which this Stream Analytics Job was scheduled to start.
streaming_units int
The number of streaming units that this Stream Analytics Job uses.
transformation_query str
The query that will be run in this Stream Analytics Job, written in Stream Analytics Query Language (SAQL).
compatibilityLevel String
The compatibility level for this job.
dataLocale String
The Data Locale of the Job.
eventsLateArrivalMaxDelayInSeconds Number
The maximum tolerable delay in seconds where events arriving late could be included.
eventsOutOfOrderMaxDelayInSeconds Number
The maximum tolerable delay in seconds where out-of-order events can be adjusted to be back in order.
eventsOutOfOrderPolicy String
The policy which should be applied to events which arrive out of order in the input event stream.
id String
The provider-assigned unique ID for this managed resource.
identities List<Property Map>
An identity block as defined below.
jobId String
The Job ID assigned by the Stream Analytics Job.
lastOutputTime String
The time at which the Stream Analytics job last produced an output.
location String
The Azure location where the Stream Analytics Job exists.
name String
outputErrorPolicy String
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).
resourceGroupName String
skuName String
The SKU Name to use for the Stream Analytics Job.
startMode String
The starting mode set for this Stream Analytics Job.
startTime String
The time at which this Stream Analytics Job was scheduled to start.
streamingUnits Number
The number of streaming units that this Stream Analytics Job uses.
transformationQuery String
The query that will be run in this Stream Analytics Job, written in Stream Analytics Query Language (SAQL).

Supporting Types

GetJobIdentity

IdentityIds This property is required. List<string>
A list of User Assigned Managed Identity IDs assigned to this resource.
PrincipalId This property is required. string
The Principal ID associated with this Managed Service Identity.
TenantId This property is required. string
The Tenant ID associated with this Managed Service Identity.
Type This property is required. string
The identity type of this Managed Service Identity.
IdentityIds This property is required. []string
A list of User Assigned Managed Identity IDs assigned to this resource.
PrincipalId This property is required. string
The Principal ID associated with this Managed Service Identity.
TenantId This property is required. string
The Tenant ID associated with this Managed Service Identity.
Type This property is required. string
The identity type of this Managed Service Identity.
identityIds This property is required. List<String>
A list of User Assigned Managed Identity IDs assigned to this resource.
principalId This property is required. String
The Principal ID associated with this Managed Service Identity.
tenantId This property is required. String
The Tenant ID associated with this Managed Service Identity.
type This property is required. String
The identity type of this Managed Service Identity.
identityIds This property is required. string[]
A list of User Assigned Managed Identity IDs assigned to this resource.
principalId This property is required. string
The Principal ID associated with this Managed Service Identity.
tenantId This property is required. string
The Tenant ID associated with this Managed Service Identity.
type This property is required. string
The identity type of this Managed Service Identity.
identity_ids This property is required. Sequence[str]
A list of User Assigned Managed Identity IDs assigned to this resource.
principal_id This property is required. str
The Principal ID associated with this Managed Service Identity.
tenant_id This property is required. str
The Tenant ID associated with this Managed Service Identity.
type This property is required. str
The identity type of this Managed Service Identity.
identityIds This property is required. List<String>
A list of User Assigned Managed Identity IDs assigned to this resource.
principalId This property is required. String
The Principal ID associated with this Managed Service Identity.
tenantId This property is required. String
The Tenant ID associated with this Managed Service Identity.
type This property is required. String
The identity type of this Managed Service Identity.

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