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

We recommend using Azure Native.

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

azure.streamanalytics.getJob

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

    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);

    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)

    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
	})
}

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

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

    variables:
  example:
    fn::invoke:
      function: azure:streamanalytics:getJob
      arguments:
        name: example-job
        resourceGroupName: example-resources
outputs:
  jobId: ${example.jobId}

    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>
    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]
    func LookupJob(ctx *Context, args *LookupJobArgs, opts ...InvokeOption) (*LookupJobResult, error)
func LookupJobOutput(ctx *Context, args *LookupJobOutputArgs, opts ...InvokeOption) LookupJobResultOutput

    > 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)
}
    public static CompletableFuture<GetJobResult> getJob(GetJobArgs args, InvokeOptions options)
public static Output<GetJobResult> getJob(GetJobArgs args, InvokeOptions options)

    fn::invoke:
  function: azure:streamanalytics/getJob:getJob
  arguments:
    # arguments dictionary

    The following arguments are supported:

    Name string
    Specifies the name of the Stream Analytics Job.
    ResourceGroupName string
    Specifies the name of the resource group the Stream Analytics Job is located in.
    Name string
    Specifies the name of the Stream Analytics Job.
    ResourceGroupName string
    Specifies the name of the resource group the Stream Analytics Job is located in.
    name String
    Specifies the name of the Stream Analytics Job.
    resourceGroupName String
    Specifies the name of the resource group the Stream Analytics Job is located in.
    name string
    Specifies the name of the Stream Analytics Job.
    resourceGroupName string
    Specifies the name of the resource group the Stream Analytics Job is located in.
    name str
    Specifies the name of the Stream Analytics Job.
    resource_group_name str
    Specifies the name of the resource group the Stream Analytics Job is located in.
    name String
    Specifies the name of the Stream Analytics Job.
    resourceGroupName 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 List<string>
    A list of User Assigned Managed Identity IDs assigned to this resource.
    PrincipalId string
    The Principal ID associated with this Managed Service Identity.
    TenantId string
    The Tenant ID associated with this Managed Service Identity.
    Type string
    The identity type of this Managed Service Identity.
    IdentityIds []string
    A list of User Assigned Managed Identity IDs assigned to this resource.
    PrincipalId string
    The Principal ID associated with this Managed Service Identity.
    TenantId string
    The Tenant ID associated with this Managed Service Identity.
    Type string
    The identity type of this Managed Service Identity.
    identityIds List<String>
    A list of User Assigned Managed Identity IDs assigned to this resource.
    principalId String
    The Principal ID associated with this Managed Service Identity.
    tenantId String
    The Tenant ID associated with this Managed Service Identity.
    type String
    The identity type of this Managed Service Identity.
    identityIds string[]
    A list of User Assigned Managed Identity IDs assigned to this resource.
    principalId string
    The Principal ID associated with this Managed Service Identity.
    tenantId string
    The Tenant ID associated with this Managed Service Identity.
    type string
    The identity type of this Managed Service Identity.
    identity_ids Sequence[str]
    A list of User Assigned Managed Identity IDs assigned to this resource.
    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 str
    The identity type of this Managed Service Identity.
    identityIds List<String>
    A list of User Assigned Managed Identity IDs assigned to this resource.
    principalId String
    The Principal ID associated with this Managed Service Identity.
    tenantId String
    The Tenant ID associated with this Managed Service Identity.
    type 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.
    azure logo

    We recommend using Azure Native.

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