Package software.amazon.awscdk.services.stepfunctions.tasks

Class EventBridgeSchedulerCreateScheduleTask

java.lang.Object
software.amazon.jsii.JsiiObject
software.constructs.Construct
software.amazon.awscdk.services.stepfunctions.State
software.amazon.awscdk.services.stepfunctions.TaskStateBase
software.amazon.awscdk.services.stepfunctions.tasks.EventBridgeSchedulerCreateScheduleTask
All Implemented Interfaces:
IChainable, INextable, software.amazon.jsii.JsiiSerializable, software.constructs.IConstruct, software.constructs.IDependable
@Generated(value="jsii-pacmak/1.106.0 (build e852934)", date="2025-02-12T12:32:12.129Z") @Stability(Stable) public class EventBridgeSchedulerCreateScheduleTask extends TaskStateBase
Create a new AWS EventBridge Scheduler schedule.

Example: 

 import software.amazon.awscdk.services.scheduler.*;
 import software.amazon.awscdk.services.kms.*;
 Key key;
 CfnScheduleGroup scheduleGroup;
 Queue targetQueue;
 Queue deadLetterQueue;
 Role schedulerRole = Role.Builder.create(this, "SchedulerRole")
         .assumedBy(new ServicePrincipal("scheduler.amazonaws.com"))
         .build();
 // To send the message to the queue
 // This policy changes depending on the type of target.
 schedulerRole.addToPrincipalPolicy(PolicyStatement.Builder.create()
         .actions(List.of("sqs:SendMessage"))
         .resources(List.of(targetQueue.getQueueArn()))
         .build());
 EventBridgeSchedulerCreateScheduleTask createScheduleTask1 = EventBridgeSchedulerCreateScheduleTask.Builder.create(this, "createSchedule")
         .scheduleName("TestSchedule")
         .actionAfterCompletion(ActionAfterCompletion.NONE)
         .clientToken("testToken")
         .description("TestDescription")
         .startDate(new Date())
         .endDate(new Date(new Date().getTime() + 1000 * 60 * 60))
         .flexibleTimeWindow(Duration.minutes(5))
         .groupName(scheduleGroup.getRef())
         .kmsKey(key)
         .schedule(Schedule.rate(Duration.minutes(5)))
         .timezone("UTC")
         .enabled(true)
         .target(EventBridgeSchedulerTarget.Builder.create()
                 .arn(targetQueue.getQueueArn())
                 .role(schedulerRole)
                 .retryPolicy(RetryPolicy.builder()
                         .maximumRetryAttempts(2)
                         .maximumEventAge(Duration.minutes(5))
                         .build())
                 .deadLetterQueue(deadLetterQueue)
                 .build())
         .build();

See Also:

  • Constructor Details

    • EventBridgeSchedulerCreateScheduleTask

      protected EventBridgeSchedulerCreateScheduleTask(software.amazon.jsii.JsiiObjectRef objRef)

    • EventBridgeSchedulerCreateScheduleTask

      protected EventBridgeSchedulerCreateScheduleTask(software.amazon.jsii.JsiiObject.InitializationMode initializationMode)

    • EventBridgeSchedulerCreateScheduleTask

      @Stability(Stable) public EventBridgeSchedulerCreateScheduleTask(@NotNull software.constructs.Construct scope, @NotNull String id, @NotNull EventBridgeSchedulerCreateScheduleTaskProps props)
      Parameters:
      scope - This parameter is required.
      id - Descriptive identifier for this chainable. This parameter is required.
      props - This parameter is required.

  • Method Details