#Tech - Tech Stack
Website:
Next JS 15+ / Typescript / Tailwind CSS
Google Cloud Console for web access
MongoDB / cosmos DB through Azure
Dedicated RPC node
Helius back-up RPC node
Hosted on Vercel Serverless (Lightweight)
Telegram Bot
Typescript / node.js server
PostgreSQL database
Weaviate Vectorization
Dedicated RPC node
Helius back-up RPC node
Google Cloud Console for web access
Hosted on Railway.app (Lightweight)
Morris' Brains c.q. Agentic Layer
Python 3.+
Tensorflow
R for analytics
Azure Environment
In a complex data processing workflow, breaking down tasks into specialised agents significantly enhances efficiency, particularly for large-scale, multi-step processes. By leveraging an agentic architecture, each agent handles a specific task—such as data ingestion, profiling, knowledge graph creation, or query orchestration—independently, which reduces latency and enables parallel processing.
For example, the Profiling, Knowledge Graph, and Embedding Generation Agents can work simultaneously to prepare data, while the Model Inference and Query Processing Agents handle query-specific tasks in sequence. This agent-based structure not only improves processing speed but also allows for real-time system optimization through continuous monitoring by a dedicated Monitoring and Logging Agent. Altogether, this approach streamlines the end-to-end process, providing users with faster, accurate responses and an overall optimized data interaction experience.
Throughout his agentic layer, he will use proven algorithms and methods in order to train himself:
Reinforcement training: https://www.ibm.com/topics/reinforcement-learning
Predictive models:
Agent-Based Architecture
Ingestion Agent
Ingest data
Trigger notifications to subsequent agents
Profiling Agent
Run Great Expectations profiling on ingested data in Cosmos DB
Identify schema elements, data types, missing values, and basic data distributions
Store profiling metadata for quick access
Knowledge Graph Agent
Use profiling data to define entity relationships in Cosmos DB Knowledge Graph
Update or create a dynamic knowledge graph with inferred relationships
Alert the Query Orchestration Agent of any schema changes.
Embedding Generation Agent
Generate semantic embeddings using Weaviate based on profiling metadata
Store embeddings for column names and values in Cosmos DB for fast semantic retrieval
Notify the Query Orchestration Agent once embeddings are updated
Model Training Agent
Train or fine-tune company-specific models using Azure Machine Learning based on data and relationships
Regularly check for data updates, retrain models as needed, and version new models in Azure ML Model Management
Notify the Model Inference Agent of any model updates
Model Inference Agent
Load the most recent Morris model from Azure ML Model Management
Interpret and translate user queries based on the trained model
Coordinate with the Query Orchestration Agent to ensure query requests align with the model’s understanding of the data
Query Orchestration Agent
Translate natural language queries into optimised queries using GraphQL
Retrieve column metadata from the Profiling Agent and embeddings from the Embedding Generation Agent
Use the Knowledge Graph to understand relationships and direct queries to the correct data collections
Send refined queries to the Query Processing Agent
Query Processing Agent
Execute complex queries using Apache Spark on Azure and Presto on Azure
Perform aggregations and calculations, fetching results in the desired format
Send processed results to the Response Generation Agent
Response Generation Agent
Receive processed results and convert them into natural language responses via the Morris API
Format responses for readability and contextual accuracy, adjusting tone and detail as per the user’s question
Send final responses to user
Monitoring and Logging Agent
Track performance metrics, response times, and error rates for each agent using Azure Monitor & Log Analytics
Detect bottlenecks or failures and optimise resource allocation across agents
Trigger alerts or corrective actions if latency issues are detected
Last updated