Build a Financial Pipeline with Suspicious Transaction Detection

Build a Financial Pipeline with Suspicious Transaction Detection
Build a Financial Pipeline with Suspicious Transaction Detection

CLOUD LABS



Build a Financial Pipeline with Suspicious Transaction Detection

In this Cloud Lab, you’ll build a real-time serverless transaction monitoring pipeline using DynamoDB, SQS, Lambda, SNS, and API Gateway to ingest, validate, process, and flag suspicious activity.

7 Tasks

intermediate

1hr 30m

Certificate of Completion

Desktop OnlyDevice is not compatible.
No Setup Required
Amazon Web Services

Learning Objectives

An understanding of how to configure and integrate DynamoDB, SQS, Lambda, SNS, and API Gateway for serverless workflows
The ability to build ingestion and processing layers to improve scalability, reliability, and fault tolerance in financial systems
Familiarity with an automated, cloud-native transaction monitoring system that validates transactions, detects anomalies, and notifies customers in real time

Technologies
Lambda logoLambda
DynamoDB logoDynamoDB
SQS logoSQS
Cloud Lab Overview

In today’s fast-paced digital financial world, transactions occur continuously, but not all are safe. Large or unusual transactions can indicate potential issues, ranging from simple errors to suspicious activity. If left unchecked, these can lead to financial losses or operational disruptions. Detecting such transactions in real time is essential for maintaining trust and security.

In this Cloud Lab, you will build a serverless, real-time transaction monitoring pipeline to detect suspicious activity using Amazon DynamoDB, SQS, Lambda, SNS, and API Gateway. The Cloud Lab begins by creating two DynamoDB tables, one to store user profile information for validation, and the second one to store all processed transactions along with alerts for suspicious activity. You’ll then configure the SQS FIFO queue to handle incoming transaction messages. An SNS topic will be set up to send alerts whenever a transaction is flagged as suspicious due to its amount exceeding a defined threshold.

The processing workflow is powered by two Lambda functions. The first Lambda, triggered by an HTTP API, ingests transaction requests, validates the input, and pushes them to the SQS queue. The second Lambda, triggered by SQS messages, evaluates the transaction amount, flags it as suspicious if it exceeds the threshold, stores the results in DynamoDB, and sends an SNS alert to notify the customer. Finally, you’ll use an HTTP API endpoint to submit transactions and trigger the pipeline from start to finish.

By the end of this Cloud Lab, you’ll have enough knowledge to build a robust serverless pipeline that processes transactions in real time, flags large transactions, and sends alerts automatically.


The following diagram illustrates the high-level architecture of the infrastructure you’ll build in this Cloud Lab:

Fintech transaction pipeline using AWS Lambda and SQS queue
Fintech transaction pipeline using AWS Lambda and SQS queue
Cloud Lab Tasks
1.Introduction
Getting Started
2.Build the Transaction Processing Pipeline
Create DynamoDB Tables
Create SQS Queue and SNS Topic
3.Enable Real-Time Ingestion and End-to-End Testing
Create Lambda Functions
Create HTTP API and Test the Pipeline
4.Conclusion
Clean Up
Wrap Up
Labs Rules Apply
Stay within resource usage requirements.
Do not engage in cryptocurrency mining.
Do not engage in or encourage activity that is illegal.

Relevant Course

Use the following content to review prerequisites or explore specific concepts in detail.

Hear what others have to say
Join 1.4 million developers working at companies like