EventBridgeで実現するクロスリージョンイベントルーティング。バージニア -> 東京へのイベント転送を CDK でやってみた

cloudformation-notification/
  ├── bin/
  │   └── cloudformation-notification.ts    # メイン（TokyoStack & VirginiaStackをインスタンス化）
  ├── lib/
  │   ├── constructs/
  │   │   ├── events/
  │   │   │   └── index.ts                  # EventBridgeルール作成
  │   │   └── slack/
  │   │       └── index.ts                  # SNS + Slack通知設定
  │   ├── tokyo-stack.ts                    # 東京リージョンスタック
  │   └── virginia-stack.ts                 # USリージョンスタック
  ├── test/
  │   └── cloudformation-notification.test.ts
  ...

import * as events from "aws-cdk-lib/aws-events";
import { Construct } from "constructs";

export class EventsConstruct extends Construct {
  public readonly rule: events.Rule;
  constructor(scope: Construct, id: string) {
    super(scope, id);

    // EventBridge ルールを作成
    const rule = new events.Rule(this, "Rule", {
      eventPattern: {
        source: ["aws.cloudformation"],
        detailType: ["CloudFormation Stack Status Change"],
        detail: {
          "status-details": {
            status: [
              "CREATE_FAILED",
              "DELETE_FAILED",
              "IMPORT_ROLLBACK_COMPLETE",
              "IMPORT_ROLLBACK_FAILED",
              "ROLLBACK_COMPLETE",
              "ROLLBACK_FAILED",
              "UPDATE_FAILED",
              "UPDATE_ROLLBACK_COMPLETE",
              "UPDATE_ROLLBACK_FAILED",
            ],
          },
        },
      },
    });
    this.rule = rule;
  }
}

import * as cdk from 'aws-cdk-lib';
import * as sns from 'aws-cdk-lib/aws-sns';
import * as events from 'aws-cdk-lib/aws-events';
import * as targets from 'aws-cdk-lib/aws-events-targets';
import * as chatbot from 'aws-cdk-lib/aws-chatbot';
import { Construct } from 'constructs';

export interface SlackConstructProps {
  rule: events.Rule;
}

export class SlackConstruct extends Construct {
  constructor(scope: Construct, id: string, props: SlackConstructProps) {
    super(scope, id);

    const { rule } = props;

    // SNSトピックの作成
    const topic = new sns.Topic(this, 'Topic');

    // Chatbotの設定
    new chatbot.SlackChannelConfiguration(this, 'SlackChannel', {
      slackChannelConfigurationName: this.node.path.replace(
      /[^a-zA-Z0-9-_]/g,
      '-'
      ),
      slackWorkspaceId: 'TXXXXXXXXX', // ワークスペースIDを指定
      slackChannelId: 'CXXXXXXXXX',   // チャンネルIDを指定
      notificationTopics: [topic],
    });

    /**
     * EventBridge ルールのターゲットとして SNS トピックを設定
     */
    rule.addTarget(new targets.SnsTopic(topic));
  }
}

import * as cdk from 'aws-cdk-lib';
import { Construct } from 'constructs';
import { EventsConstruct } from './constructs/events';
import { SlackConstruct } from './constructs/slack';

export class TokyoStack extends cdk.Stack {
  constructor(scope: Construct, id: string, props?: cdk.StackProps) {
    super(scope, id, {
      ...props,
      env: {
        region: 'ap-northeast-1', // 東京リージョン
      },
    });

    // EventBridge設定
    const eventsConstruct = new EventsConstruct(this, 'Events');

    // Slack通知設定
    new SlackConstruct(this, 'Slack', {
    rule: eventsConstruct.rule,
    });
  }
}

import * as cdk from 'aws-cdk-lib';
import * as events from 'aws-cdk-lib/aws-events';
import * as targets from 'aws-cdk-lib/aws-events-targets';
import { Construct } from 'constructs';
import { EventsConstruct } from './constructs/events';

export class VirginiaStack extends cdk.Stack {
  constructor(scope: Construct, id: string, props?: cdk.StackProps) {
    super(scope, id, {
      ...props,
      env: {
        region: 'us-east-1', // USリージョン
      },
    });

    // EventBridge設定（EventsConstructを使用）
    const eventsConstruct = new EventsConstruct(this, 'Events');

    // 東京リージョンのEventBridgeにイベントを転送
    const tokyoEventBus = events.EventBus.fromEventBusArn(
      this,
      'TokyoEventBus',
      this.formatArn({
        service: 'events',
        resource: 'event-bus',
        resourceName: 'default',
        region: 'ap-northeast-1',
      })
    );

    // VirginiaスタックのEventBridgeルールに、東京リージョンのEventBusをターゲットとして追加
    eventsConstruct.rule.addTarget(
      new targets.EventBus(tokyoEventBus)
    );

    // 動作確認用にS3バケットを作成（意図的に失敗させる）
    // new cdk.aws_s3.Bucket(this, 'TestBucket', {
    //   bucketName: 'aws', // 既に存在するバケット名を指定
    //   removalPolicy: cdk.RemovalPolicy.DESTROY,
    // });
  }
}

#!/usr/bin/env node
import * as cdk from 'aws-cdk-lib';
import { TokyoStack } from '../lib/tokyo-stack';
import { VirginiaStack } from '../lib/virginia-stack';

const app = new cdk.App();

new TokyoStack(app, 'CloudformationNotificationTokyoStack', {
  env: {
    region: 'ap-northeast-1', // 東京リージョン
  },
});

new VirginiaStack(app, 'CloudformationNotificationVirginiaStack', {
  env: {
    region: 'us-east-1', // USリージョン
  },
});

## TokyoStackとVirginiaStackの両方をデプロイ
cdk deploy --all --require-approval never