1. Overview
Scope: setGetApi, API Gateway , AWS API Gateway , Amazon Simple Queue Service
2. System Components
Web UI: Client interface for uploading data.
Kairos Processing Modules: Details on
kairos-file-process
,kairos-product-manager
, andkairos-products
that prepare data for storage.API Gateway: Manages client requests and routes them to SQS for processing.
Amazon SQS: Queues data to ensure order and manage asynchronous processing.
setGetApi: Retrieves and processes data from SQS and performs validation.
Redis: Serves as both a temporary and long-term data storage layer.
Scheduler: Nightly task that backs up Redis data to MongoDB.
MongoDB: Stores a secondary copy of data for archival purposes.
3. Data Flow
Describe the sequential data journey:
From Web UI upload to Kairos modules for processing.
API Gateway routes processed data to SQS.
setGetApi retrieves data from SQS, processes it, and stores it in Redis.
The Scheduler copies Redis data to MongoDB each night.
4. Data Persistence and Storage
Redis: Long-term storage and temporary data retrieval cache.
MongoDB: Archival storage updated nightly.
5. Architecture
for Set Api
for Get Api
Request from KP(webhook Key)→ setGetApi (retrieves data from Redis) → Response to KP.
6. Advantages
Storing Multiple Webhook Keys:
The ability to store an arbitrary number of webhook keys enhances flexibility, allowing for different systems or endpoints to receive the same data. This improves the extensibility and scalability of your integration.Reduced Load on Kairos-Products and ActiveMQ:
By handling webhook keys and managing the distribution of data within this module, the system offloads processing from the Kairos-products module and internal ActiveMQ. This reduces the risk of overloading these critical components, improving overall performance and reliability.Configurable TTL (Time-To-Live):
The TTL configuration on both the account and flow level allows for greater control over how long data is retained before it expires or is removed. This flexibility is especially useful for handling transient data or controlling cache behavior on an account-level or flow-level basis, ensuring efficient memory and resource usage.
0 Comments