Class ProducerStack

python/eventbridge-mesh/single-consumer/app.py:11–42

from constructs import Construct

class ProducerStack(Stack):
    def __init__(self, scope: Construct, id: str, *, 
                app_name: str, 
                consumer_account_id: str, 
                 **kwargs) -> None:
        super().__init__(scope, id, **kwargs)

        # Create the EventBus
        producer_event_bus = events.EventBus(
            self, f"{app_name}-producer-event-bus"
        )

        # Create rule to forward events to consumer account
        rule = events.Rule(
            self, f"{app_name}-forward-to-consumer-rule",
            event_bus=producer_event_bus,
            event_pattern=events.EventPattern(
                source=['com.myapp.events']
            )
        )

        # Add target to forward to consumer account's event bus
        consumer_bus = events.EventBus.from_event_bus_arn(
            self,
            'ConsumerEventBus',
            f"arn:aws:events:{Stack.of(self).region}:{consumer_account_id}:event-bus/default"
        )
        rule.add_target(targets.EventBus(consumer_bus))

        # Optional: Add CloudWatch target for monitoring
        log_group = logs.LogGroup(self, f"{app_name}-producer-logs")
        rule.add_target(targets.CloudWatchLogGroup(log_group))


class ConsumerStack(Stack):