donnees-en-direct
title: Live Data sidebar_label: Live Data (5) sidebar_position: 9 doc_type: reference
Live Data
Overview
View your connected data sources and their schemas.
Prerequisites
- API key with the MCP preset and required scopes
- Configured MCP client (see Configuration)
Quick start examples
Explore your connected sources
- List connected sources :
{
"name": "livedata_list_sources",
"arguments": {}
}
- View the data schema :
{
"name": "livedata_source_schema",
"arguments": {
"sourceId": "uuid-de-la-source"
}
}
- Query the data :
{
"name": "livedata_query",
"arguments": {
"sourceId": "uuid-de-la-source",
"limit": 10
}
}
livedata_list_sources
[DISCOVERY] List all connected live data sources with status and metadata.
USE WHEN: • Need to discover available data sources • Checking status of connections • Finding a specific source by name or type RETURNS: List of sources (Airbyte, webhooks, HTTP, MQTT, IoT) with IDs, names, status, stream counts FEATURES: • Filter by category (airbyte, webhook, http, mqtt, iot, database, file) • Filter by status (active, inactive, error) • Search by name • Pagination support REQUIRES: optional: category, status, search, limit, offset RELATED: • livedata_source_status: Get health and activity details • livedata_source_schema: Get stream structure • livedata_query: Query actual data EXAMPLE: "What data sources exist?" or "List active connections" → this tool
| Scope | mcp.read |
| Read-only | Yes |
| Destructive | No |
| Idempotent | Yes |
Parameters
| Parameter | Type | Required | Description |
|---|---|---|---|
category | choice (connecteur, webhook, http, mqtt, iot, database, file) | No | Filter by source category |
limit | number | No | Maximum results to return (default : 50) |
offset | number | No | Offset for pagination (default : 0) |
search | string | No | Search by source name |
status | choice (active, inactive, error) | No | Filter by source status |
Response
| Field | Type | Description |
|---|---|---|
sources | array | |
total | number | |
hasMore | boolean |
Example
{
"name": "livedata_list_sources",
"arguments": {}
}
Related tools :
livedata_source_status,livedata_source_schema,livedata_query
livedata_query
[QUERY] Query real-time data from connected sources with filters.
USE WHEN: • Retrieving actual data records from live sources • Analyzing time-series data for an entity • Getting recent data from a specific stream RETURNS: Data records with timestamps, values, metadata, and time range summary FEATURES: • Time range filtering (ISO8601 startTime/endTime) • Filter by source, stream, or linked entity • TimescaleDB-backed for efficient time-series queries • Pagination support REQUIRES: optional: sourceId, streamId, entityId, startTime, endTime, limit, offset RELATED: • livedata_source_schema: Understand stream structure first • livedata_list_sources: Find source IDs EXAMPLE: "Get last 24h of sales data" or "Query records for Customer X" → this tool
| Scope | mcp.read |
| Read-only | Yes |
| Destructive | No |
| Idempotent | Yes |
Parameters
| Parameter | Type | Required | Description |
|---|---|---|---|
endTime | string | No | End time for query range (ISO8601) |
entityId | string (uuid) | No | Filter by linked entity (node) ID |
limit | number | No | Maximum records to return (default : 100) |
offset | number | No | Offset for pagination (default : 0) |
sourceId | string (uuid) | No | Filter by specific source ID |
startTime | string | No | Start time for query range (ISO8601) |
streamId | string (uuid) | No | Filter by specific stream ID |
Response
| Field | Type | Description |
|---|---|---|
records | array | |
total | number | |
hasMore | boolean | |
timeRange | object | |
earliest | string | |
latest | string |
Related tools :
livedata_list_sources,livedata_source_schema
livedata_source_schema
[QUERY] Get schema and stream structure of a data source.
USE WHEN: • Understanding what data a source provides • Before querying to know available streams • Checking which streams are linked to ontology nodes RETURNS: Streams list with names, namespaces, status, linked nodes, configuration FEATURES: • Stream status visibility (active, paused, error) • Linked ontology nodes per stream • Stream metadata and namespace • Source configuration details REQUIRES: sourceId (from livedata_list_sources) RELATED: • livedata_query: Query data from specific streams • livedata_source_status: Check source health first • livedata_list_sources: Find source first EXAMPLE: "What streams does Salesforce provide?" or "Show source schema" → this tool
| Scope | mcp.read |
| Read-only | Yes |
| Destructive | No |
| Idempotent | Yes |
Parameters
| Parameter | Type | Required | Description |
|---|---|---|---|
sourceId | string (uuid) | Yes | The source ID to get schema for |
Response
| Field | Type | Description |
|---|---|---|
source | object | |
id | string | |
name | string | |
category | string | |
sourceType | string | |
streams | array | |
config | record |
Related tools :
livedata_list_sources,livedata_source_status,livedata_query
livedata_source_status
[MONITORING] Get detailed status and health information for a data source.
USE WHEN: • Checking if a source is healthy • Debugging connection or sync issues • Monitoring source activity RETURNS: Health status, last sync time, error count, success rate, recent activity FEATURES: • Health score based on status and errors • Success rate calculation • Optional activity log with recent calls • Error message extraction REQUIRES: sourceId (from livedata_list_sources); optional: includeActivity RELATED: • livedata_source_schema: Get stream structure • livedata_query: Query data from healthy sources • livedata_list_sources: Find source first EXAMPLE: "Is my Salesforce source healthy?" or "Check source errors" → this tool
| Scope | mcp.read |
| Read-only | Yes |
| Destructive | No |
| Idempotent | Yes |
Parameters
| Parameter | Type | Required | Description |
|---|---|---|---|
sourceId | string (uuid) | Yes | The source ID to check status |
includeActivity | boolean | No | Include recent activity log entries (default : false) |
Response
| Field | Type | Description |
|---|---|---|
source | object | |
id | string | |
name | string | |
category | string | |
sourceType | string | |
status | string | |
lastSyncAt | string | |
errorMessage | string | |
health | object | |
isHealthy | boolean | |
lastActivityAt | string | |
errorCount | number | |
successRate | number | |
activity | object | |
callCount | number | |
avgProcessingTimeMs | number | |
recentCalls | array | |
timestamp | string | |
eventType | string | |
success | boolean |
Related tools :
livedata_list_sources,livedata_source_schema,livedata_query
livedata_trigger_sync
[WRITE] Trigger a data synchronization for a LiveData connection.
USE WHEN: • Need to refresh data from an external source (Stripe, Salesforce, etc.) • Want to manually trigger a sync outside the scheduled interval • Verifying that a data connection works after setup RETURNS: Connection ID, sync status, source name NOTE: The sync runs asynchronously via Airbyte. Use livedata_source_status to check progress. REQUIRES: connectionId (UUID of the Airbyte connection) RELATED: • livedata_list_sources: Find connection IDs • livedata_source_status: Check sync progress • livedata_query: Query synced data EXAMPLE: "Refresh the Stripe data" → this tool
| Scope | mcp.write |
| Read-only | No |
| Destructive | Yes |
| Idempotent | No |
Parameters
| Parameter | Type | Required | Description |
|---|---|---|---|
connectionId | string (uuid) | Yes | Airbyte connection ID to trigger sync for |
Response
| Field | Type | Description |
|---|---|---|
connectionId | string | |
sourceName | string | |
status | string | |
message | string |
Related tools :
livedata_list_sources,livedata_source_status,livedata_query
Troubleshooting
| Code | Message | Solution |
|---|---|---|
| 404 | Source not found | Check the ID with livedata_list_sources. |
Need help?
Contact us: Support and contact.