div
strong
🔨 In Development
 — This section is still being developed and may change.

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.


```bash 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"
      }
    ]
  }'
```


```python Python
import os
import requests

api_key = os.environ["PIPELINE_API_KEY"]
response = requests.post(
    "https://api.aitronos.com/v1/pipeline/upsert",
    headers={"X-API-Key": api_key},
    json={
        "records": [{
            "id": "task_123",
            "namespace": "clickup",
            "data": {"title": "Task 1"},
            "organization_id": "org_abc123"
        }]
    }
)
result = response.json()
```


```javascript JavaScript
const apiKey = process.env.PIPELINE_API_KEY;
const response = await fetch(
  'https://api.aitronos.com/v1/pipeline/upsert',
  {
    method: 'POST',
    headers: {
      'X-API-Key': apiKey,
      'Content-Type': 'application/json'
    },
    body: JSON.stringify({
      records: [{
        id: 'task_123',
        namespace: 'clickup',
        data: {title: 'Task 1'},
        organization_id: 'org_abc123'
      }]
    })
  }
);
const result = await response.json();
```

## Response


```json
{
  "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


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

### 401 Unauthorized


```json
{
  "success": false,
  "error": {
    "code": "INVALID_API_KEY",
    "message": "Invalid pipeline connector API key",
    "status": 401
  }
}
```