feat(scheduler-targets-alpha): KinesisDataFirehosePutRecord Target

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

@@ -27,6 +27,7 @@ The following targets are supported:
 1. `targets.LambdaInvoke`: [Invoke an AWS Lambda function](#invoke-a-lambda-function))
 2. `targets.StepFunctionsStartExecution`: [Start an AWS Step Function](#start-an-aws-step-function)
 3. `targets.CodeBuildStartBuild`: [Start a CodeBuild job](#start-a-codebuild-job)
+4. `targets.KinesisDataFirehosePutRecord`: [Put a record to a Kinesis Data Firehose](#put-a-record-to-a-kinesis-data-firehose)
 
 ## Invoke a Lambda function
 
@@ -121,3 +122,26 @@ new Schedule(this, 'Schedule', {
   target: new targets.CodeBuildStartBuild(project),
 });
 ```
+
+## Put a record to a Kinesis Data Firehose
+
+Use the `KinesisDataFirehosePutRecord` target to put a record to a Kinesis Data Firehose delivery stream.
+
+The code snippet below creates an event rule with a delivery stream as a target
+called every hour by Event Bridge Scheduler with a custom payload.
+
+```ts
+import * as firehose from 'aws-cdk-lib/aws-kinesisfirehose';
+declare const deliveryStream: firehose.CfnDeliveryStream;
+
+const payload = {
+  Data: "record",
+};
+
+new Schedule(this, 'Schedule', {
+  schedule: ScheduleExpression.rate(Duration.minutes(60)),
+  target: new targets.KinesisDataFirehosePutRecord(deliveryStream, {
+    input: ScheduleTargetInput.fromObject(payload),
+  }),
+});
+```

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

@@ -1,4 +1,5 @@
-export * from './target';
+export * from './codebuild-start-build';
+export * from './kinesis-data-firehose-put-record';
 export * from './lambda-invoke';
 export * from './stepfunctions-start-execution';
-export * from './codebuild-start-build';
+export * from './target';

packages/@aws-cdk/aws-scheduler-targets-alpha/lib/kinesis-data-firehose-put-record.ts

@@ -0,0 +1,37 @@
+import { ISchedule, IScheduleTarget } from '@aws-cdk/aws-scheduler-alpha';
+import { Names } from 'aws-cdk-lib';
+import { IRole, PolicyStatement } from 'aws-cdk-lib/aws-iam';
+import { CfnDeliveryStream } from 'aws-cdk-lib/aws-kinesisfirehose';
+import { ScheduleTargetBase, ScheduleTargetBaseProps } from './target';
+import { sameEnvDimension } from './util';
+
+/**
+ * Use an Amazon Kinesis Data Firehose as a target for AWS EventBridge Scheduler.
+ */
+export class KinesisDataFirehosePutRecord extends ScheduleTargetBase implements IScheduleTarget {
+  constructor(
+    private readonly deliveryStream: CfnDeliveryStream,
+    private readonly props: ScheduleTargetBaseProps = {},
+  ) {
+    super(props, deliveryStream.attrArn);
+  }
+
+  protected addTargetActionToRole(schedule: ISchedule, role: IRole): void {
+    if (!sameEnvDimension(this.deliveryStream.stack.region, schedule.env.region)) {
+      throw new Error(`Cannot assign the Firehose delivery stream in region ${this.deliveryStream.stack.region} to the schedule ${Names.nodeUniqueId(schedule.node)} in region ${schedule.env.region}. Both the schedule and the Firehose delivery stream must be in the same region.`);
+    }
+
+    if (!sameEnvDimension(this.deliveryStream.stack.account, schedule.env.account)) {
+      throw new Error(`Cannot assign the Firehose delivery stream in account ${this.deliveryStream.stack.account} to the schedule ${Names.nodeUniqueId(schedule.node)} in account ${schedule.env.region}. Both the schedule and the Firehose delivery stream must be in the same account.`);
+    }
+
+    if (this.props.role && !sameEnvDimension(this.props.role.env.account, this.deliveryStream.stack.account)) {
+      throw new Error(`Cannot grant permission to execution role in account ${this.props.role.env.account} to invoke target ${Names.nodeUniqueId(this.deliveryStream.node)} in account ${this.deliveryStream.stack.account}. Both the target and the execution role must be in the same account.`);
+    }
+
+    role.addToPrincipalPolicy(new PolicyStatement({
+      actions: ['firehose:PutRecord'],
+      resources: [this.deliveryStream.attrArn],
+    }));
+  }
+}