File tree Expand file tree Collapse file tree 2 files changed +10
-4
lines changed
aws_lambda_powertools/utilities/data_classes
examples/event_sources/src Expand file tree Collapse file tree 2 files changed +10
-4
lines changed Original file line number Diff line number Diff line change 4646from .secrets_manager_event import SecretsManagerEvent
4747from .ses_event import SESEvent
4848from .sns_event import SNSEvent
49- from .sqs_event import SQSEvent
49+ from .sqs_event import SQSEvent , SQSRecord
5050from .transfer_family_event import TransferFamilyAuthorizer , TransferFamilyAuthorizerResponse
5151from .vpc_lattice import VPCLatticeEvent , VPCLatticeEventV2
5252
8787 "SESEvent" ,
8888 "SNSEvent" ,
8989 "SQSEvent" ,
90+ "SQSRecord" ,
9091 "event_source" ,
9192 "AWSConfigRuleEvent" ,
9293 "VPCLatticeEvent" ,
Original file line number Diff line number Diff line change 1- from aws_lambda_powertools .utilities .data_classes import SQSEvent , event_source
1+ from aws_lambda_powertools .utilities .data_classes import SQSEvent , SQSRecord , event_source
22
33
44@event_source (data_class = SQSEvent )
55def lambda_handler (event : SQSEvent , context ):
66 # Multiple records can be delivered in a single event
77 for record in event .records :
8- message = record .body
9- message_id = record .message_id
8+ message , message_id = process_record (record )
109 return {
1110 "message" : message ,
1211 "message_id" : message_id ,
1312 }
13+
14+
15+ def process_record (record : SQSRecord ):
16+ message = record .body
17+ message_id = record .message_id
18+ return message , message_id
You can’t perform that action at this time.
0 commit comments