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

We recommend using Azure Native.

Azure Classic v5.58.0 published on Saturday, Dec 2, 2023 by Pulumi

azure.streamanalytics.getJob

Explore with Pulumi AI

azure logo

We recommend using Azure Native.

Azure Classic v5.58.0 published on Saturday, Dec 2, 2023 by Pulumi

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

    Example Usage

    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 main
    
    import (
    	"github.com/pulumi/pulumi-azure/sdk/v5/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
    	})
    }
    
    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()));
        }
    }
    
    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)
    
    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);
    
    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)
    // Output-based functions aren't available in Java yet
    
    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
    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
    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
    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
    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
    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
    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

    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.

    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.

    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.

    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.

    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.

    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 Classic v5.58.0 published on Saturday, Dec 2, 2023 by Pulumi