Graph service platform

Summary

Grab's GrabDefence team required a dedicated graph infrastructure to proactively identify mobile fraud patterns, such as multiple accounts operating on shared physical devices and suspicious financial loops. To address this, the team built a four-layer Platform as a Service that encapsulates graph database operations behind uniform RESTful APIs for OLTP search and OLAP analysis. The architecture utilizes Amazon S3 for raw data files, Amazon Neptune for graph storage, DynamoDB for schema and metadata configurations, and Kafka for streaming ingestion. When users trigger data loading tasks, the service validates entity attributes against schemas stored in DynamoDB before importing records into Neptune. This infrastructure allows investigators to traverse adjacent account IDs and visualize complex entity relationships without managing underlying database runtimes.

Takeaways

1. 1

   The graph service synchronizes and validates entity and attribute data against DynamoDB schemas before importing S3 CSV files into Amazon Neptune.

2. 2

   Using Kafka as a streaming write engine provides primary user authentication while mitigating write pressure on the Neptune database cluster.

3. 3

   The platform exposes separate RESTful API interfaces for real-time stream search (OLTP) and batch processing graph analysis (OLAP).