pulumi-aws-kotlin/com.pulumi.aws.glue.kotlin/Trigger

Trigger

class Trigger : KotlinCustomResource

Manages a Glue Trigger resource.

Example Usage

Conditional Trigger

import * as pulumi from "@pulumi/pulumi";
import * as aws from "@pulumi/aws";
const example = new aws.glue.Trigger("example", {
    name: "example",
    type: "CONDITIONAL",
    actions: [{
        jobName: example1.name,
    }],
    predicate: {
        conditions: [{
            jobName: example2.name,
            state: "SUCCEEDED",
        }],
    },
});
Content copied to clipboard
import pulumi
import pulumi_aws as aws
example = aws.glue.Trigger("example",
    name="example",
    type="CONDITIONAL",
    actions=[{
        "job_name": example1["name"],
    }],
    predicate={
        "conditions": [{
            "job_name": example2["name"],
            "state": "SUCCEEDED",
        }],
    })
Content copied to clipboard
using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Aws = Pulumi.Aws;
return await Deployment.RunAsync(() =>
{
    var example = new Aws.Glue.Trigger("example", new()
    {
        Name = "example",
        Type = "CONDITIONAL",
        Actions = new[]
        {
            new Aws.Glue.Inputs.TriggerActionArgs
            {
                JobName = example1.Name,
            },
        },
        Predicate = new Aws.Glue.Inputs.TriggerPredicateArgs
        {
            Conditions = new[]
            {
                new Aws.Glue.Inputs.TriggerPredicateConditionArgs
                {
                    JobName = example2.Name,
                    State = "SUCCEEDED",
                },
            },
        },
    });
});
Content copied to clipboard
package main
import (
	"github.com/pulumi/pulumi-aws/sdk/v6/go/aws/glue"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := glue.NewTrigger(ctx, "example", &glue.TriggerArgs{
			Name: pulumi.String("example"),
			Type: pulumi.String("CONDITIONAL"),
			Actions: glue.TriggerActionArray{
				&glue.TriggerActionArgs{
					JobName: pulumi.Any(example1.Name),
				},
			},
			Predicate: &glue.TriggerPredicateArgs{
				Conditions: glue.TriggerPredicateConditionArray{
					&glue.TriggerPredicateConditionArgs{
						JobName: pulumi.Any(example2.Name),
						State:   pulumi.String("SUCCEEDED"),
					},
				},
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}
Content copied to clipboard
package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.aws.glue.Trigger;
import com.pulumi.aws.glue.TriggerArgs;
import com.pulumi.aws.glue.inputs.TriggerActionArgs;
import com.pulumi.aws.glue.inputs.TriggerPredicateArgs;
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 Trigger("example", TriggerArgs.builder()
            .name("example")
            .type("CONDITIONAL")
            .actions(TriggerActionArgs.builder()
                .jobName(example1.name())
                .build())
            .predicate(TriggerPredicateArgs.builder()
                .conditions(TriggerPredicateConditionArgs.builder()
                    .jobName(example2.name())
                    .state("SUCCEEDED")
                    .build())
                .build())
            .build());
    }
}
Content copied to clipboard
resources:
  example:
    type: aws:glue:Trigger
    properties:
      name: example
      type: CONDITIONAL
      actions:
        - jobName: ${example1.name}
      predicate:
        conditions:
          - jobName: ${example2.name}
            state: SUCCEEDED
Content copied to clipboard

On-Demand Trigger

import * as pulumi from "@pulumi/pulumi";
import * as aws from "@pulumi/aws";
const example = new aws.glue.Trigger("example", {
    name: "example",
    type: "ON_DEMAND",
    actions: [{
        jobName: exampleAwsGlueJob.name,
    }],
});
Content copied to clipboard
import pulumi
import pulumi_aws as aws
example = aws.glue.Trigger("example",
    name="example",
    type="ON_DEMAND",
    actions=[{
        "job_name": example_aws_glue_job["name"],
    }])
Content copied to clipboard
using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Aws = Pulumi.Aws;
return await Deployment.RunAsync(() =>
{
    var example = new Aws.Glue.Trigger("example", new()
    {
        Name = "example",
        Type = "ON_DEMAND",
        Actions = new[]
        {
            new Aws.Glue.Inputs.TriggerActionArgs
            {
                JobName = exampleAwsGlueJob.Name,
            },
        },
    });
});
Content copied to clipboard
package main
import (
	"github.com/pulumi/pulumi-aws/sdk/v6/go/aws/glue"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := glue.NewTrigger(ctx, "example", &glue.TriggerArgs{
			Name: pulumi.String("example"),
			Type: pulumi.String("ON_DEMAND"),
			Actions: glue.TriggerActionArray{
				&glue.TriggerActionArgs{
					JobName: pulumi.Any(exampleAwsGlueJob.Name),
				},
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}
Content copied to clipboard
package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.aws.glue.Trigger;
import com.pulumi.aws.glue.TriggerArgs;
import com.pulumi.aws.glue.inputs.TriggerActionArgs;
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 Trigger("example", TriggerArgs.builder()
            .name("example")
            .type("ON_DEMAND")
            .actions(TriggerActionArgs.builder()
                .jobName(exampleAwsGlueJob.name())
                .build())
            .build());
    }
}
Content copied to clipboard
resources:
  example:
    type: aws:glue:Trigger
    properties:
      name: example
      type: ON_DEMAND
      actions:
        - jobName: ${exampleAwsGlueJob.name}
Content copied to clipboard

Scheduled Trigger

import * as pulumi from "@pulumi/pulumi";
import * as aws from "@pulumi/aws";
const example = new aws.glue.Trigger("example", {
    name: "example",
    schedule: "cron(15 12 * * ? *)",
    type: "SCHEDULED",
    actions: [{
        jobName: exampleAwsGlueJob.name,
    }],
});
Content copied to clipboard
import pulumi
import pulumi_aws as aws
example = aws.glue.Trigger("example",
    name="example",
    schedule="cron(15 12 * * ? *)",
    type="SCHEDULED",
    actions=[{
        "job_name": example_aws_glue_job["name"],
    }])
Content copied to clipboard
using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Aws = Pulumi.Aws;
return await Deployment.RunAsync(() =>
{
    var example = new Aws.Glue.Trigger("example", new()
    {
        Name = "example",
        Schedule = "cron(15 12 * * ? *)",
        Type = "SCHEDULED",
        Actions = new[]
        {
            new Aws.Glue.Inputs.TriggerActionArgs
            {
                JobName = exampleAwsGlueJob.Name,
            },
        },
    });
});
Content copied to clipboard
package main
import (
	"github.com/pulumi/pulumi-aws/sdk/v6/go/aws/glue"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := glue.NewTrigger(ctx, "example", &glue.TriggerArgs{
			Name:     pulumi.String("example"),
			Schedule: pulumi.String("cron(15 12 * * ? *)"),
			Type:     pulumi.String("SCHEDULED"),
			Actions: glue.TriggerActionArray{
				&glue.TriggerActionArgs{
					JobName: pulumi.Any(exampleAwsGlueJob.Name),
				},
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}
Content copied to clipboard
package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.aws.glue.Trigger;
import com.pulumi.aws.glue.TriggerArgs;
import com.pulumi.aws.glue.inputs.TriggerActionArgs;
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 Trigger("example", TriggerArgs.builder()
            .name("example")
            .schedule("cron(15 12 * * ? *)")
            .type("SCHEDULED")
            .actions(TriggerActionArgs.builder()
                .jobName(exampleAwsGlueJob.name())
                .build())
            .build());
    }
}
Content copied to clipboard
resources:
  example:
    type: aws:glue:Trigger
    properties:
      name: example
      schedule: cron(15 12 * * ? *)
      type: SCHEDULED
      actions:
        - jobName: ${exampleAwsGlueJob.name}
Content copied to clipboard

Conditional Trigger with Crawler Action

Note: Triggers can have both a crawler action and a crawler condition, just no example provided.

import * as pulumi from "@pulumi/pulumi";
import * as aws from "@pulumi/aws";
const example = new aws.glue.Trigger("example", {
    name: "example",
    type: "CONDITIONAL",
    actions: [{
        crawlerName: example1.name,
    }],
    predicate: {
        conditions: [{
            jobName: example2.name,
            state: "SUCCEEDED",
        }],
    },
});
Content copied to clipboard
import pulumi
import pulumi_aws as aws
example = aws.glue.Trigger("example",
    name="example",
    type="CONDITIONAL",
    actions=[{
        "crawler_name": example1["name"],
    }],
    predicate={
        "conditions": [{
            "job_name": example2["name"],
            "state": "SUCCEEDED",
        }],
    })
Content copied to clipboard
using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Aws = Pulumi.Aws;
return await Deployment.RunAsync(() =>
{
    var example = new Aws.Glue.Trigger("example", new()
    {
        Name = "example",
        Type = "CONDITIONAL",
        Actions = new[]
        {
            new Aws.Glue.Inputs.TriggerActionArgs
            {
                CrawlerName = example1.Name,
            },
        },
        Predicate = new Aws.Glue.Inputs.TriggerPredicateArgs
        {
            Conditions = new[]
            {
                new Aws.Glue.Inputs.TriggerPredicateConditionArgs
                {
                    JobName = example2.Name,
                    State = "SUCCEEDED",
                },
            },
        },
    });
});
Content copied to clipboard
package main
import (
	"github.com/pulumi/pulumi-aws/sdk/v6/go/aws/glue"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := glue.NewTrigger(ctx, "example", &glue.TriggerArgs{
			Name: pulumi.String("example"),
			Type: pulumi.String("CONDITIONAL"),
			Actions: glue.TriggerActionArray{
				&glue.TriggerActionArgs{
					CrawlerName: pulumi.Any(example1.Name),
				},
			},
			Predicate: &glue.TriggerPredicateArgs{
				Conditions: glue.TriggerPredicateConditionArray{
					&glue.TriggerPredicateConditionArgs{
						JobName: pulumi.Any(example2.Name),
						State:   pulumi.String("SUCCEEDED"),
					},
				},
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}
Content copied to clipboard
package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.aws.glue.Trigger;
import com.pulumi.aws.glue.TriggerArgs;
import com.pulumi.aws.glue.inputs.TriggerActionArgs;
import com.pulumi.aws.glue.inputs.TriggerPredicateArgs;
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 Trigger("example", TriggerArgs.builder()
            .name("example")
            .type("CONDITIONAL")
            .actions(TriggerActionArgs.builder()
                .crawlerName(example1.name())
                .build())
            .predicate(TriggerPredicateArgs.builder()
                .conditions(TriggerPredicateConditionArgs.builder()
                    .jobName(example2.name())
                    .state("SUCCEEDED")
                    .build())
                .build())
            .build());
    }
}
Content copied to clipboard
resources:
  example:
    type: aws:glue:Trigger
    properties:
      name: example
      type: CONDITIONAL
      actions:
        - crawlerName: ${example1.name}
      predicate:
        conditions:
          - jobName: ${example2.name}
            state: SUCCEEDED
Content copied to clipboard

Conditional Trigger with Crawler Condition

Note: Triggers can have both a crawler action and a crawler condition, just no example provided.

import * as pulumi from "@pulumi/pulumi";
import * as aws from "@pulumi/aws";
const example = new aws.glue.Trigger("example", {
    name: "example",
    type: "CONDITIONAL",
    actions: [{
        jobName: example1.name,
    }],
    predicate: {
        conditions: [{
            crawlerName: example2.name,
            crawlState: "SUCCEEDED",
        }],
    },
});
Content copied to clipboard
import pulumi
import pulumi_aws as aws
example = aws.glue.Trigger("example",
    name="example",
    type="CONDITIONAL",
    actions=[{
        "job_name": example1["name"],
    }],
    predicate={
        "conditions": [{
            "crawler_name": example2["name"],
            "crawl_state": "SUCCEEDED",
        }],
    })
Content copied to clipboard
using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Aws = Pulumi.Aws;
return await Deployment.RunAsync(() =>
{
    var example = new Aws.Glue.Trigger("example", new()
    {
        Name = "example",
        Type = "CONDITIONAL",
        Actions = new[]
        {
            new Aws.Glue.Inputs.TriggerActionArgs
            {
                JobName = example1.Name,
            },
        },
        Predicate = new Aws.Glue.Inputs.TriggerPredicateArgs
        {
            Conditions = new[]
            {
                new Aws.Glue.Inputs.TriggerPredicateConditionArgs
                {
                    CrawlerName = example2.Name,
                    CrawlState = "SUCCEEDED",
                },
            },
        },
    });
});
Content copied to clipboard
package main
import (
	"github.com/pulumi/pulumi-aws/sdk/v6/go/aws/glue"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := glue.NewTrigger(ctx, "example", &glue.TriggerArgs{
			Name: pulumi.String("example"),
			Type: pulumi.String("CONDITIONAL"),
			Actions: glue.TriggerActionArray{
				&glue.TriggerActionArgs{
					JobName: pulumi.Any(example1.Name),
				},
			},
			Predicate: &glue.TriggerPredicateArgs{
				Conditions: glue.TriggerPredicateConditionArray{
					&glue.TriggerPredicateConditionArgs{
						CrawlerName: pulumi.Any(example2.Name),
						CrawlState:  pulumi.String("SUCCEEDED"),
					},
				},
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}
Content copied to clipboard
package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.aws.glue.Trigger;
import com.pulumi.aws.glue.TriggerArgs;
import com.pulumi.aws.glue.inputs.TriggerActionArgs;
import com.pulumi.aws.glue.inputs.TriggerPredicateArgs;
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 Trigger("example", TriggerArgs.builder()
            .name("example")
            .type("CONDITIONAL")
            .actions(TriggerActionArgs.builder()
                .jobName(example1.name())
                .build())
            .predicate(TriggerPredicateArgs.builder()
                .conditions(TriggerPredicateConditionArgs.builder()
                    .crawlerName(example2.name())
                    .crawlState("SUCCEEDED")
                    .build())
                .build())
            .build());
    }
}
Content copied to clipboard
resources:
  example:
    type: aws:glue:Trigger
    properties:
      name: example
      type: CONDITIONAL
      actions:
        - jobName: ${example1.name}
      predicate:
        conditions:
          - crawlerName: ${example2.name}
            crawlState: SUCCEEDED
Content copied to clipboard

Import

Using pulumi import, import Glue Triggers using name. For example:

$ pulumi import aws:glue/trigger:Trigger MyTrigger MyTrigger
Content copied to clipboard

Properties

Link copied to clipboard
val actions: Output<List<TriggerAction>>

List of actions initiated by this trigger when it fires. See Actions Below.

Link copied to clipboard
val arn: Output<String>

Amazon Resource Name (ARN) of Glue Trigger

Link copied to clipboard
val description: Output<String>?

A description of the new trigger.

Link copied to clipboard
val enabled: Output<Boolean>?

Start the trigger. Defaults to true.

Link copied to clipboard
val eventBatchingConditions: Output<List<TriggerEventBatchingCondition>>?

Batch condition that must be met (specified number of events received or batch time window expired) before EventBridge event trigger fires. See Event Batching Condition.

Link copied to clipboard
val id: Output<String>
Link copied to clipboard
val name: Output<String>

The name of the trigger.

Link copied to clipboard
val predicate: Output<TriggerPredicate>?

A predicate to specify when the new trigger should fire. Required when trigger type is CONDITIONAL. See Predicate Below.

Link copied to clipboard
val pulumiChildResources: Set<KotlinResource>
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
val schedule: Output<String>?

A cron expression used to specify the schedule. Time-Based Schedules for Jobs and Crawlers

Link copied to clipboard
val startOnCreation: Output<Boolean>?

Set to true to start SCHEDULED and CONDITIONAL triggers when created. True is not supported for ON_DEMAND triggers.

Link copied to clipboard
val state: Output<String>

The current state of the trigger.

Link copied to clipboard
val tags: Output<Map<String, String>>?

Key-value map of resource tags. If configured with a provider default_tags configuration block present, tags with matching keys will overwrite those defined at the provider-level.

Link copied to clipboard
val tagsAll: Output<Map<String, String>>

A map of tags assigned to the resource, including those inherited from the provider default_tags configuration block.

Link copied to clipboard
val type: Output<String>

The type of trigger. Valid values are CONDITIONAL, EVENT, ON_DEMAND, and SCHEDULED.

Link copied to clipboard
val urn: Output<String>
Link copied to clipboard
val workflowName: Output<String>?

A workflow to which the trigger should be associated to. Every workflow graph (DAG) needs a starting trigger (ON_DEMAND or SCHEDULED type) and can contain multiple additional CONDITIONAL triggers.