feature request: Event Bridge Scheduler

[thantos]

Is there an existing issue for this?

• I have searched the existing issues

Feature description

Support Event Bridge Scheduler and CFN Resources for the Scheduler (Schedule, ScheduleGroup).

https://aws.amazon.com/eventbridge/scheduler/

🧑‍💻 Implementation

Extend the Scheduled Rules support to one time schedules and the new API/SDK.

Anything else?

https://aws.amazon.com/eventbridge/scheduler/

[OAFCROB]

For anyone Googling this and wondering how to handle this in a Dockerised local environment. Then the approach we've taken is to encapsulate the scheduler SDK calls in a wrapper service. We then simply fake that service out for the local docker environment. Hope that helps, until the feature has been implemented.

Logic to determine which service to use.

/**
 * Currently localstack does not support AWS's EventBridge Scheduler, meaning we have to fake our wrapper service out for local environment.
 * @see https://github.com/localstack/localstack/issues/7268
 */
const eventService = config.isLocal()
    ? getEventServiceFaker(logger)
    : getEventService(logger, config);

Local fake service

const service = (logger) => ({
    createScheduledEvent: async (event) => {
        logger.info(
            { event },
            'EventServiceFaker called on createScheduledEvent()'
        );
    },
    rescheduleEvent: async (event) => {
        logger.info({ event }, 'EventServiceFaker called on rescheduleEvent()');
    },
});

export default service;

Service example

import {
    SchedulerClient,
    CreateScheduleCommand,
} from '@aws-sdk/client-scheduler';

const service = (logger, config) => ({
    createScheduledEvent: async (event) => {
        logger.info({ event }, 'Attempting to schedule an event');

        try {
            const scheduler = new SchedulerClient({
                region: config.getAwsRegion(),
            });


            await scheduler.send(
                new CreateScheduleCommand({
                    /** 
                     * AWS create schedule command input object
                     * @see https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-scheduler/interfaces/createschedulecommandinput.html 
                     */
                }
            );

            logger.error({ event }, 'Successfully scheduled an event');
        } catch (e) {
            logger.error({ event, error: e }, 'Failed to schedule an event');
        }
    },
    rescheduleEvent: async (event) => {
        logger.info({ event }, 'Attempting to reschedule an event');

        /**
         * TODO: Implement the UpdateScheduleCommand
         * @see https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-scheduler/classes/updateschedulecommand.html
         */
    },
});

export default service;