Skip to content
/
Upsert pipeline data
Last updated
🔨 In Development — This section is still being developed and may change.
POST/v1/pipeline/upsert

Accept data from data pipeline platforms for processing.

Validates payload and returns acknowledgment. Future phases will process data, generate embeddings, and store in vector store.

Authentication: Dedicated Pipeline Connector API Key required (X-API-Key header)

Rate Limits

  • 100 requests per minute per organization
  • Maximum 1000 records per request

Returns

Returns a success response with processing results including processed count, failed count, request ID, and processing time.

cURL
curl -X POST https://api.aitronos.com/v1/pipeline/upsert \
  -H "X-API-Key: $PIPELINE_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "records": [
      {
        "id": "task_123",
        "namespace": "clickup",
        "data": {"title": "Task 1"},
        "organization_id": "org_abc123"
      }
    ]
  }'

Response

{
  "success": true,
  "message": "Batch received successfully",
  "processed_count": 1,
  "failed_count": 0,
  "request_id": "req_abc123def456",
  "processing_time_ms": 145,
  "summary": {
    "namespaces": {"clickup": 1},
    "source_systems": {"airbyte": 1},
    "actions": {"upsert": 1}
  }
}

Error Responses

400 Bad Request

{
  "success": false,
  "error": {
    "code": "BATCH_SIZE_EXCEEDED",
    "message": "Batch size exceeds maximum allowed (1000)",
    "status": 400
  }
}

401 Unauthorized

{
  "success": false,
  "error": {
    "code": "INVALID_API_KEY",
    "message": "Invalid pipeline connector API key",
    "status": 401
  }
}
Previous page
Next page