feat(scheduler-targets): eventBridge putEvents target

packages/@aws-cdk/aws-scheduler-targets-alpha/README.md

@@ -29,6 +29,7 @@ The following targets are supported:
 3. `targets.CodeBuildStartBuild`: [Start a CodeBuild job](#start-a-codebuild-job)
 4. `targets.SqsSendMessage`: [Send a Message to an Amazon SQS Queue](#send-a-message-to-sqs-queue)
 5. `targets.SnsPublish`: [Publish messages to an Amazon SNS topic](#publish-messages-to-an-amazon-sns-topic)
+6. `targets.EventBridgePutEvents`: [Put Events on EventBridge](#send-events-to-an-eventbridge-event-bus)
 
 ## Invoke a Lambda function
 
@@ -178,3 +179,30 @@ new Schedule(this, 'Schedule', {
   target,
 });
 ```
+
+## Send events to an EventBridge event bus
+
+Use the `EventBridgePutEvents` target to send events to an EventBridge event bus.
+
+The code snippet below creates an event rule with an EventBridge event bus as a target
+called every hour by Event Bridge Scheduler with a custom event payload.
+
+```ts
+import * as events from 'aws-cdk-lib/aws-events';
+
+const eventBus = new events.EventBus(this, 'EventBus', {
+  eventBusName: 'DomainEvents',
+});
+
+const eventEntry: targets.EventBridgePutEventsEntry = {
+  eventBus,
+  source: 'PetService',
+  detail: ScheduleTargetInput.fromObject({ Name: 'Fluffy' }),
+  detailType: '🐶',
+};
+
+new Schedule(this, 'Schedule', {
+  schedule: ScheduleExpression.rate(Duration.hours(1)),
+  target: new targets.EventBridgePutEvents(eventEntry, {}),
+});
+```

packages/@aws-cdk/aws-scheduler-targets-alpha/lib/event-bridge-put-events.ts

@@ -0,0 +1,91 @@
+import { IScheduleTarget, ISchedule, ScheduleTargetInput, ScheduleTargetConfig } from '@aws-cdk/aws-scheduler-alpha';
+import { Names } from 'aws-cdk-lib';
+import * as events from 'aws-cdk-lib/aws-events';
+import { IRole } from 'aws-cdk-lib/aws-iam';
+import { ScheduleTargetBase, ScheduleTargetBaseProps } from './target';
+import { sameEnvDimension } from './util';
+
+/**
+ * An entry to be sent to EventBridge
+ *
+ * @see https://docs.aws.amazon.com/eventbridge/latest/APIReference/API_PutEventsRequestEntry.html
+ */
+export interface EventBridgePutEventsEntry {
+  /**
+   * The event body
+   *
+   * Can either be provided as an object or as a JSON-serialized string
+   * @example
+   *
+   * ScheduleTargetInput.fromText('{"instance-id": "i-1234567890abcdef0", "state": "terminated"}');
+   * ScheduleTargetInput.fromObject({ Message: 'Hello from a friendly event :)' });
+   */
+  readonly detail: ScheduleTargetInput;
+
+  /**
+   * Used along with the source field to help identify the fields and values expected in the detail field
+   *
+   * For example, events by CloudTrail have detail type "AWS API Call via CloudTrail"
+   * @see https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-events.html
+   */
+  readonly detailType: string;
+
+  /**
+   * The event bus the entry will be sent to.
+   *
+   */
+  readonly eventBus: events.IEventBus;
+
+  /**
+   * The service or application that caused this event to be generated
+   *
+   * Example value: `com.example.service`
+   *
+   * @see https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-events.html
+   */
+  readonly source: string;
+}
+
+/**
+ * Send an event to an AWS EventBridge by AWS EventBridge Scheduler.
+ */
+export class EventBridgePutEvents extends ScheduleTargetBase implements IScheduleTarget {
+  constructor(
+    private readonly entry: EventBridgePutEventsEntry,
+    private readonly props: ScheduleTargetBaseProps,
+  ) {
+    super(props, entry.eventBus.eventBusArn);
+    if (this.props.input) {
+      throw new Error('ScheduleTargetBaseProps.input is not supported for EventBridgePutEvents. Please use entry.detail instead.');
+    }
+  }
+
+  protected addTargetActionToRole(schedule: ISchedule, role: IRole): void {
+    const eventBus = this.entry.eventBus;
+    const eventBusEnv = eventBus.env;
+    if (!sameEnvDimension(eventBusEnv.region, schedule.env.region)) {
+      throw new Error(`Cannot assign eventBus in region ${eventBusEnv.region} to the schedule ${Names.nodeUniqueId(schedule.node)} in region ${schedule.env.region}. Both the schedule and the eventBus must be in the same region.`);
+    }
+
+    if (!sameEnvDimension(eventBusEnv.account, schedule.env.account)) {
+      throw new Error(`Cannot assign eventBus in account ${eventBusEnv.account} to the schedule ${Names.nodeUniqueId(schedule.node)} in account ${schedule.env.region}. Both the schedule and the eventBus must be in the same account.`);
+    }
+
+    if (this.props.role && !sameEnvDimension(this.props.role.env.account, eventBusEnv.account)) {
+      throw new Error(`Cannot grant permission to execution role in account ${this.props.role.env.account} to invoke target ${Names.nodeUniqueId(eventBus.node)} in account ${eventBusEnv.account}. Both the target and the execution role must be in the same account.`);
+    }
+
+    eventBus.grantPutEventsTo(role);
+  }
+
+  protected bindBaseTargetConfig(_schedule: ISchedule): ScheduleTargetConfig {
+    return {
+      ...super.bindBaseTargetConfig(_schedule),
+      input: this.entry.detail,
+      eventBridgeParameters: {
+        detailType: this.entry.detailType,
+        source: this.entry.source,
+      },
+    };
+  }
+}

packages/@aws-cdk/aws-scheduler-targets-alpha/lib/index.ts

@@ -1,6 +1,7 @@
 export * from './codebuild-start-build';
+export * from './event-bridge-put-events';
+export * from './target';
 export * from './lambda-invoke';
 export * from './sns-publish';
-export * from './sqs-send-message';
 export * from './stepfunctions-start-execution';
-export * from './target';
+export * from './sqs-send-message';

packages/@aws-cdk/aws-scheduler-targets-alpha/lib/target.ts

@@ -97,7 +97,7 @@ export abstract class ScheduleTargetBase {
   /**
    * Create a return a Schedule Target Configuration for the given schedule
    * @param schedule
-   * @returnn
+   * @returns a Schedule Target Configuration
    */
   bind(schedule: ISchedule): ScheduleTargetConfig {
     return this.bindBaseTargetConfig(schedule);