Platform & Integration APIs for Modern Lakehouse Systems
Integrate D Modulus data platform and frontline operational services directly into your enterprise stack. Ingest streaming events, trigger federated queries, or orchestrate enterprise data pipelines and AI agents via standardized secure APIs.
Onboarding Process
Before making API requests, you must register your integration to obtain standard API credentials. Follow these simple steps to start using our data platform and operational modules in your application.
Register an API App
Log in to your D Modulus Developer Portal and create a new App. Specify the exact modules and data scopes you need to ensure least-privilege enterprise security.
Obtain Credentials
Once registered, you'll receive a Client ID and a
Client Secret. Keep the secret secure. Do not expose it in client-side
code.
Test in Sandbox
Route your requests to https://sandbox.api.dmodulus.com during development
to test your integrations safely without affecting live data.
Authentication
All production and sandbox endpoints require a Bearer token passed in the Authorization header. You can exchange your Client credentials for a token via our Auth server.
Header Format
Include the token in your requests like so:
Authorization: Bearer YOUR_ACCESS_TOKEN
Lakehouse Event Stream Ingestion
Stream high-velocity transactional and telemetry events directly into the Tesseract LakeOS medallion raw tier. Payloads are automatically schema-validated by the Autonomous Schema Guardian.
Publish batch or single micro-events into the sovereign ACID storage fabric with sub-second write confirmation.
Payload Format (JSON):
{ "stream_name": "orders_realtime", "partition_key": "org_982", "events": [ { "event_id": "evt_001", "timestamp": "2026-10-14T10:00:00Z", "payload": { "order_val": 149.50, "sku": "SKU-992" } } ] }
Federated SQL Query Execution
Execute distributed ANSI SQL queries across heterogeneous operational databases, cloud buckets, and lakehouse tables without moving underlying data.
Submit an asynchronous or synchronous query execution plan. Returns paginated row arrays and query execution telemetry metrics.
Payload Format (SQL):
{ "sql": "SELECT category, SUM(amount) FROM lakehouse.curated.sales GROUP BY 1 LIMIT 50", "timeout_ms": 30000 }
Governed Ingestion & Contracts
Provision governed ingestion pipelines with pre-flight column rules, 204 catalogued transform functions, and automated Iceberg technical contracts (partitioning, clustering, deterministic deduplication).
Create or update a governed ingestion pipeline with full technical contract and column transformation definitions.
Payload Format (JSON):
{ "pipelineName": "orders_ingest", "srcConnId": "mysql_prod", "tgtCatalog": "lakehouse", "tgtSchema": "raw", "tables": [{ "source_table": "orders", "write_mode": "merge", "dedup_order_by": "updated_at DESC", "partitionBy": ["date(created_at)"], "clustering": ["customer_id", "status"], "where_clause": "created_at >= '2026-01-01'", "column_rules": [{ "column": "card_number", "transform": { "kind": "mask_partial", "keepLast": 4 } }, { "column": "email", "transform": { "kind": "hash" } }, { "column": "total_usd", "derived": true, "expr": "total_cents / 100.0" }] }] }
Interactive sub-second preview engine. Samples real source rows and applies column rules via embedded DuckDB translation.
Request Payload:
{ "conn_id": "mysql_prod", "table": "orders", "limit": 100, "column_rules": [...] }
Billing & Notifications Module
Use this module if you already have a billing engine and only need to trigger Email or SMS invoice deliveries to customers using D Modulus reliable notification infrastructure.
Send an invoice or bill notification to a customer via the specified channel (SMS, Email, or WhatsApp).
| Parameter | Type | Description |
|---|---|---|
sale_id |
Path | The unique identifier of the sale/invoice. |
channel |
Path | Must be sms, email, or whatsapp. |
phone |
Query | Required if channel is SMS or WhatsApp. |
email |
Query | Required if channel is Email. |
Contact & CRM Module
Integrate our Contact feature directly into your storefront or internal application. This allows external applications to push lead data or sales requests directly into the D Modulus CRM.
Submit a new contact or sales inquiry request to be managed by the D Modulus team.
| Body Field | Type | Description |
|---|---|---|
name |
String | Name of the person making the inquiry (Required) |
email |
String | Contact email address (Required) |
message |
String | The actual message or inquiry details (Required) |
phone |
String | Optional phone number |
Network Link Module
D Modulus features an Enterprise Business Network. Use the link APIs to discover and connect with other merchants and suppliers, allowing external apps to establish network connections.
Send a connection request to link your business with another merchant or supplier in the network.
| Body Field | Type | Description |
|---|---|---|
target_user_id |
String | The ID of the business you wish to link with. |
Retrieve a list of all your active linked business connections.
Real-time Chat Module
Embed our robust chat feature into any interface. Powered by high-speed WebSocket pub/sub, it ensures instantaneous messaging between business connections or staff.
Establish a persistent WebSocket connection to send and receive real-time messages. Requires token-based authentication during the handshake.
Payload Format (Send Message):
{ "type": "message", "recipient_id": "user_456", "content": "Hello!" }
Fetch a list of recent chat conversations including the last message snippet and unread counts.