title | description |
---|---|
Event Source Data Classes |
Utility |
Event Source Data Classes provides self-describing and strongly-typed classes for various AWS Lambda event sources.
- Type hinting and code completion for common event types
- Helper functions for decoding/deserializing nested fields
- Docstrings for fields contained in event schemas
- Standardized attribute-based access to event properties
???+ tip All examples shared in this documentation are available within the project repository{target="_blank"}.
There are two ways to use Event Source Data Classes in your Lambda functions.
Method 1: Direct Initialization
You can initialize the appropriate data class by passing the Lambda event object to its constructor.
=== "app.py"
```python hl_lines="1 4"
--8<-- "examples/event_sources/src/getting_started_data_classes.py"
```
=== "API Gateway Proxy Example Event"
```json hl_lines="3-4"
--8<-- "examples/event_sources/events/apigw_event.json"
```
Method 2: Using the event_source Decorator
Alternatively, you can use the event_source
decorator to automatically parse the event.
=== "app.py"
```python hl_lines="1 4"
--8<-- "examples/event_sources/src/apigw_proxy_decorator.py"
```
=== "API Gateway Proxy Example Event"
```json hl_lines="3-4"
--8<-- "examples/event_sources/events/apigw_event.json"
```
Event Source Data Classes has the ability to leverage IDE autocompletion and inline documentation. When using the APIGatewayProxyEvent class, for example, the IDE will offer autocomplete suggestions for various properties and methods.
Each event source is linked to its corresponding GitHub file with the full set of properties, methods, and docstrings specific to each event type.
Event Source | Data_class | Properties |
---|---|---|
Active MQ | ActiveMQEvent |
Github |
API Gateway Authorizer | APIGatewayAuthorizerRequestEvent |
Github |
API Gateway Authorizer V2 | APIGatewayAuthorizerEventV2 |
Github |
API Gateway Proxy | APIGatewayProxyEvent |
Github |
API Gateway Proxy V2 | APIGatewayProxyEventV2 |
Github |
Application Load Balancer | ALBEvent |
Github |
AppSync Authorizer | AppSyncAuthorizerEvent |
Github |
AppSync Resolver | AppSyncResolverEvent |
Github |
AWS Config Rule | AWSConfigRuleEvent |
Github |
Bedrock Agent | BedrockAgent |
Github |
CloudFormation Custom Resource | CloudFormationCustomResourceEvent |
Github |
CloudWatch Alarm State Change Action | CloudWatchAlarmEvent |
Github |
CloudWatch Dashboard Custom Widget | CloudWatchDashboardCustomWidgetEvent |
Github |
CloudWatch Logs | CloudWatchLogsEvent |
Github |
CodeDeploy Lifecycle Hook | CodeDeployLifecycleHookEvent |
Github |
CodePipeline Job Event | CodePipelineJobEvent |
Github |
Cognito User Pool | Multiple available under cognito_user_pool_event |
Github |
Connect Contact Flow | ConnectContactFlowEvent |
Github |
DynamoDB streams | DynamoDBStreamEvent , DynamoDBRecordEventName |
Github |
EventBridge | EventBridgeEvent |
Github |
Kafka | KafkaEvent |
Github |
Kinesis Data Stream | KinesisStreamEvent |
Github |
Kinesis Firehose Delivery Stream | KinesisFirehoseEvent |
Github |
Lambda Function URL | LambdaFunctionUrlEvent |
Github |
Rabbit MQ | RabbitMQEvent |
Github |
S3 | S3Event |
Github |
S3 Batch Operations | S3BatchOperationEvent |
Github |
S3 Object Lambda | S3ObjectLambdaEvent |
Github |
S3 EventBridge Notification | S3EventBridgeNotificationEvent |
Github |
SES | SESEvent |
Github |
SNS | SNSEvent |
Github |
SQS | SQSEvent |
Github |
[TransferFamilyAuthorizer] | TransferFamilyAuthorizer |
Github |
[TransferFamilyAuthorizerResponse] | TransferFamilyAuthorizerResponse |
Github |
VPC Lattice V2 | VPCLatticeV2Event |
Github |
VPC Lattice V1 | VPCLatticeEvent |
Github |
IoT Core Thing Created/Updated/Deleted | IoTCoreThingEvent |
GitHub |
IoT Core Thing Type Created/Updated/Deprecated/Undeprecated/Deleted | IoTCoreThingTypeEvent |
GitHub |
IoT Core Thing Type Associated/Disassociated with a Thing | IoTCoreThingTypeAssociationEvent |
GitHub |
IoT Core Thing Group Created/Updated/Deleted | IoTCoreThingGroupEvent |
GitHub |
IoT Thing Added/Removed from Thing Group | IoTCoreAddOrRemoveFromThingGroupEvent |
GitHub |
IoT Child Group Added/Deleted from Parent Group | IoTCoreAddOrDeleteFromThingGroupEvent |
GitHub |
???+ info The examples showcase a subset of Event Source Data Classes capabilities - for comprehensive details, leverage your IDE's autocompletion, refer to type hints and docstrings, and explore the full API reference for complete property listings of each event source.
It is used for Active MQ payloads{target="_blank"}, also see the AWS blog post{target="_blank"} for more details.
=== "app.py"
```python hl_lines="5 10"
--8<-- "examples/event_sources/src/active_mq_example.py"
```
=== "Active MQ Example Event"
```json hl_lines="6 9 18 21"
--8<-- "tests/events/activeMQEvent.json"
```
It is used for API Gateway Rest API Lambda Authorizer payload{target="_blank"}.
Use APIGatewayAuthorizerRequestEvent
for type REQUEST
and APIGatewayAuthorizerTokenEvent
for type TOKEN
.
=== "Rest APIs"
```python hl_lines="2-4 8 18"
--8<-- "examples/event_sources/src/apigw_authorizer_request.py"
```
=== "WebSocket APIs"
```python hl_lines="2-4 8 18"
--8<-- "examples/event_sources/src/apigw_authorizer_request_websocket.py"
```
=== "API Gateway Authorizer Request Example Event"
```json hl_lines="3 11"
--8<-- "tests/events/apiGatewayAuthorizerRequestEvent.json"
```
=== "app_token.py"
```python hl_lines="2-4 8"
--8<-- "examples/event_sources/src/apigw_authorizer_token.py"
```
=== "API Gateway Authorizer Token Example Event"
```json hl_lines="2 3"
--8<-- "tests/events/apiGatewayAuthorizerTokenEvent.json"
```
It is used for API Gateway HTTP API Lambda Authorizer payload version 2{target="_blank"}. See also this blog post{target="_blank"} for more details.
=== "app.py"
```python hl_lines="4-6 16"
--8<-- "examples/event_sources/src/apigw_auth_v2.py"
```
=== "API Gateway Authorizer V2 Example Event"
```json
--8<-- "tests/events/apiGatewayAuthorizerV2Event.json"
```
It is used for either API Gateway REST API or HTTP API using v1 proxy event.
=== "app.py"
```python hl_lines="1 4"
--8<-- "examples/event_sources/src/apigw_proxy_decorator.py"
```
=== "API Gateway Proxy Example Event"
```json hl_lines="3 4"
--8<-- "examples/event_sources/events/apigw_event.json"
```
It is used for HTTP API using v2 proxy event.
=== "app.py"
```python hl_lines="1 4"
--8<-- "examples/event_sources/src/apigw_proxy_v2.py"
```
=== "API Gateway Proxy V2 Example Event"
```json
--8<-- "tests/events/apiGatewayProxyV2Event.json"
```
Is it used for Application load balancer event.
=== "app.py"
```python hl_lines="1 4"
--8<-- "examples/event_sources/src/albEvent.py"
```
=== "Application Load Balancer Example Event"
```json hl_lines="7 8"
--8<-- "tests/events/albEvent.json"
```
Used when building an AWS_LAMBDA Authorization{target="_blank"} with AppSync. See blog post Introducing Lambda authorization for AWS AppSync GraphQL APIs{target="_blank"} or read the Amplify documentation on using AWS Lambda for authorization{target="_blank"} with AppSync.
=== "app.py"
```python hl_lines="5-7 20"
--8<-- "examples/event_sources/src/appSyncAuthorizer.py"
```
=== "AppSync Authorizer Example Event"
```json
--8<-- "tests/events/appSyncAuthorizerEvent.json"
```
Used when building Lambda GraphQL Resolvers with Amplify GraphQL Transform Library{target="_blank"} (@function
),
and AppSync Direct Lambda Resolvers{target="_blank"}.
The example serves as an AppSync resolver for the locations
field of the Merchant
type. It uses the @event_source
decorator to parse the AppSync event, handles pagination and filtering for locations, and demonstrates AppSyncIdentityCognito
.
=== "app.py"
```python hl_lines="2-4 9"
--8<-- "examples/event_sources/src/appSyncResolver.py"
```
=== "AppSync Resolver Example Event"
```json
--8<-- "tests/events/appSyncResolverEvent.json"
```
The example utilizes AWSConfigRuleEvent to parse the incoming event. The function logs the message type of the invoking event and returns a simple success response. The example event receives a Scheduled Event Notification, but could also be ItemChanged and Oversized.
=== "app.py"
python hl_lines="2-3 10" --8<-- "examples/event_sources/src/aws_config_rule.py"
=== "ScheduledNotification Example Event"
json --8<-- "tests/events/awsConfigRuleScheduled.json"
The example handles Bedrock Agent event with BedrockAgentEvent
to parse the incoming event. The function logs the action group and input text, then returns a structured response compatible with Bedrock Agent's expected format, including a mock response body.
=== "app.py"
```python hl_lines="2 7"
--8<-- "examples/event_sources/src/bedrock_agent.py"
```
=== "Bedrock Agent Example Event"
json --8<-- "tests/events/bedrockAgentEvent.json"
The example focuses on the Create
request type, generating a unique physical resource ID and logging the process. The function is structured to potentially handle Update
and Delete
operations as well.
=== "app.py"
```python hl_lines="2-3 11 15 21"
--8<-- "examples/event_sources/src/cloudformation_custom_resource_handler.py"
```
=== "CloudFormation Custom Resource Example Event"
json --8<-- "tests/events/cloudformationCustomResourceCreate.json"
Thie example for CloudWatchDashboardCustomWidgetEvent
logs the dashboard name, extracts key information like widget ID and time range, and returns a formatted response with a title and markdown content. Read more about custom widgets for Cloudwatch dashboard.
=== "app.py"
```python hl_lines="2 7"
--8<-- "examples/event_sources/src/cloudWatchDashboard.py"
```
=== "CloudWatch Dashboard Example Event"
json --8<-- "tests/events/cloudWatchDashboardEvent.json"
CloudWatch supports Lambda as an alarm state change action{target="_blank"}.
You can use the CloudWathAlarmEvent
data class to access the fields containing such data as alarm information, current state, and previous state.
=== "app.py"
```python hl_lines="2 8"
--8<-- "examples/event_sources/src/cloudwatch_alarm_event.py"
```
=== "CloudWatch Alarm Example Event"
json --8<-- "tests/events/cloudWatchAlarmEventSingleMetric.json"
CloudWatch Logs events by default are compressed and base64 encoded. You can use the helper function provided to decode, decompress and parse json data from the event.
=== "app.py"
```python hl_lines="2-3 8"
--8<-- "examples/event_sources/src/cloudwatch_logs.py"
```
=== "CloudWatch Logs Example Event"
json --8<-- "tests/events/cloudWatchLogEvent.json"
When streaming CloudWatch Logs to a Kinesis Data Stream{target="_blank"} (cross-account or not), you can use extract_cloudwatch_logs_from_event
to decode, decompress and extract logs as CloudWatchLogsDecodedData
to ease log processing.
=== "app.py"
```python hl_lines="5-7 11"
--8<-- "examples/event_sources/src/kinesisStreamCloudWatchLogs.py"
```
=== "Kinesis Stream CloudWatch Logs Example Event"
json --8<-- "tests/events/kinesisStreamCloudWatchLogsEvent.json"
Alternatively, you can use extract_cloudwatch_logs_from_record
to seamless integrate with the Batch utility{target="_blank"} for more robust log processing.
=== "app.py"
```python hl_lines="7-9 18"
--8<-- "examples/event_sources/src/kinesis_batch_example.py"
```
=== "Kinesis Stream CloudWatch Logs Example Event"
json --8<-- "tests/events/kinesisStreamCloudWatchLogsEvent.json"
CodeDeploy triggers Lambdas with this event when defined in AppSpec definitions to test applications at different stages of deployment.
=== "app.py"
```python hl_lines="1 4"
--8<-- "examples/event_sources/src/codedeploy_lifecycle_hook.py"
```
=== "CodeDeploy LifeCycle Hook Example Event"
json --8<-- "tests/events/codeDeployLifecycleHookEvent.json"
Data classes and utility functions to help create continuous delivery pipelines tasks with AWS Lambda.
=== "app.py"
python hl_lines="1 4" --8<-- "examples/event_sources/src/code_pipeline_job.py"
=== "CodePipeline Job Example Event"
json hl_lines="3 19" --8<-- "tests/events/codePipelineEvent.json"
Cognito User Pools have several different Lambda trigger sources{target="_blank"}, all of which map to a different data class, which
can be imported from aws_lambda_powertools.data_classes.cognito_user_pool_event
:
Trigger/Event Source | Data Class |
---|---|
Custom message event | data_classes.cognito_user_pool_event.CustomMessageTriggerEvent |
Post authentication | data_classes.cognito_user_pool_event.PostAuthenticationTriggerEvent |
Post confirmation | data_classes.cognito_user_pool_event.PostConfirmationTriggerEvent |
Pre authentication | data_classes.cognito_user_pool_event.PreAuthenticationTriggerEvent |
Pre sign-up | data_classes.cognito_user_pool_event.PreSignUpTriggerEvent |
Pre token generation | data_classes.cognito_user_pool_event.PreTokenGenerationTriggerEvent |
Pre token generation V2 | data_classes.cognito_user_pool_event.PreTokenGenerationV2TriggerEvent |
User migration | data_classes.cognito_user_pool_event.UserMigrationTriggerEvent |
Define Auth Challenge | data_classes.cognito_user_pool_event.DefineAuthChallengeTriggerEvent |
Create Auth Challenge | data_classes.cognito_user_pool_event.CreateAuthChallengeTriggerEvent |
Verify Auth Challenge | data_classes.cognito_user_pool_event.VerifyAuthChallengeResponseTriggerEvent |
Custom Email Sender | data_classes.cognito_user_pool_event.CustomEmailSenderTriggerEvent |
Custom SMS Sender | data_classes.cognito_user_pool_event.CustomSMSSenderTriggerEvent |
Some examples for the Cognito User Pools Lambda triggers sources:
=== "app.py"
```python hl_lines="1 5"
--8<-- "examples/event_sources/src/cognito_post_confirmation.py"
```
=== "Cognito Post Confirmation Example Event"
json hl_lines="12-14" --8<-- "tests/events/cognitoPostConfirmationEvent.json"
???+ note
In this example we are modifying the wrapped dict response fields, so we need to return the json serializable wrapped event in event.raw_event
.
This example is based on the AWS Cognito docs for Define Auth Challenge Lambda Trigger{target="_blank"}.
=== "app.py"
```python hl_lines="1 5"
--8<-- "examples/event_sources/src/cognito_define_auth.py"
```
=== "Cognito Define Auth Challengen Example Event"
json --8<-- "tests/events/cognitoDefineAuthChallengeEvent.json"
This example is based on the AWS Cognito docs for Create Auth Challenge Lambda Trigger{target="_blank"}.
=== "app.py"
```python hl_lines="2 5"
--8<-- "examples/event_sources/src/cognito_create_auth.py"
```
=== "Cognito Create Auth Challengen Example Event"
json --8<-- "tests/events/cognitoCreateAuthChallengeEvent.json"
This example is based on the AWS Cognito docs for Verify Auth Challenge Response Lambda Trigger{target="_blank"}.
=== "app.py"
```python hl_lines="2 5"
--8<-- "examples/event_sources/src/cognito_verify_auth.py"
```
=== "Cognito Verify Auth Challengen Example Event"
json --8<-- "tests/events/cognitoVerifyAuthChallengeResponseEvent.json"
The example integrates with Amazon Connect by handling contact flow events. The function converts the event into a ConnectContactFlowEvent
object, providing a structured representation of the contact flow data.
=== "app.py"
```python hl_lines="1-5 10"
--8<-- "examples/event_sources/src/connect_contact_flow.py"
```
=== "Connect Contact Flow Example Event"
json --8<-- "tests/events/connectContactFlowEventAll.json"
The DynamoDB data class utility provides the base class for DynamoDBStreamEvent
, as well as enums for stream view type (StreamViewType
) and event type.
(DynamoDBRecordEventName
).
The class automatically deserializes DynamoDB types into their equivalent Python types.
=== "app.py"
python hl_lines="1-3 8" --8<-- "examples/event_sources/src/dynamodb_stream.py"
=== "app_multiple_records.py"
python hl_lines="1 5" --8<-- "examples/event_sources/src/dynamodb_multiple_records.py"
=== "DynamoDB Streams Example Event"
json --8<-- "tests/events/dynamoStreamEvent.json"
When an event matching a defined rule occurs in EventBridge, it can automatically trigger a Lambda function, passing the event data as input.
=== "app.py"
```python hl_lines="1 4"
--8<-- "examples/event_sources/src/eventBridgeEvent.py"
```
=== "EventBridge Example Event"
json --8<-- "tests/events/eventBridgeEvent.json"
This example is based on the AWS docs for Amazon MSK{target="_blank"} and self-managed Apache Kafka{target="_blank"}.
=== "app.py"
```python hl_lines="1 8"
--8<-- "examples/event_sources/src/kafka_event.py"
```
=== "Kafka Example Event"
json --8<-- "tests/events/kafkaEventMsk.json"
Kinesis events by default contain base64 encoded data. You can use the helper function to access the data either as json or plain text, depending on the original payload.
=== "app.py"
```python hl_lines="4 11"
--8<-- "examples/event_sources/src/kinesis_streams.py"
```
=== "Kinesis streams Example Event"
json --8<-- "tests/events/kinesisStreamEvent.json"
When using Kinesis Firehose, you can use a Lambda function to perform data transformation{target="_blank"}. For each transformed record, you can choose to either:
- A) Put them back to the delivery stream (default)
- B) Drop them so consumers don't receive them (e.g., data validation)
- C) Indicate a record failed data transformation and should be retried
To do that, you can use KinesisFirehoseDataTransformationResponse
class along with helper functions to make it easier to decode and encode base64 data in the stream.
=== "Transforming streaming records"
```python hl_lines="2-3 10 12"
--8<-- "examples/event_sources/src/kinesis_firehose_delivery_stream.py"
```
1. **Ingesting JSON payloads?** <br><br> Use `record.data_as_json` to easily deserialize them.
2. For your convenience, `base64_from_json` serializes a dict to JSON, then encode as base64 data.
=== "Dropping invalid records"
```python hl_lines="5-6 14 16"
--8<-- "examples/event_sources/src/kinesis_firehose_response_drop.py"
```
1. This exception would be generated from `record.data_as_json` if invalid payload.
=== "Indicating a processing failure"
```python hl_lines="2-3 11 33"
--8<-- "examples/event_sources/src/kinesis_firehose_response_exception.py"
```
1. This record will now be sent to your [S3 bucket in the `processing-failed` folder](https://docs.aws.amazon.com/firehose/latest/dev/data-transformation.html#data-transformation-failure-handling){target="_blank"}.
=== "kinesisFirehoseEvent.json"
json --8<-- "tests/events/kinesisFirehoseKinesisEvent.json"
Lambda Function URLs provide a direct HTTP endpoint for invoking Lambda functions. This feature allows functions to receive and process HTTP requests without the need for additional services like API Gateway.
=== "app.py"
```python hl_lines="1 4"
--8<-- "examples/event_sources/src/lambdaFunctionUrl.py"
```
=== "Lambda Function URL Example Event"
json --8<-- "tests/events/lambdaFunctionUrlEvent.json"
It is used for Rabbit MQ payloads{target="_blank"}. See the blog post{target="_blank"} for more details.
=== "app.py"
```python hl_lines="5 10"
--8<-- "examples/event_sources/src/rabbit_mq_example.py"
```
=== "Rabbit MQ Example Event"
json --8<-- "tests/events/rabbitMQEvent.json"
Integration with Amazon S3 enables automatic, serverless processing of object-level events in S3 buckets. When triggered by actions like object creation or deletion, Lambda functions receive detailed event information, allowing for real-time file processing, data transformations, and automated workflows.
=== "app.py"
```python hl_lines="3 6"
--8<-- "examples/event_sources/src/s3Event.py"
```
=== "S3 Example Event"
json --8<-- "tests/events/s3Event.json"
This example is based on the AWS S3 Batch Operations documentation Example Lambda function for S3 Batch Operations{target="_blank"}.
=== "app.py"
```python hl_lines="4 8 10 20 25 27 29 33"
--8<-- "examples/event_sources/src/s3_batch_operation.py"
```
=== "S3 Batch Operations Example Event"
```json
--8<-- "tests/events/s3BatchOperationEventSchemaV2.json"
```
This example is based on the AWS Blog post Introducing Amazon S3 Object Lambda – Use Your Code to Process Data as It Is Being Retrieved from S3{target="_blank"}.
=== "app.py"
```python hl_lines="5 6 13 15"
--8<-- "examples/event_sources/src/s3_object_lambda.py"
```
=== "S3 Object Lambda Example Event"
```json
--8<-- "examples/event_sources/events/s3ObjectEvent.json"
```
S3 EventBridge notifications enhance Lambda's ability to process S3 events by routing them through Amazon EventBridge. This integration offers advanced filtering, multiple destination support, and standardized CloudEvents format.
=== "app.py"
```python hl_lines="1 4"
--8<-- "examples/event_sources/src/s3_event_bridge.py"
```
=== "S3 EventBridge Notification Example Event"
```json
--8<-- "tests/events/s3EventBridgeNotificationObjectCreatedEvent.json"
```
AWS Secrets Manager rotation uses an AWS Lambda function to update the secret. Click here{target="_blank"} for more information about rotating AWS Secrets Manager secrets.
=== "app.py"
```python hl_lines="2 7 11"
--8<-- "examples/event_sources/src/secrets_manager.py"
```
=== "Secrets Manager Example Event"
```json
--8<-- "tests/events/secretsManagerEvent.json"
```
The integration with Simple Email Service (SES) enables serverless email processing. When configured, SES can trigger Lambda functions in response to incoming emails or delivery status notifications. The Lambda function receives an SES event containing details like sender, recipients, and email content.
=== "app.py"
```python hl_lines="1 4"
--8<-- "examples/event_sources/src/ses_event.py"
```
=== "SES Example Event"
```json
--8<-- "tests/events/sesEvent.json"
```
The integration with Simple Notification Service (SNS) enables serverless message processing. When configured, SNS can trigger Lambda functions in response to published messages or notifications. The Lambda function receives an SNS event containing details like the message body, subject, and metadata.
=== "app.py"
```python hl_lines="1 4"
--8<-- "examples/event_sources/src/sns_event.py"
```
=== "SNS Example Event"
```json
--8<-- "tests/events/snsEvent.json"
```
The integration with Simple Queue Service (SQS) enables serverless queue processing. When configured, SQS can trigger Lambda functions in response to messages in the queue. The Lambda function receives an SQS event containing details like message body, attributes, and metadata.
=== "app.py"
```python hl_lines="1 4"
--8<-- "examples/event_sources/src/sqs_event.py"
```
=== "SQS Example Event"
```json
--8<-- "tests/events/sqsEvent.json"
```
You can register your Lambda functions as targets within an Amazon VPC Lattice service network. By doing this, your Lambda function becomes a service within the network, and clients that have access to the VPC Lattice service network can call your service using Payload V2{target="_blank"}.
Click here{target="_blank"} for more information about using AWS Lambda with Amazon VPC Lattice.
=== "app.py"
```python hl_lines="2 8"
--8<-- "examples/event_sources/src/vpc_lattice_v2.py"
```
=== "Lattice Example Event"
```json
--8<-- "examples/event_sources/events/vpc_lattice_v2_payload.json"
```
You can register your Lambda functions as targets within an Amazon VPC Lattice service network. By doing this, your Lambda function becomes a service within the network, and clients that have access to the VPC Lattice service network can call your service.
Click here{target="_blank"} for more information about using AWS Lambda with Amazon VPC Lattice.
=== "app.py"
```python hl_lines="2 8"
--8<-- "examples/event_sources/src/vpc_lattice.py"
```
=== "Lattice Example Event"
```json
--8<-- "examples/event_sources/events/vpc_lattice_payload.json"
```
You can use IoT Core registry events to trigger your lambda functions. More information on this specific one can be found here.
=== "app.py"
python hl_lines="2 5" --8<-- "examples/event_sources/src/iot_registry_thing_event.py"
=== "Example Event"
json --8<-- "tests/events/iotRegistryEventsThingEvent.json"
You can use IoT Core registry events to trigger your lambda functions. More information on this specific one can be found here.
=== "app.py"
python hl_lines="2 5" --8<-- "examples/event_sources/src/iot_registry_thing_type_event.py"
=== "Example Event"
json --8<-- "tests/events/iotRegistryEventsThingTypeEvent.json"
You can use IoT Core registry events to trigger your lambda functions. More information on this specific one can be found here.
=== "app.py"
python hl_lines="2 5" --8<-- "examples/event_sources/src/iot_registry_thing_type_association_event.py"
=== "Example Event"
json --8<-- "tests/events/iotRegistryEventsThingTypeAssociationEvent.json"
You can use IoT Core registry events to trigger your lambda functions. More information on this specific one can be found here.
=== "app.py"
python hl_lines="2 5" --8<-- "examples/event_sources/src/iot_registry_thing_group_event.py"
=== "Example Event"
json --8<-- "tests/events/iotRegistryEventsThingGroupEvent.json"
You can use IoT Core registry events to trigger your lambda functions. More information on this specific one can be found here.
=== "app.py"
python hl_lines="2 5" --8<-- "examples/event_sources/src/iot_registry_add_or_remove_from_thing_group_event.py"
=== "Example Event"
json --8<-- "tests/events/iotRegistryEventsAddOrRemoveFromThingGroupEvent.json"
You can use IoT Core registry events to trigger your lambda functions. More information on this specific one can be found here.
=== "app.py"
python hl_lines="2 5" --8<-- "examples/event_sources/src/iot_registry_add_or_delete_from_thing_group_event.py"
=== "Example Event"
json --8<-- "tests/events/iotRegistryEventsAddOrDeleteFromThingGroupEvent.json"
Alternatively, you can print out the fields to obtain more information. All classes come with a __str__
method that generates a dictionary string which can be quite useful for debugging.
However, certain events may contain sensitive fields such as secret_access_key
and session_token
, which are labeled as [SENSITIVE]
to prevent any accidental disclosure of confidential information.
!!! warning "If we fail to deserialize a field value (e.g., JSON), they will appear as [Cannot be deserialized]
"
=== "debugging.py"
python hl_lines="9" --8<-- "examples/event_sources/src/debugging.py"
=== "debugging_event.json"
json hl_lines="28 29" --8<-- "examples/event_sources/events/debugging_event.json"
=== "debugging_output.json"
json hl_lines="16 17 18" --8<-- "examples/event_sources/events/debugging_output.json"