From ab7df8e90fa73ee0f36cd69eed60ce95bf93260c Mon Sep 17 00:00:00 2001 From: Michele Date: Thu, 12 Feb 2026 14:32:06 +0100 Subject: [PATCH 1/2] Initial commit --- eventbridge-pipes-sqs-to-dynamodb/README.md | 79 +++++++ eventbridge-pipes-sqs-to-dynamodb/app.py | 9 + eventbridge-pipes-sqs-to-dynamodb/cdk.json | 3 + .../__init__.py | 0 .../eventbridge_pipes_sqs_to_dynamodb.py | 218 ++++++++++++++++++ .../example-pattern.json | 65 ++++++ .../requirements.txt | 2 + 7 files changed, 376 insertions(+) create mode 100644 eventbridge-pipes-sqs-to-dynamodb/README.md create mode 100644 eventbridge-pipes-sqs-to-dynamodb/app.py create mode 100644 eventbridge-pipes-sqs-to-dynamodb/cdk.json create mode 100644 eventbridge-pipes-sqs-to-dynamodb/eventbridge_pipes_sqs_to_dynamodb/__init__.py create mode 100644 eventbridge-pipes-sqs-to-dynamodb/eventbridge_pipes_sqs_to_dynamodb/eventbridge_pipes_sqs_to_dynamodb.py create mode 100644 eventbridge-pipes-sqs-to-dynamodb/example-pattern.json create mode 100644 eventbridge-pipes-sqs-to-dynamodb/requirements.txt diff --git a/eventbridge-pipes-sqs-to-dynamodb/README.md b/eventbridge-pipes-sqs-to-dynamodb/README.md new file mode 100644 index 0000000000..3a091c9a21 --- /dev/null +++ b/eventbridge-pipes-sqs-to-dynamodb/README.md @@ -0,0 +1,79 @@ +# SQS to DynamoDB using EventBridge Pipes with API Gateway and CDK/Python + +This pattern will send messages from an SQS queue to a DynamoDB table via API Gateway using EventBridge Pipes. + +Learn more about this pattern at Serverless Land Patterns: https://serverlessland.com/patterns/eventbridge-pipes-sqs-to-dynamodb + +Important: this application uses various AWS services and there are costs associated with these services after the Free Tier usage - please see the [AWS Pricing page](https://aws.amazon.com/pricing/) for details. You are responsible for any AWS costs incurred. No warranty is implied in this example. + +## Requirements + +- [Create an AWS account](https://portal.aws.amazon.com/gp/aws/developer/registration/index.html) if you do not already have one and log in. The IAM user that you use must have sufficient permissions to make necessary AWS service calls and manage AWS resources. +- [AWS CLI](https://docs.aws.amazon.com/cli/latest/userguide/install-cliv2.html) installed and configured +- [Git Installed](https://git-scm.com/book/en/v2/Getting-Started-Installing-Git) +- [AWS CDK](https://docs.aws.amazon.com/cdk/latest/guide/cli.html) installed and configured + +## Deployment Instructions + +1. Create a new directory, navigate to that directory in a terminal and clone the GitHub repository: + ```bash + git clone https://github.com/aws-samples/serverless-patterns + ``` +2. Change directory to the pattern directory: + ```bash + cd serverless-patterns/eventbridge-pipes-sqs-to-dynamodb + ``` +3. To manually create a virtualenv on MacOS and Linux: + ```bash + $ python3 -m venv .venv + ``` +4. After the init process completes and the virtualenv is created, you can use the following +step to activate your virtualenv. + ```bash + $ source .venv/bin/activate + ``` +5. If you are a Windows platform, you would activate the virtualenv like this: + ```bash + % .venv\Scripts\activate.bat + ``` +6. Once the virtualenv is activated, you can install the required dependencies. + ```bash + $ pip install -r requirements.txt + ``` +7. To deploy the application: + ```bash + $ cdk deploy + ``` + +## How it works + +This template will create an SQS queue, EventBridge Pipe, API Gateway and a DynamoDB table. + +Messages sent to the SQS queue are polled by EventBridge Pipe. EventBridge Pipe processes the messages and sends them to API Gateway endpoint. API Gateway transforms the message and writes the data to DynamoDB table using direct integration. + +## Testing + +Once this stack is deployed in your AWS account, copy the SQS queue name value from the output. + +Then, send a message to the SQS queue as follows: +```sh + aws sqs send-message \ + --queue-url "https://sqs..amazonaws.com//" \ + --message-body '{"Message": "{\"content\":\"Test message\",\"params\":{\"name\":\"Mario\",\"surname\":\"Rossi\"}}"}' +``` + +When you check the DynamoDB table, you can see the entry with all the attributes parsed by API Gateway. + +## Cleanup + +1. Delete the stack + +```bash + cdk destroy +``` + +--- + +Copyright 2026 Amazon.com, Inc. or its affiliates. All Rights Reserved. + +SPDX-License-Identifier: MIT-0 diff --git a/eventbridge-pipes-sqs-to-dynamodb/app.py b/eventbridge-pipes-sqs-to-dynamodb/app.py new file mode 100644 index 0000000000..6326056260 --- /dev/null +++ b/eventbridge-pipes-sqs-to-dynamodb/app.py @@ -0,0 +1,9 @@ +#!/usr/bin/env python3 +import os +import aws_cdk as cdk +from eventbridge_pipes_sqs_to_dynamodb.eventbridge_pipes_sqs_to_dynamodb import EventbridgePipesSqsToDynamodb + +app = cdk.App() +stack = EventbridgePipesSqsToDynamodb(app, "EventbridgePipesSqsToDynamodb") + +app.synth() \ No newline at end of file diff --git a/eventbridge-pipes-sqs-to-dynamodb/cdk.json b/eventbridge-pipes-sqs-to-dynamodb/cdk.json new file mode 100644 index 0000000000..b4baa10225 --- /dev/null +++ b/eventbridge-pipes-sqs-to-dynamodb/cdk.json @@ -0,0 +1,3 @@ +{ + "app": "python3 app.py" +} diff --git a/eventbridge-pipes-sqs-to-dynamodb/eventbridge_pipes_sqs_to_dynamodb/__init__.py b/eventbridge-pipes-sqs-to-dynamodb/eventbridge_pipes_sqs_to_dynamodb/__init__.py new file mode 100644 index 0000000000..e69de29bb2 diff --git a/eventbridge-pipes-sqs-to-dynamodb/eventbridge_pipes_sqs_to_dynamodb/eventbridge_pipes_sqs_to_dynamodb.py b/eventbridge-pipes-sqs-to-dynamodb/eventbridge_pipes_sqs_to_dynamodb/eventbridge_pipes_sqs_to_dynamodb.py new file mode 100644 index 0000000000..2a4cdcef71 --- /dev/null +++ b/eventbridge-pipes-sqs-to-dynamodb/eventbridge_pipes_sqs_to_dynamodb/eventbridge_pipes_sqs_to_dynamodb.py @@ -0,0 +1,218 @@ +from aws_cdk import ( + Stack, + aws_apigateway as apigateway, + aws_dynamodb as dynamodb, + aws_logs as logs, + aws_pipes as pipes, + aws_sqs as sqs, + aws_iam as iam, + RemovalPolicy, + CfnOutput +) +from constructs import Construct +import aws_cdk as cdk + +class EventbridgePipesSqsToDynamodb(Stack): + + def __init__(self, scope: Construct, construct_id: str, env: cdk.Environment, **kwargs) -> None: + super().__init__(scope, construct_id, env=env, **kwargs) + + # SQS queue for decoupling and buffering events for destination_lambda_b + source_queue = sqs.Queue( + self, "EntryPointToEventbridgePipe", + visibility_timeout=cdk.Duration.seconds(60), + retention_period=cdk.Duration.days(4), + enforce_ssl=True + ) + + # DynamoDB table + self.table = dynamodb.Table( + self, "EventTableNew", + table_name="Audit-Table", + partition_key=dynamodb.Attribute( + name="id", + type=dynamodb.AttributeType.STRING + ), + billing_mode=dynamodb.BillingMode.PAY_PER_REQUEST, + removal_policy=RemovalPolicy.DESTROY, + point_in_time_recovery_specification=dynamodb.PointInTimeRecoverySpecification( + point_in_time_recovery_enabled=True + ) + ) + + # IAM role for API Gateway to access DynamoDB + api_gateway_role = iam.Role( + self, "ApiGatewayDynamoDBRole", + assumed_by=iam.ServicePrincipal("apigateway.amazonaws.com"), + inline_policies={ + "DynamoDBAccess": iam.PolicyDocument( + statements=[ + iam.PolicyStatement( + actions=[ + "dynamodb:PutItem", + "dynamodb:GetItem", + "dynamodb:UpdateItem", + "dynamodb:DeleteItem", + "dynamodb:Query", + "dynamodb:Scan" + ], + resources=[self.table.table_arn] + ) + ] + ) + } + ) + + # CloudWatch Log Group for API Gateway + api_log_group = logs.LogGroup( + self, "ApiGatewayLogGroup", + removal_policy=RemovalPolicy.DESTROY + ) + + stage_name = "test" + + # API Gateway with Resource policy to be invoked only by Eventbridge Pipes + self.api = apigateway.RestApi( + self, "RegionalApi", + rest_api_name="EventBridge-DynamoDB-API", + endpoint_configuration=apigateway.EndpointConfiguration( + types=[apigateway.EndpointType.REGIONAL] + ), + policy=iam.PolicyDocument( + statements=[ + iam.PolicyStatement( + effect=iam.Effect.ALLOW, + principals=[iam.ServicePrincipal("pipes.amazonaws.com")], + actions=["execute-api:Invoke"], + resources=[f"execute-api:/{stage_name}/POST/events"] + ) + ] + ), + deploy_options=apigateway.StageOptions( + stage_name=stage_name, + access_log_destination=apigateway.LogGroupLogDestination(api_log_group), + access_log_format=apigateway.AccessLogFormat.clf(), + logging_level=apigateway.MethodLoggingLevel.INFO, + data_trace_enabled=True + ) + ) + + # API Gateway integration with DynamoDB + dynamodb_integration = apigateway.AwsIntegration( + service="dynamodb", + action="PutItem", + options=apigateway.IntegrationOptions( + credentials_role=api_gateway_role, + request_templates={ + "application/json": f'''#set($inputRoot = $input.path('$')) +#set($body = $util.parseJson($inputRoot.body)) +#set($message = $util.parseJson($body.Message)) +{{ + "TableName": "{self.table.table_name}", + "Item": {{ + "id": {{ + "S": "$context.requestId" + }}, + "createdAt": {{ + "S": "$context.requestTime" + }}, + "name": {{ + "S": "$message.params.name" + }}, + "surname": {{ + "S": "$message.params.surname" + }}, + "content": {{ + "S": "$util.escapeJavaScript($message.content)" + }} + }} +}}''' + }, + integration_responses=[ + apigateway.IntegrationResponse( + status_code="200", + response_templates={ + "application/json": '{"status": "success", "id": "$context.requestId"}' + } + ) + ] + ) + ) + + # API Gateway resource and method with IAM authentication + events_resource = self.api.root.add_resource("events") + events_resource.add_method( + "POST", + dynamodb_integration, + authorization_type=apigateway.AuthorizationType.IAM, + method_responses=[ + apigateway.MethodResponse( + status_code="200", + response_models={ + "application/json": apigateway.Model.EMPTY_MODEL + } + ) + ] + ) + + # IAM role for EventBridge Pipe + pipe_role = iam.Role( + self, "EventBridgePipeRole", + assumed_by=iam.ServicePrincipal("pipes.amazonaws.com").with_conditions({ + "StringEquals": { + "aws:SourceAccount": cdk.Stack.of(self).account, + "aws:SourceArn": f"arn:aws:pipes:{cdk.Stack.of(self).region}:{cdk.Stack.of(self).account}:pipe/EventBridgePipe" + } + }), + inline_policies={ + "SqsPipeSourceAccess": iam.PolicyDocument( + statements=[ + iam.PolicyStatement( + actions=[ + "sqs:ReceiveMessage", + "sqs:DeleteMessage", + "sqs:GetQueueAttributes" + ], + resources=[source_queue.queue_arn] + ) + ] + ), + "ApiGatewayPipeTargetAccess": iam.PolicyDocument( + statements=[ + iam.PolicyStatement( + actions=[ + "execute-api:Invoke", + "execute-api:ManageConnections" + ], + resources=[f"arn:aws:execute-api:{cdk.Stack.of(self).region}:{cdk.Stack.of(self).account}:{self.api.rest_api_id}/{stage_name}/*"] + ) + ] + ) + } + ) + + # EventBridge Pipe: SQS → API Gateway + self.pipe = pipes.CfnPipe( + self, "SqsToApiGatewayPipe", + role_arn=pipe_role.role_arn, + name="EventBridgePipe", + desired_state="RUNNING", + source=source_queue.queue_arn, + source_parameters=pipes.CfnPipe.PipeSourceParametersProperty( + sqs_queue_parameters=pipes.CfnPipe.PipeSourceSqsQueueParametersProperty( + batch_size=1 + ) + ), + target=f"arn:aws:execute-api:{cdk.Stack.of(self).region}:{cdk.Stack.of(self).account}:{self.api.rest_api_id}/{stage_name}/POST/events", + target_parameters=pipes.CfnPipe.PipeTargetParametersProperty( + http_parameters=pipes.CfnPipe.PipeTargetHttpParametersProperty( + header_parameters={ + "Content-Type": "application/json" + } + ) + ) + ) + + # Output + CfnOutput(self, "QueueName", value=source_queue.queue_name) + diff --git a/eventbridge-pipes-sqs-to-dynamodb/example-pattern.json b/eventbridge-pipes-sqs-to-dynamodb/example-pattern.json new file mode 100644 index 0000000000..e5b5adb15b --- /dev/null +++ b/eventbridge-pipes-sqs-to-dynamodb/example-pattern.json @@ -0,0 +1,65 @@ +{ + "title": "SQS to DynamoDB using EventBridge Pipes with API Gateway and CDK Python", + "description": "Pattern that sends messages from SQS queue to DynamoDB table via API Gateway using EventBridge Pipes. Implemented with CDK using Python.", + "language": "Python", + "level": "300", + "framework": "AWS CDK", + "introBox": { + "headline": "How it works", + "text": [ + "Messages sent to the SQS queue are polled by EventBridge Pipe.", + "EventBridge Pipe processes the messages and sends them to API Gateway endpoint.", + "API Gateway transforms the message and writes the data to DynamoDB table using direct integration." + ] + }, + "gitHub": { + "template": { + "repoURL": "https://github.com/aws-samples/serverless-patterns/tree/main/eventbridge-pipes-sqs-to-dynamodb", + "templateURL": "serverless-patterns/eventbridge-pipes-sqs-to-dynamodb", + "projectFolder": "eventbridge-pipes-sqs-to-dynamodb", + "templateFile": "eventbridge-pipes-sqs-to-dynamodb/eventbridge_pipes_sqs_to_dynamodb/eventbridge_pipes_sqs_to_dynamodb.py" + } + }, + "resources": { + "bullets": [ + { + "text": "Amazon Simple Queue Service", + "link": "https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/welcome.html" + }, + { + "text": "EventBridge Pipes Documentation", + "link": "https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-pipes-event-source.html" + }, + { + "text": "Cloudformation API for Pipes", + "link": "https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-resource-pipes-pipe.html" + }, + { + "text": "Pipes Documentation for CDK v2 Python", + "link": "https://docs.aws.amazon.com/cdk/api/v2/python/aws_cdk.aws_pipes/CfnPipe.html" + }, + { + "text": "API Gateway DynamoDB Integration", + "link": "https://docs.aws.amazon.com/apigateway/latest/developerguide/api-gateway-overview-developer-experience.html" + } + ] + }, + "deploy": { + "text": ["cdk deploy"] + }, + "testing": { + "text": ["See the README in the GitHub repo for detailed testing instructions."] + }, + "cleanup": { + "text": ["Delete the stack: cdk destroy."] + }, + "authors": [ + { + "name": "Michele Scarimbolo", + "image": "https://avatars.githubusercontent.com/u/229997073", + "bio": "Technical Account Manager at AWS. Serverless specialist and enthusiast.", + "linkedin": "michele-scarimbolo", + "twitter": "" + } + ] + } diff --git a/eventbridge-pipes-sqs-to-dynamodb/requirements.txt b/eventbridge-pipes-sqs-to-dynamodb/requirements.txt new file mode 100644 index 0000000000..c330735bd0 --- /dev/null +++ b/eventbridge-pipes-sqs-to-dynamodb/requirements.txt @@ -0,0 +1,2 @@ +aws-cdk-lib==2.181.1 +constructs>=10.0.0,<11.0.0 \ No newline at end of file From 86b5fc0fd586762d5201bbd5401cd9070e756de4 Mon Sep 17 00:00:00 2001 From: Michele Date: Sat, 21 Feb 2026 11:57:22 +0100 Subject: [PATCH 2/2] adding architecture diagram, enhancing documentation, fixing CDK --- eventbridge-pipes-sqs-to-dynamodb/README.md | 25 +++++++++++++----- .../architecture.png | Bin 0 -> 29409 bytes .../eventbridge_pipes_sqs_to_dynamodb.py | 4 +-- .../example-pattern.json | 4 +-- 4 files changed, 23 insertions(+), 10 deletions(-) create mode 100644 eventbridge-pipes-sqs-to-dynamodb/architecture.png diff --git a/eventbridge-pipes-sqs-to-dynamodb/README.md b/eventbridge-pipes-sqs-to-dynamodb/README.md index 3a091c9a21..803c29db63 100644 --- a/eventbridge-pipes-sqs-to-dynamodb/README.md +++ b/eventbridge-pipes-sqs-to-dynamodb/README.md @@ -1,8 +1,10 @@ -# SQS to DynamoDB using EventBridge Pipes with API Gateway and CDK/Python +# Amazon SQS to Amazon DynamoDB using Amazon EventBridge Pipes with Amazon API Gateway and CDK/Python This pattern will send messages from an SQS queue to a DynamoDB table via API Gateway using EventBridge Pipes. -Learn more about this pattern at Serverless Land Patterns: https://serverlessland.com/patterns/eventbridge-pipes-sqs-to-dynamodb +![Architecture](./architecture.png) + +Learn more about this pattern at Serverless Land Patterns: [https://serverlessland.com/patterns/eventbridge-pipes-sqs-to-dynamodb](https://serverlessland.com/patterns/eventbridge-pipes-sqs-to-dynamodb) Important: this application uses various AWS services and there are costs associated with these services after the Free Tier usage - please see the [AWS Pricing page](https://aws.amazon.com/pricing/) for details. You are responsible for any AWS costs incurred. No warranty is implied in this example. @@ -55,21 +57,32 @@ Messages sent to the SQS queue are polled by EventBridge Pipe. EventBridge Pipe Once this stack is deployed in your AWS account, copy the SQS queue name value from the output. +Alternatively, retrieve the queue URL using AWS CLI: +```sh +aws sqs list-queues --query 'QueueUrls[?contains(@, `EntryPointToEventbridgePipe`)]' +``` + Then, send a message to the SQS queue as follows: ```sh - aws sqs send-message \ - --queue-url "https://sqs..amazonaws.com//" \ - --message-body '{"Message": "{\"content\":\"Test message\",\"params\":{\"name\":\"Mario\",\"surname\":\"Rossi\"}}"}' +aws sqs send-message \ + --queue-url "" \ + --message-body '{"Message": "{\"content\":\"Test message\",\"params\":{\"name\":\"Mario\",\"surname\":\"Rossi\"}}"}' ``` +Navigate to [AWS Console DynamoDB Tables](https://console.aws.amazon.com/dynamodbv2/home#tables) and check for a table with name `Audit-Table`. When you check the DynamoDB table, you can see the entry with all the attributes parsed by API Gateway. +Alternatively, you can scan the table using AWS CLI: +```sh +aws dynamodb scan --table-name Audit-Table +``` + ## Cleanup 1. Delete the stack ```bash - cdk destroy +cdk destroy ``` --- diff --git a/eventbridge-pipes-sqs-to-dynamodb/architecture.png b/eventbridge-pipes-sqs-to-dynamodb/architecture.png new file mode 100644 index 0000000000000000000000000000000000000000..adece901b3798323e9a3a120d22fe1169c5060c2 GIT binary patch literal 29409 zcmeGEWmJ^i_W%qFjtU|zph!z7-5o=B3IjuTNOzag-96IX-JrCzbR!_$-SA#`|LXRB zKfIsb^{i+8S!)*8oa>x@&faIA-Dd*jWJHml<34}%=n=BGn2^GwM~@>OJ%Y1BcnY)( z#>a#MU(`$l1?9vA1&QQrEDcS}3?4mt7ik~SM_p!cBLjwT>?AWS3wX@mnAq| zJqWi}-Jv^?A#*UKlu5LrGP;?1N^-iOyzD34D}|WYYBHAhc1@|@UK~x#9&c~Dw|?1w z;t9)-(Ll)>DPiK_e5tOY{`@Jy!Ke_;xVGwRtUwV8eIL48=;a$X)zZcjwcMd%hrMzh z_2~)?ESKh)d#?M;kGh8;WLK2tD!tageNG8&ge`wP3Ntr;MdgBz zig691O^V%2Sd2ei?PH>H7x6Z&lq+9%mOVz>@TpZBa{cbIFiRXW|IPUhU&unQI$3;Y z4WKr}Kt0H_HQMHM?0X(>)UOLJNseM?;fS|{`0LmqKE zaRQI#26j3`PUdD7wwz8pB)@xb0?!Z4bR&6Ro9<5gh{u2L~NJBON0n4bX$e*4e^N z$BD+m_U&Il{tZXSz*f)3#LCXZ(t_v#u8yvyy&Vq;$-_kd`TJ{~22Ljboyo%XUuXdc z(mlMPW1yv{`wwhjDEC7vr<{qCff-cD#2g?GFb6LaD?9h^{{MLM-x>dBq{@FsaxgId z@5ujo^XEt1$FNer<88*Dui`h~6Pc z$iO2#1%X~Z!Mc!di;7G6tS=9a2+8QU-7ai2s%mfc`%*WdC!T91DjdQKV(<64DK-^zyca(|f4@2KdITbR z1cv~A1TV<1-Cx30r=!U&Gvzi$D;P=W478&Cw*#6N7zZQaV=ww%`7=xVw+&@G$iYpw zHOXu*1Ro(VM}MVfqb6nhCT(n3k@e&^#J|RR*I-_B`o@p<4oAZu1qilk6cTa$4Jxn# zdU|-vmdm){C;E#*wcgpn)DH{#-%fdGa3FnO+~fj*zqh}70SEe}y@8JNx87c0Uj!l| zscfx#$#1lGiV?ZCe$R}6RrUm*}G zt@KCx3%{=cjFIsghT?2CiP>`%l60GUb=wPQr!k{LyYW74J@eK^itP$P@uJ@CTa|Ktv1UT=PyjJNzo8G}Wi4b!EBGZ3Ya2vgZ4 zbCiat!>nI%bz}dX4<3PL1k)m(j0D9!=fwQ%pgB7=B$SCPKi<@0|h`{hCU(mm;RJH;UCpJAE3DOt%;gemnmPDl44LHd+4J6Hsi0yjx0__OrNmDpX!gyxHb@7;D{!UOxJ_|BNT zaZ`;5|D>C$Xxb8<7$VCX8_I9SZPFyN*A)a32wPJ(6+xzlcC-tV)@IPLa_lL2Rf);A zttoZ+;A~$br2mm9zaKwS49kHjkp^62PKSIlgkZc!;jloSOA{>t**Nhx6}bMzjxrN{ zk&ZM4+u(3R>EpYQ`^_eW2bv!|Df}Wu&>FMEvs>=7Bp<* zF>mMeP#3l&2E6gqCp!H8JYN>%a>fXz6iW18kiN@J$b5X=3;(y3pKy9Nz$+XRj6SiL zffHICR_|5eF2KWx*yQeahzaNZV}lgE!R^FFNwTk6dG+$r6O6|MxG{oN-MS$<)wY5f zx4|&7KOE9}D#=xec2MvU)?s=l@t&RTNkQNk7Hf>@qqchN&>? ztb5T}c0eI-RiaiWp`ogdC~;AIDEsR2#hS9plA>o`_BJg5&fU zYn7C8V47YLzq`%q7o()_6B}xEHyMv|t19{mq28+m3LA_i7H zJN3!(eZ9dd$*!u35pfF95(eYGula**pUMznMfm!c85+DtO5?4-O(J8cCNk{oJ7(H8 z$XqHr?a(e7+)Z-Tk7-wGQ@hCg#%rV`Cy}Z!15eg%<|1s1ak%(w}d5QE-0r?6Jl=c6R?%rD%ui_N( z;SwJ$q5UZkD}d!!*8ltmT8IGQ;e7=EBts9mmskJVC%QkeB?SnNh=%fyeM)`=&zOwV z@((ruj1O`!yU*W6$RlqvfYHooFaE&>0szaX9Qw@pv7njSdQL}_ zyK&{BSPn0na`?%0^NOuN%STr`D(w83$$1Zecys+X&P(#6H-so+I%7|Z|}CzXWZa9a-ftrGuN7jLk@ztGvO#?IzN z%X{a|y}hDsE#{RoAyT|I(~qV3Oig6@KL(v9@ai{wv61gZe6%F4W-&)^X3kiDt5^{9kkMG+X0CLS1N#XY5_xL%(G(um*? zYsMWD+Xk9{(bLV5*Olw>zI#=9`Asow-0=$usoSkHVg2^dZQf;K1PLff>Z{PQz;(a8 zmy*ang{7lf$$&@$ z!S0Q>N)dFLjAVB8Qv~cCfzne%ad)(+-H+%;18<3}jdiW*1KwJi0>v<+ z!eK|@O&b@=2>|G}P}y-}fHM^sa<8gpa1#uC6*-)WMQgRBV_K&{6+U{E$Hs;(2;U7y zNQ=EO=zkbzl*n_EpS+}9D8(5XsWHce+&Nf$YhJesPo1G4L63f)zeVttsBrdd3=dvI zT05^e{HY}T>FzHUf-}|d6MI5ze;QDM5RokV$EgB!uHtav88~974~9;XH29PBgb1dE z$rU+@bjP$ct_4wduWekUyX`x&S08YKdrt7W$4R}siVPb+m?GG*zy)?Ys1PEnE_~ut zAr3{GrNqdiz+>r_Lz)QTHSG-((6ePwa^MIQwM7tr`>iGxw1p@dD1_K$7}QzR@Xo!j z9aMk}W8pWsgB~6h5&&F$I+KDcn6{0mA1E5wkZ!}eE*~dq3#_?_xC%O<5UlKA3Xz$O z3zc<3U`__3FHP-mC&M%w0#F1hrhUZeg1v;25Sh976f=Gt_01+}kFgF>CgI@RFHm@S z?cB2F_&vxNsIJs9gJfNG#j-P`r^rShaltS~n#AVm{rBF=*PGE#L0jk>PnHrUP>B;U zmgDC1Jwrd;dbClWjjk@loo ziX9gyX77pn$hKy;Lu!YCS!c`9h$wtDK1l81EVmG$_}8UahaqH)%8I6EFK z#$J9_W$Io z4dYUkLBJFyzo+b;?3lM8meir*al1lv161#IH4tkVcx7#a73XGeT7tIR4kx05B zLAG*Mq7+ew)}S)KhK>iMe?3)8V`Se_$=R@Fr|Lh(ndj_VbzBqL{@%Tw9d);lGGC@; z6&?QYi8mbD@M(;uDCeL{0E5@BHzMCFd09iId>&cjccw4!oL&s(HW~&^lD|wPZ3qB2 zVdMuDD{G2@H|_D19PNFxJjr^d80ZVGSVp8z<4=F6Gx?8M9G!?s#&LXM!DudLYGNzk zrwKxfDEnZA~MqU^``JBCOiQ^$v_4;%u;Oc z(TdA>b26$t!|?369+W|?_P3+LN|=L{G`pd_9}@X2y$TQUcf4Z13j{fTuab2;CqpIz zud(lpDH4Q1Jxr4QtP;7?>z!{4@pPk<)(qEWU7DpI73$rdNz+7~3ff}BMMrY1mx9WF?WH(FqbC?1P!sxJ|=!U(DW zeV`%?*jV^3!PnB-3&=AarLdxBOq9pkqS(xhMOlCd2eiLCh_nXMV7yd=@LgqtrI1HK zex}GyJl7WBDXv_aBuxy=@bXxZ_UQ`FuhK)@6#T2j>BZJYtV1?Y(VzviJoMpee62;! z9}>Z86V1_Nx~5Oe+QXdmW8W9G07^sDULJk6jc1ExLB&a(l3nLX4V7l&Aj3$MQ28i1i-=zN? znt9~{j}gHZ?oze5l|@ck{U{WqNqv;0(FRc=RO({a5HhJ$D`pxI1UrauF;~CbV()^f z+PiUybE_H{pa*iT28g|FuX*9k9jxYN9xF~qXBPK_u4U+Gxw_9Y&&R%TOZ2yQ?c(hf zC^o<+1@lSZ#fWC@Q2L}mVp~RwoimVfosh#dWrNYmgm{1(K4=!tA4^%oU4RK2Kg3sj zDji~GP#IQN(?nMh=tUJ3Q}U)UuBewYu1<=^+M%VNRWig75x}X2vuGT@P_Ixt`VNe^ z!4qBXdiDjeT1ivQ+G3B)zp*|Zcde?EKW!ADMq8M zmt(mPXv#gKrK)3-t2MqU^Ay^N?r$SIa~B9bgXYO_vDABG4h>FK&sDn@g|a|a6sl6i zO=eutUM23pihMZ32=fv=r_GZ}mS;~@S&P$O(2+O9_lrwyjlPgKH>vRb3P#M@PsDQ_ z@~_TPwHZX3sE@~k^nJ!hup@!P)R>W=A7reMWlwUF>NC5mf!(+*(oat<3KiUx@pkD? z(MbR~m>5MIpASY1dt-+7E?m{P5D1m$%;D~s&4-df;xto=YE3pldi%`Na$8m3sNb<@ zV9K6?S8CYOa+ExnAvHA7qGn_TD7Fni)Y|lzW zkoBZ#QerI-C>PN|x`k;_;?YmppBQu~Ia=Xz)KXY7!FS9ykMs31nK}5FK?&l# z%qeO~l5^?1an9k+;ISX!#ktn=N6SA^y%WGxrLVK``HBLMcgJq2sq}N>Vr}>VBR&rU zuJYB)#8!zOB9EFo3y_r5mL|QzeJ`{1)v9oEV{S#|` zS@hQt0nP!d;tJjZv&ZFztgZ;=Os^tE7yuKOrYm1huoHi^sFN2LOTArq{F_O@E9`WIZ`T#0gBFKB_}31 zrrD?EVjRUS&kGwmPiZhx>0!cN#6_@if@}#UmF-MTXKfkSZuUN3{d>XtG5%NsroFGI z9h|sGGj$~pLm(;*b_Ym$<;MOH@=L=9DZr7T=U;}E$Cf3o28}8$7~b~JvNBm_`#PDi z{y59^e^PO4PX8051D*z3O&C*gU7?LuM)dlshtEA%Gt-U?Z=fL258wDwQ6$?mwFt#J z38x#Fg3$Y$z^%rU$kJER}{zE-aO^{4=^o5Z5cXqz}|hvtaG1GM&Aix8Zi8c-BI1Y)UobpsmP< z#-F#)H}7z5QBN%e1G^tQ3Ae7W%i(cXNB#Q*Jf&E0?wnxxDMQVPNnU=SsOeiSO{;xg z!Uv1LrY;O0Fb_?!2gdk#;*6P>rrr%OTe#o_i^5F(SeOPrube#?fZ?}ZHms7V)QATD z32O%LB6GsCX}%f81!dsNbk?GnQi}}G(d}p4L23*q8jTlx-f+V~2~Q)vs!#=N4%Cko z0RN9MoIM=kc=13b8I15Xv~ZD6<^PKFOFUHF)v8&KKvODewANHenV1)A%!>s6mVe(9l7=yVZ~JGAHBj?S5vqVnH@ z1$DFY6*@8`71qRwQnoB?j8)o{5M#}3f{4@OrXN}^@!Esfig^Q>Z3$nZ5Vn4{@fSq?jg0 z=It#Sm^f=nPdvgy6+cZ!KVh(gRbwYUUtlLSf6j9E`j}3Lu)1n9d#Iw2 zA@s%QMQ9k!K6@&=47Gz&EA=;1lXqX**0Ysz7OY=SS<-no<+fVqHwcSu&6ss}6BHO1 zUK90g^7b~gR(m00ILgg#K?~=4Ws0;lCaEDX!Yh1tu$|2^WqWu! z72>K_wwjN_SG_!m#5HUyJY$(=;wZqakqg^uI3?&^hC;ZzY)SN}^dK`Bk(onDBSV>Z z*fOTUH?J&s-bcd}QY2#aE?46nsY;tF-mqDyx4X=GM$`=45sp}WNPhMn zJwF^YC)avhPVAHND4-jU9_v5^>|p#B)le*FS>okKQ{5s>7BUi+mo-==#;^55V_t>y zsbxhI_y?}A7W653*7b(obsdF%vThMXs5(MzlE+%{e-qkPbKSJ(opC;=-RCkY&BjrU zRKkVOaXw7F7ZFBX1=9H<{Ns6%BVSTqGNH+OwUP@)7;MAB<6zQaJKu4?BSSvt1^gjT zRn08rTOnsUL^1c}rBru;5uh;e&2xs=>sodfA1MjQ+>|ucSrF{jNRZ~%Hxl;@{b|a)X0eX1w8B74z=s#C_BoK2RuRThErC%YnrMK@= zm7YC-9n(9RvZ~YVJX=*1q^#()mL2Hn2ncEie%D0da!q+Ga(m}?z7I&goV~?1Py?}J z<%Nob-p=LP0AU6c%x>hs@yi+QTjV((Bo7q|P_C*txODH`)`@?yj^GSRY#;6fkD@cq zKzGS)(RIEt?q|eYR+BTUl5a7&AFWTfk~6S>o)Ea4d~)+<9m6BrU@jW-(d0p&Ha<+L z+kq~Zf1wXuK^ec32sYo8Y0&RZ?+tUqfbYh$4dJ@l$i!USX+I&ry)SGve1_*^Nlhxv z-Ss^&b{LdBnAkZ~gRM!zG?cA#+_rl8mf*NYv5ydLI(-*EnAra1Y2fXMu9}g;ond+Z z^Hc{`J*wa}G}hT{gJG-bx*|@?cf)XB{ z6S2}+_LvfJ4aY-!yj06mkH#Z&`)09LcJGYka{P0-LshBgP!S=SpxD+)B5baW1FKkC-0O2rvG5^Im=fH)7hBw)$5mGuObQtHiFmn!dzKqiZ9eohj= zLp^79@7l2gn@r!eJe?H`Q70Zw08`8fhDt)IeFDW0yHswl%6TdMn=U$SC={^(U#Mrt z$F)Z&$uA}j8bgj9d*~5aL(S+m-fOTK`#!l-XVw*PY48_v466$#Bdh5@=Le0j8BOqV zO|W9eSGdifDX+rTV+_Bj3+$R zSCupn;%d*1{YqIe!Z|HBdu&u8Unwos9Ushl@y7hmh2cIaGnhM5?rxxiYw@L8ORj_yWH^6OpI?5#g+Vq`CKitzB&sCMfpg53#-7+B-^SQrjH>u;ERE>eC`c|(&* zvMjIDzY3+_<(^%53xrFTSy}qhsH32Q2SJbl>QLt;y+d--P$-zD35vVRzA#ho9kftq z_Bmfqo&3!I%U8<6q7jz;7ghemg0g{l#1XP-z5DarX4B^|zj9vJAs;tziZ>Vz-sRCK zqRc1r>|ksZVFqHH;5sKh?1TYIS8AybeLCoec@^Cz9joS$*W$UA4^Bg)`&OLHa<5Pp zGJf$J;uZZb)xvR!P0Ys~X@SjEk7@6}_4|g53JMuA>*6?lznTi9ZT_-@yVp^nK#ri8 z`1N$%LveNM!#NNN|3O{|3lud!{jQppgSAXe(1MH9BeKlEQ)(!_NHwh|Eo^Ut@M7q& zyAcVYLx8sWIre*xIH#E5QOf)+mF`U(aarpVdADTDd?$?hQ;6Y!Bo}RJZO)aijXpuF6&R=r_1t)=G;Ruj z3ef3Jb9}lxbhXVO$onulZ}KH&2=m%1Svij5@PI-RPD`X`W$*Yq!a?Qaui(ARkC>Tf zfcuq;p<>;MHUEOCKjJdcalv^$C)r|auW`R6?&ac9%g;|ps!<+vq#p%Ul;WqJ=jmZa zk&_!-n&vRUnOttM)5=m3#5#TfvzSe> z+G6dAOaV1UennW9ZZ&w!W8X{hg7K6xidTmy0;BBu-Rb^`-Zj24gaiG@0Esv!nlYg_ zu$Jz5m+j*EC&QOUU!1!%fMxEb`xDq`-5tf-woh=CUn~bV8l}2V%-i(QSd@2SBk|uK zr{0epeet}zH2rbD=;;Z-Sg*&FVgI&UGi$+ePr29eNseUD&)X0goux3f=DBIc5Osos zdW>F@Bfu+FG?s|syOQilXyYy8>Bbxglk>-WS-OZO=kCd5^N$@@mCa4IY_%u$T(h5>h=<>U2%LU;tI999pKGw4j(wO6 z({ei$c03+nYn0CvdD413#J31@S`Mr}7IxHh-DNrd`5D#kC-7Q}Mm6OeLy}tl_`Xl; zZkbdaN8RdMl9rMq;BDQNA4IW_ijv4K_k)tGgKn|sX5Fr9pg>t{{wlr92NLEQB10&_ ziu!WJM=flHdiDW!?(1er!0FdmsL2O!`wD}X>%%{OF?5V*Z2JD*BN*X@K7n;`kOKQO zWd2RDM6FdP0#GUSBIv7z<2=@KI3CA{G!x)cUK}h{58>JNFV!r#nATpdCHvD8dR#1d z9aSuqO42pk^|WKuuYYlEE1`}WmEkgD2KiI}DmaeG7a;kHb6l;-;$D zoo7|5x;EE*yIUQB2(D`y%?g%`f$xq(A3wJb%C;V=dYXoUuSKO;&C!Awp_IKirh?S( zZ0O-iw}10$ycTc#cfR|}AuEfuL?e{h2NtpboN)_(e1`<;!Eet9@djbmU9V*X_H9$I zQ`Bq+SOnPvl{z2HUiO+MWfdJ?E9!F2+mq4Bk(;qx-qkRkv#FUwzPm%z+SNFu(aYJv9boy zViOMDPq3}%nokr`q(pad&@~KWV-m(h+eU=4Ysv#m73-ZYKH@=4Iwm?V@UGE%NWP*? zP*ZAbP@tO#LJhtJ3mdR0b#J9H*6KQGvX!S50sI)@X!&AoDN;yp$LyWyPB$-zXc!-4 z(RA1)Cx=*0O+l6JSKez5eARKCHLvwGpFkT;wrI$A*gKuna;zW$*s%JWY+M)A2sTbr zH7u|+<&(8~8z}46=6+V0ij2*V$c4xU6vJw8{M7%Y^E(5Cp|3lBLQH zlek52XJ#x9^HZ(Z2SpJ{&KB&=8F3{RV4oZib5M;^w$)DGKv2)lRfUUNfg7CT)G8RP zP6dgpX2!qLKvK67ZN*`Dyepa4^%nj)xiCEtstN_^TURb61DqS}dUv@lXrj;Iwo~4n z((yCV=*#PymdgRl2~ZNE7_xZiyz725j!@D~oVv|-ZQ`b@twI=eVAANjL-Hkx^P@hx zXXv@N*>S28$wUkKzD>WPBOF(WVnaJ1aY)c~^22cW-Afw+x-;>QSA%@VccVlh(=K1;D15#Iw&4$`K> zRy+;(gV4*kd_jmyz87AIQ;2_S+Y%&R2n%c8OWR;FR){Z=jNb& zY1l7*3y9HDhIObndC8>ILP@diuC_}j$q|OjR$3iqOmZXqgo*-1VbPrmByx}*Q9^fS zP<#N8&F&7v-=0vjZ2nnV`aXB3G3;#CvNef4_TH>=ASX20c95gJCc2fhiy4na;~*!| zK*qlmMUk5lR#YE5Kuu+0&kLlV)@$YSF$x|Vw}XpUCO1hKcW(+lhkOQeA#7-tU+3aq z;s9p7hlSt9fa}J~`<$2W33Z6%V!qBvqVyrpB-yq%d-V@7)zWJ?ECY%Sg)FWvSeZX| z-ELGG2g0wR7s_%KNUz4hf*lAkmz0I@+mgRz=~h5GNvJFyhSJMd6EL$apzmHq zT!rD1)cA_48Cz%&67K#hQnamnOJC4pl|iQsWE6Y`pu|cX;+{xULtM7Dn6DPd=&njb zs&wxi(A^ZP!xc-h`jG}e$Mh1#d82@CCkeiD{OSFyp&f;*NN(J0d_sj(Rj87H zwsEIo4Xfxgrx?y=c~iWaMZKyDW^&S~@kHC=?Ve-x@!=;EY zKSsf=B6V`-QK8mtfsA8Tv`S1cjZ1mNSiPYdSzmxCvNOw4UPT9O;m)D+nd?L1_t~s6 ztl4QViqm)NCcAxfM#H{CuTjnG#vVE6T-a^j4mVwKF5m4eA`faXki=K)#x>74TXYpY zIE>B?SZ}sWrk(Xb-Vx!_#>#rld+b- z$|+gr4Fq9%~)TolHZwItJ$pRV2bjy~q9yqLMT1%*oL1I@ts z-2=`zqQ7$~a(UVAf&|f)dq`zSiVh=jenp~^!u4|sICeCn%U_+fmywjB%};DzYMGcM zqXgrN)d!5iKrY8PRa~1WJ?T{h!5Wk>Sp%Wa^@c0m-JLU3ymDK{1#QCtUY7S#KS4RqCCm2p_W17I z^*(BDwZO-ns({dXVH^$S9gl-=&l2GkK1m;wtS&bVP`(cCoz!%t@ks^{Z4WA0(q4|o zzT#L+F>=*7u5jU0-HSGveWTkQDo-{cD#2 zVfphVe?q^s3ihOEvJXh}J>oYe)^F+oh0krqLU;(+V{TKE@qrwx*S>Ua>1&qQKQ2y* zTz38El$14A&!&x1lTPLKbH?yQn?2gsgj)d1Vo7C5y5pnP;D}6dF)OKZyJ6$N_lDeX z=(!Yk&Z$_jPkEhGJIb#qpA6`mXHieBUE;rHB@Q*Kb@xt6!Iq|6(q(dsBDY9UVn2wg z;~&+vQ+WqF;T2#LrEHTEvR<)!bL}@V z2@NLosn97kqX^0rrUELi#G-l}VoOz2CO{LU8LK0MG}-fgCePQ@tQ;59+?qQ$v)Hdt z(_z}+TOUMY{F?HVpl2nVkGIJ|5E}^Q<2y`!+ikhtBQAo9>Y*26R`?_tFxEJ2sV_t* z!?v-F1df87ySdz%*X0N?9R^DLN0hF9Cx3I5E?F9Hve>FXWndJV{hC$7c0oP3TzB`Q zqBjHYia0Yit(3A&m&;!}M?3{m`9yuohLd@No#zAE$CPih&W$Mb{WGMXQYTy^GS~*w z=mhXeZ?#Ei@kgcu+5;)RY)oi*-V!|@;yIr~b1Q8=drq>uQ#pi!Ehec4?1*E9)mC#b zj)tAQc|!gwZ1BTaP*DZ51oZiTP^%#@1C?NALV5m!g~z$F zGndT7`7#B(<{xVE5 z$qOu47qnV{u2mQCm*k+BS#FGO`% zI+Rk!Xqpb%mRJb#Tf?+GE?24d!_F$}!zt(y*TqDKSrciwW_k?iFW{aa|s5sLOk zZ@@5VGfKi)LNKF{_tyyYVU|)?en<_q(enH4IqjR6T#($nw=mJ&T;ttW`?u{X=c#zF;=Y0K$wZcZQhL zz@&cuV)y6%9S`r;mfmsbYu!wuM`A)7s-%U|I+OE2@}xz z8f0e22x3;9f)KJU;M$@mHTKGFQdNiU_=+J`Y952lz$xeyfp$Cm>#w387<}w$T1~S<|1RQ>_rnt9e9@5j~ zoJO9drery?D+RBF79G$v*mUMnt%wn*YQR#nm6$dLftN19*JYGtF5otNZ?I8dtT;;i zP~|p;3uLL`;hiC3h>huJ*3e^m^YmicucGK`V%kKyN7Jt4Rb@htWpRJ7TRC*#al-|c zC5!T?Vn$+Etm!i3TaiyC-F`&v8(mYMDUWTh>DAJm=+(J1D-;DPGMZU)yMS;84th_e zK#eL`BCD(2$XCk1#J)vijQOQKiFcc>&HA8V&iDt>)Yy3}T^YUgYGu0ko}v))Whrh| z7}=K8)aE$BnpFSv#LaO{oZn#gwe!+yxK)v8Zqj;%Crjb?PpS{KtQ+jWrB{i%Y@}&p zZy1C&FM5rFzL=n5*81SRoC&;ehyJFJKRtYgHG)pG5;+`Z)QrT>froOEwLqTZT64n; zG9Kv=U2|&05`k~%5m+D13V`jiqkx0nD)3MCKCwT-9t48D>!+h73X_=8XSfj#G17%u z67Oaj-=K%?8b3Lr761zjcBHf=r&ZlL72a0R%FOzh?kKbJv?==o<{78Cv^4P}Z(4F9 z(-pbqiMLpVZC%6Tv@K4YX&dDUV=3(pty{V~38+n8W}Y0JX(sOkaL~n`7^t5xVv7ms zN`>8eKV0_p!L@#=9?EO0u*vy(O0&G<{20fL& zIuDenvdGUmA>+EKCiC6if1SCO!w zlov;Y;ER-<-wXBgDvEF}J?+7W7e4OAZRjm16y8Mt*Hu_Kd_X2`Rk5%DcfDMEzze24 zBTA~zK4=8W19!3!F#dHXdpH^Ns%<8DSE3l;b^?mDNtddTaw{3C%_!EtYK_xefe2z_ z?e04cK;h`XLy@+ak-D}0+E@!;Wc~ZTBG~95#B10nNBKYtWJI7C|nEbExT91_+jb{Q{~PV4)SL*%eWm^1$4$WuDNBRQ}HbB%GG+Ochl#>574)BB!dj5Yy<^P|{Z>*vP zj4D6Zi^%Tz#rwNY*9YyWZzh&^9T%+6`7Q#0pqD4hi|ZevgpD{_S4Lu5OMG`1D}L6% zPjx)(+&F34ePH+fRSe*dpBEx}{gyfJz}iCI^dJ*rZ{@qw0yW$D0YMa;yB(?8jd+}o zIu@|lDxsh0{`d4ZP_^$l$!F0P@jqr87#jC}<|ODoKSr6Q^0=pP?3%`@GfH)BSt~tw zQ&bzr_3NkmJVkC|&RQvKQNy{KYx%mn(er+NKIvZFc5tty@}6LCd%H;fxNu8GskFJz z!!?#`&7Wez{A^T~W3afYt-`*Y`8bQS@ZRkbi|tq{)q3>GRCUi-tE)>>gK%>vO8xK(6ub@W&Ew?~5_g zA@04@%l;6H%~IN>vuRspwrjIg$Nkp(7B!d4>UoHo*-ne=PhRQXX0E8qgnduy%gn>k-x3ijSPVM<#)6K%jR7a&a{1kUdljEme^%nZc6yntTyM52S zAKiCb9=4r?^X9dSK*(_`iYQ5OZ!;&k#K2&4%!jV|<~)7iba;DBt-G#6OfbcvMd`@2a;EwjT=2Q#`g)uV)uwclW2$&fW4n z=V>Kou>0HndmkjLWcfve+3*`N_EY)NL)3z%xGHC$N>$75_6r7}qX;;+UxaDe^itDvOZ4_9Mf#}q@_VDkm2e*Q1^$4Ku0QAok6@oTs@}|P6_#wU&Y8JV z>?z?yC^et$s7`IGWzIkEqtWxnZ=AP1$DcRi-YXbMZLPuc-C+ zg`)w%1&CtRt)Ntfx~rM(c?V1`dy~f-GpW{H;;1g9*sbN`8${fwTo+nLs`}< zdOT(^PGg@#M`bu`4D;t~jzi~}hVBN6FHdRatSM5~L@u`{M4ojVK2$T!sSVZ93(Kusms_}qD5oYR5|?VxLy!-hRtbHd>p`P%Yx9;kzLbev(zWq?Cx?6 zxf{}w*>aA5z7joTb3S(sF1s?Xz9hHUreO<=-mNXY471rB=H!uIuq>UQ+jX4VUAR1N zozLZC5zNbMqYSrWkLWlfezv<((!BTdJbCf6|7LL}yLa;VW;`4FJeAB%)aqDU-1NL!xhj+ebON!&8nveg zuH|T4vk%|UbnadBtcX~2ycgX2aOa|7u(~?`rEyj$Kxb=RPZR*6{%M* zoJamV@ZiO$?0(BdC&#?xy<4Xmg#1G08~ynJ?EI)bvITn$P3z!Ta_-yWbl)wIO|n(K zlt-q(bIiIPdok*NVxPJpe#11xyB~LEUNI8%wpg`#SL;oT)V~-Y?-g-iFrtEQS`}47Zs#+fRV1dadt< z=uldp3|%kAXS*eBopcLE-k;s@wGE#Y-d%WlbhLBHpk||-y~S@~-k*CSF+D@%c|al} z^OlY|q_pLxayTa1uM8YYz=E{vo;itaj9Enzc7O98SWg}_U_+LG~VBqzNwt_w)l40`ZDK! zr>u{6$;D+CIDN5q=PLJtS9CwzG59u$95pECz3<{o{y*)VXIK+!x3I+uB1A>NLJ`5T zg#aQgv>;VQ0;u#RB2pqm=`~TLh;*e$ml|qlhS0O62qGOq=%EHe3(^9lecA7I&U@Z( zpWo--o_{mfHEZTsGxMx=&w6CPpTO3((MKp0SyR6asa{?Qx^j>Q6yLf3X{0XRDU+X{jgB-d$d68Xn2q4SCGH^Dk4Z9v(ffu8QZXx3ctkC6!^XG#Pc-kDf?LP zIX5>hX&Y<6w${K7Qpe4V z#TXT0$lJy#yv=|&bB>>Q8lM^VpaXJETX0^ghpJ8aNU1cbXKW^eesczCD#;xWhylHftzN~HQ?)!e9I^+SUV2=G)$Kwkntim*+!#QM zlRtRD*dx?oz`xJ(rHa(EgKm8hbd74XLQ^ zlZWmHJ+5OOzOc2BqS`emnSh?|=?ChXVL5e$f`ZBWw9=&Tm1}o4iD|G?@~mWj)P&tq zlV%g|{nk00qnA!HhLfgZ2)NDqzU-NlfA7kCmXEVE__E*zP!jRVm zCcl#{w&Ad_X>pi?;Ebmq?V#^X%SFu?n#+$p*L9>lRpaQ$@F5U_epsGT*ufVLj=D@t zxsXEIWSV7FEY}-n51~|%UXT49(=+%wB8l&fzqEtKJ%Nvk);#qFp1|%q)Y25A8iF^c z&q2FAE1P_-k5#4~1lInUtYJ~*G78V7zJ!1SO-dPo^d7W3Z9MkjCqneRTgid7JBc@Q zQTd*V{9zXUy-hpwAT)Vo4!YD;g5qLq8?0TWD385AWsJpar9K5%$-bhZ8pr^Ej~tUm z%d!>_@-!1rWglVw5~%LugQt0^3eE_}(KdCF#|Mf|dHIi`DQw~97ZAdDGUE1(I{eoK zGCQ-OywNLGxPp9mYykBAOS)U!bT1ql9hg>rTz#&_J2a6+?6sY<4&259i z8{O42GCU(wuc3YC6`mfasl;$Z0?{iW(Fz2S7bK}sj%J>-<8$j6LJ@DPrF?J}!s6~d zyM;aQ=H|>2?2Cn>6yN(S#B)KKXXy@IrP$&kVfM5gE!t?iT9ELYb1BKjZk?k!*Gx|n zAC{Hn@co8at@V#JVOnXRjWlEvQTn|P^#@F_tXY0gXTRC{$>ljZLmS3Sl=b(2KX8O>wkV26bnT-L$A`Qe z@!?-r>J2AQ6)T4+QR}Ifi=lme)n(Q`x1on)&iEh=P}2#ibjtub5W2WG^5ZNe9IOP| zC#4Red2OF~0}n+$h&+l9Xxm5;N3BKXet^F#vH;Dmno)0WV{L+fdF4{d<@?jY{4^jT z*%p4C#{HpuZVVQJC_F#@;0><HqdEjAgR z`EV4x5CATub02UA?CTo`d2&s^!8eI?7dfVzicjw=lR0(;5gk)P!Cfl(a)T!N^JHF-zv}3n9WoFkr5JH1ne21yFBQb-9 zDQ=g2EER(mg;87`%{+LiS~{MDnM8?#k1Ku4om)k;r!y25kWi6ds)wUIvyF@^_BWfC ztT#*G!q)cg+I|Irk&_Db1vo(5HUOeAmJqXXt`2XD5Zxb>vsysdP|^k~m_ZFM6HIxn zaO5(h39`^Qfx$m0Pk`@a&Nd1U$bSc?vs3phb1J;)%l^ZN5Y+V`+WQQP$9uwdei!N_ z*D*QWu(5eWkj%omZsG7@>k7Z+CESR+!%FGqVQhtezGZ%Xz)1zW7FIFik|MBnd5i6o zrrE^Knc1*3Hx3U~`Q4pYcO|N(Asb0n;loFWM(Ob9Y@d(J!Ju-z~}C!>)x_ zbjcJUYcHerJ_`$y0y$5Kck(bE(7-mn15>23cz6Hc%gP9&{hPmnG)?3reh_2!!CTS- zUUt~?i6GU1bh4gDgYrfrzOlumRYOiox3@I1k2?F@4`Sflr$!HvK0eEbH4Et~klod? z%;IV^-fQD&whbr?2PVZOPX~~({18$^V|v(aD{8o2%V#;R@ZF4#3Iu@;Xt;|wyi1{r za(hm^LYuQ&qRUNe1AHdk^(&k@pXZwvI(6nLq zbT`9m8$$=urOcmwi+c;=dY@?N`~4sT=f?s^xDBf08o$MFw|uod3yjJ?a3m-%yp;|y zOv;l$o;zz|T2@#``eEw>1|6&!hP}Z|3gt*BxRW*)M(3csJ>qZ#S~!OK*!2z{FfYHx z+Br1dZW#wuuyXi5QG*NA1@$n8neX_RgI@XBInUF%xkf6CLFU{`+pRF1TS-~foEG+v zmeY}!)g+O#b+MBQk~GAvGJbktQUkqTr!H1)jcI!oOQi?Duu#-ViWo9blRv{5utI8H zbri>5HCF+=?vXR`3Kx1~b@6CPt-FhXc}EWk`v79FlWf*VwyE^^ZGxqK6xVCM=)`LR z;)3GNLa2yJ#Y4f^j8aU!&I(Y1HyqDEOb03W>dWC0=n&^yn_h@Z_&yjE47P2}{*J(CRaDlxuJkg3mPr*lZRA5Enm}3y~tB7b_o zEh{Mp{u8G!`ONZDOz1jk{>4QaM}WfxBBXEucxl6rKGhLKgbv^G_yBp^u}N+Up5_oA ziPQsb08#)UeW`L7>+3fnFfYjSxbSWQ^Ur1Nw~Yqy_#z))B&M)H{^uEm zb-4#I=+8Vp-_B>S{4=Gi-VlZRE3_d8%u+Lfs}*9P!YCXUKq}CSy)C+*xnd>!R}#vJ zZsV~Ly&aL49?3Zn0E4HmO)l874!dzZE1{hjk>_p2d=eNS|FVoy+mIC&AKm*TD z?xr`5iwcE_K~|!cMUmXhESe#RYkNo+9QVet(B`no6NSTPDs2-eoL8LPwALQ8jcq_- z9qSmE+7G=ynnfkpit5_V$DJ3gw~;f@(tN!jc1_M!+^atPxk7({R?FQ?%N$ub&nKT$NBQ%5hW6*7ObLjPN0)(Z%D`(iT38`(zFqk|!(#7C6+`RQUpOZ|@~ zUbRPnLGkxH=D)yg``A^tGfzai4J)#-C+(9_)^~7P=ZZlG?%F85P;si|9&I}a>X-+} zDJ4+0Soqagy<}PSi4pP$Di>4TT9H`kfQJd5H92I)*#2&uhP}dm;03Xg<=NT0o<<%p zS)>73Ix6GG%Bq0|V!{8Dy_?n+L~FZm!X>yW)8^M;fwqq<+?vyVG?Ws^;kE&}Uww5^AK;^xHM_gtb`ndULUFTa(doxx+wcls#-c}4?CnYCZT_zv!{ znM=ha?j|CdMx?%MhtGR=WsaO3_KUbBN;^UfT5#e$(C*zN%nM)tcs{Oo^ z5_)=u0#&K@%=QCh=)ftyA2lQ2`!#d9nwx8~^bTI^XW#-K_m~^grfAe-6SHmtK2TpX zq!EAQ!OerpA*;Dxa1Ud%ubr8-vA61ud?89dP;s$KQ*Atp3wF5+KOAynNCj{bDjw81 zXYNbdbF({unCYJnfdacfBk=Cy_lB4W=|ohjxTRWqHE1lrpYttWj?7Z{c$o1uhZ7G@ zgOAgy|--)CD-tr z{i;YKrBu$M@OpVlT_>~gB1z1TT5nA0v&K5j>pQw zusXuhc;?b1#N;Y;hsr!`NCi+T&wr?I(-xpRFrJjoKte_ks5d_RsI z_gReNhB-uRPd4hVw?&VBYuGT`G>kko|KwhG(R``rTuj;^cZu8eq$qg&6@kLfe~8Bn z%Ky4Au!vxho7{3QG^Gs)s^iazG0%{CG!DyAB9Kq$%kEkEE;|kUG z_Mg~GnT9xG*?9mg!+bu##e-`i@ilJw(v)M>Bbxaa3#2OwH)M8Px0!rCYq{`yuZ?fZ0NpUCWFskH1{kac!I!= zO|}UQ5A>L?qo$FUEot{Syz(-3WdY8}9Fy?e{9&_M zvKiM-eBDkWuBYL&Jq&h^Xo=t7!IXPrUhb&!T zSBBOY9s{j+SI(XwpN}%7;vS%7z7iLlC6P7YU3^Ly1S%BM;-n4rdb?v;Fu+wcEcALN zeq-6*z@2*NJ@mdb5)q``c_)+gKCU(#%zeOup-IPx3AB2_JIAkX# z@-AITb9MTz2itWyN0(pQ(EXkVnR~E$+$rDO{PT`s@fhU5g}stR?h@;;C!pO+v{tT^) zMow4%=oHawW!Al1d83R0Ealbq0xq*5rz8E!Y(d79sR3Pqg`LaSJr2u;kDXc-&l@U| zu$rz}_DbQ$W@6z!vS1pkcE?eoFQv!~gsV~LcE?i-l*gb2645zcCcb4u&q`1$`#qRx zcg(c6sc&5FL7#sR9}3K>vm=Cn;7`6opS8{9s`$bNgk#-~bNs<2Rc)tNW6b7Cs42=) z(m53rVBnL08BOtmv^vNk9c;n6o#kRA63$N^>8G`) zCL#Xb6&O|1N*|h1K?(;83;Tp9k6`T|Z=bVAUdPEj>JQ6zuI)VltAg0$c?=GUl;Lw* zJAAr4jp)M8q=}7{ADKaqmp=$r^j*9uQX0x9_SPOL{9co;=T+S$5Wb40XV>n@u8nIY zmbS8@#=3R|`O^SV?}>S3H+%-BB-^zE?YQoiQDkA4li}CAADa4hcKw4tokr-K$@b2igmELg7y8pY5H`l&)n}-8h~*?jnh^M&BL9(nUVLGMn+?B?C9 zlmYrA7HY6vhpvbLMG(mlTG>!zh9+PdpE0+3o|#GVK^0!d54w(+cvLOQ|BjS#0CCwR zeE!pDYby_t3#`* z;-~{$191mj%0goal|o9(^$JMlTyCt&XvU0ix&>U@cg5JKA!=IQ({uOX=bJ*!Kr;j@ zaUm{=ebs40sY5~Q9B#zy55Pj2JgQlK12Ll5Ap39?Zq#8J6non8YZ^GAd&O4#C~?E)WOY~p_6)c_0R67qcSr|KP%>(gkqIyt9q9okV%eN)25`Wp{d@dKz$U6~sga2n`BHkvR78y1$X`p&> zaMF&R#QowP0Ql|qN897-c;p@NRK&pRE=|h&@#k<`NWeg2JN|6Hb6@~TWRMDf2lPUr zKm3}e3KQMxX1n0qoN|riKd@h8h$7H0fh8N_J+VWZqvDcHSGx&AR2RADBCBlaaN!q= zBRL>eNAy*U7QTQ_%!n1s`SKEji-P2iY8s63Z%Q3kU_}v8Lk4(?+Ovj}mtDQ0Y3m1A z>M1Wq#^=neo(|}R@+-YiAy%nUZAlour(a#D&{4&1z~M$Gjy>0U-oHjISZ2~f`E7-C z6zIfHmB(sc`eA*gJ`@uk-!|x>)P0Bf9h?sp!o=NuN0TI5KR^ z3u-3b04S3l2p_;?kf!AdKj;1Eygyk)SUbn^;wD4Y+pV>yh5~qpe1pX{!glWczQAtI zdo;B`thL1lOL;H7Mvt*Xp)Ls*x4iWy^4vcmrfIfq{^leL{!w>e@4Su1V|1u?i^#fs z9n_^#YRyrHMhka`w}wXSJ4fENViAF6KTVAf#{7_b>d}Q7CG5+_QkU07kVTyG?m*wo z6YoM;4XW8%ME>gQQ+&RkYKG2hFnI-^`{_tC9Pp#j`pSoi9yRYHO|Z%vr@}*L*Vj9< zR7CoFj*o16=<#otKNuRxh5|Ui1lgKK9p@Tf%xt^Bs@NY2IEdv&?mwD;V-|pt=Czg~?J&^qWqW1n9_DW!NP?YG4y7=Gw|8OsgBS#be>Kyr^`ib-3jxVxEy3(Fln4Z)5*&m|gBD6ChaBc20>XopOY=J None: + def __init__(self, scope: Construct, construct_id: str, env: cdk.Environment = None, **kwargs) -> None: super().__init__(scope, construct_id, env=env, **kwargs) - # SQS queue for decoupling and buffering events for destination_lambda_b + # SQS queue for decoupling and buffering events source_queue = sqs.Queue( self, "EntryPointToEventbridgePipe", visibility_timeout=cdk.Duration.seconds(60), diff --git a/eventbridge-pipes-sqs-to-dynamodb/example-pattern.json b/eventbridge-pipes-sqs-to-dynamodb/example-pattern.json index e5b5adb15b..c40cb96dc1 100644 --- a/eventbridge-pipes-sqs-to-dynamodb/example-pattern.json +++ b/eventbridge-pipes-sqs-to-dynamodb/example-pattern.json @@ -1,5 +1,5 @@ { - "title": "SQS to DynamoDB using EventBridge Pipes with API Gateway and CDK Python", + "title": "Amazon SQS to Amazon DynamoDB via Amazon EventBridge Pipes using CDK/Python", "description": "Pattern that sends messages from SQS queue to DynamoDB table via API Gateway using EventBridge Pipes. Implemented with CDK using Python.", "language": "Python", "level": "300", @@ -23,7 +23,7 @@ "resources": { "bullets": [ { - "text": "Amazon Simple Queue Service", + "text": "Amazon SQS", "link": "https://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/welcome.html" }, {