added multiple-consumer solution in python

Author: jfan9

python/eventbridge-mesh/README.md

@@ -40,6 +40,13 @@ cdk bootstrap aws://222222222222/us-east-1 \
     --cloudformation-execution-policies arn:aws:iam::aws:policy/AdministratorAccess
 ```
 
+3. (Optional: Only do this step, when you deploys multiple consumers solution) In account: `333333333333`, run the below command:
+```
+cdk bootstrap aws://333333333333/us-east-1 \
+    --trust 000000000000 \
+    --cloudformation-execution-policies arn:aws:iam::aws:policy/AdministratorAccess
+```
+
 ### Deploy Single consumer solution:
 1. Run: `cd single-consumer`
 2. Change the values of `producerAccountId` and `consumerAccountId` in `cdk.json`

python/eventbridge-mesh/multiple-consumers/app.py

@@ -0,0 +1,128 @@
+#!/usr/bin/env python3
+from aws_cdk import (
+    aws_events as events,
+    aws_events_targets as targets,
+    aws_logs as logs,
+    aws_iam as iam,
+    App, Stack, Environment
+)
+from constructs import Construct
+
+class ProducerStack(Stack):
+    def __init__(self, scope: Construct, id: str, *, 
+                app_name: str, 
+                consumer_accounts: list[str], 
+                 **kwargs) -> None:
+        super().__init__(scope, id, **kwargs)
+
+        # Create the EventBus
+        producer_event_bus = events.EventBus(
+            self, f"{app_name}-producer-event-bus"
+        )
+
+        # Create rules for each consumer account
+        for index, consumer_account_id in enumerate(consumer_accounts):
+            # Create rule to forward events to consumer account
+            rule = events.Rule(
+                self, 
+                f"{app_name}-forward-to-consumer-{index + 1}-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,
+                f"{app_name}-consumer-{index + 1}-event-bus",
+                f"arn:aws:events:{Stack.of(self).region}:{consumer_account_id}:event-bus/default"
+            )
+            rule.add_target(targets.EventBus(consumer_bus))
+
+
+class ConsumerStack(Stack):
+    def __init__(self, scope: Construct, id: str, *, 
+                app_name: str,
+                consumer_name: str, 
+                producer_account_id: str, 
+                 **kwargs) -> None:
+        super().__init__(scope, id, **kwargs)
+
+        # Create or reference the consumer event bus
+        consumer_event_bus = events.EventBus(
+            self, f"{app_name}-{consumer_name}-event-bus"
+        )
+
+        # Add policy to allow producer account to put events
+        consumer_event_bus.add_to_resource_policy(iam.PolicyStatement(
+            sid="allowProducerAccount",
+            effect=iam.Effect.ALLOW,
+            principals=[iam.AccountPrincipal(producer_account_id)],
+            actions=["events:PutEvents"],
+            resources=[consumer_event_bus.event_bus_arn]
+        ))
+
+        # Create consumer rules
+        consumer_rule = events.Rule(
+            self, 
+            f"{app_name}-{consumer_name}-rule",
+            event_bus=consumer_event_bus,
+            event_pattern=events.EventPattern(
+                source=['com.myapp.events'],
+                detail_type=['specific-event-type']
+            )
+        )
+
+        # Add target (e.g., CloudWatch)
+        log_group = logs.LogGroup(
+            self, f"{app_name}-{consumer_name}-logs"
+        )
+        consumer_rule.add_target(targets.CloudWatchLogGroup(log_group))
+
+
+app = App()
+
+# Get context values
+app_name = app.node.try_get_context("appName")
+region   = app.node.try_get_context("region")
+producer_account_id  = app.node.try_get_context("producerAccountId")
+consumer1_account_id = app.node.try_get_context("consumer1AccountId")
+consumer2_account_id = app.node.try_get_context("consumer2AccountId")
+
+# Create producer stack
+producer_stack = ProducerStack(
+    app, f"{app_name}-producer-stack",
+    app_name=app_name,
+    consumer_accounts=[consumer1_account_id, consumer2_account_id],
+    env=Environment(
+        account=producer_account_id,
+        region=region
+    )
+)
+
+# Create consumer 1 stack
+consumer1_stack = ConsumerStack(
+    app, f"{app_name}-consumer1-stack",
+    app_name=app_name,
+    consumer_name="consumer1",
+    producer_account_id=producer_account_id,
+    env=Environment(
+        account=consumer1_account_id,
+        region=region
+    )
+)
+
+# Create consumer 2 stack
+consumer2_stack = ConsumerStack(
+    app, f"{app_name}-consumer2-stack",
+    app_name=app_name,
+    consumer_name="consumer2",
+    producer_account_id=producer_account_id,
+    env=Environment(
+        account=consumer2_account_id,
+        region=region
+    )
+)
+
+app.synth()

python/eventbridge-mesh/multiple-consumers/cdk.json

@@ -0,0 +1,10 @@
+{
+    "app": "python3 app.py",
+    "context": {
+        "appName": "eventbridge-mesh",
+        "region": "us-east-1",
+        "producerAccountId": "111111111111",
+        "consumer1AccountId": "222222222222",
+        "consumer2AccountId": "333333333333"
+    }
+}

python/eventbridge-mesh/multiple-consumers/requirements.txt

@@ -0,0 +1,2 @@
+aws-cdk-lib==2.186.0
+constructs>=10.0.0,<11.0.0