conduit_ingest
Send events to Conduit MCP data streams with automatic schema detection and evolution for real-time integration between services and AI agents.
Instructions
Send one or more events (JSON objects) to a stream. Schema is auto-detected and evolves.
Input Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
| stream | Yes | Stream name | |
| events | Yes | Event(s) to ingest |
Implementation Reference
- src/index.ts:308-316 (handler)The request handler logic for 'conduit_ingest' which formats the payload and POSTs it to the Conduit API.
case 'conduit_ingest': { const prefix = await getTenantPrefix(); const events = Array.isArray(args!.events) ? args!.events : [args!.events]; const data = await api(`/v1/${prefix}/${args!.stream}`, { method: 'POST', body: JSON.stringify(events.length === 1 ? events[0] : events), }); return { content: [{ type: 'text', text: JSON.stringify(data, null, 2) }] }; } - src/index.ts:118-134 (schema)The tool definition and input schema registration for 'conduit_ingest'.
name: 'conduit_ingest', description: 'Send one or more events (JSON objects) to a stream. Schema is auto-detected and evolves.', inputSchema: { type: 'object' as const, properties: { stream: { type: 'string', description: 'Stream name' }, events: { oneOf: [ { type: 'object', description: 'Single event' }, { type: 'array', items: { type: 'object' }, description: 'Batch of events' }, ], description: 'Event(s) to ingest', }, }, required: ['stream', 'events'], }, },