Bulk Update Documents

curl --request PATCH \
  --url https://api.mixpeek.com/v1/collections/{collection_identifier}/documents/bulk \
  --header 'Authorization: Bearer <token>' \
  --header 'Content-Type: application/json' \
  --data '
{
  "update_data": {},
  "filters": {
    "AND": [
      {
        "field": "metadata.status",
        "operator": "eq",
        "value": "pending"
      }
    ]
  }
}
'

import requests

url = "https://api.mixpeek.com/v1/collections/{collection_identifier}/documents/bulk"

payload = {
    "update_data": {},
    "filters": { "AND": [
            {
                "field": "metadata.status",
                "operator": "eq",
                "value": "pending"
            }
        ] }
}
headers = {
    "Authorization": "Bearer <token>",
    "Content-Type": "application/json"
}

response = requests.patch(url, json=payload, headers=headers)

print(response.text)

const options = {
  method: 'PATCH',
  headers: {Authorization: 'Bearer <token>', 'Content-Type': 'application/json'},
  body: JSON.stringify({
    update_data: {},
    filters: {AND: [{field: 'metadata.status', operator: 'eq', value: 'pending'}]}
  })
};

fetch('https://api.mixpeek.com/v1/collections/{collection_identifier}/documents/bulk', options)
  .then(res => res.json())
  .then(res => console.log(res))
  .catch(err => console.error(err));

<?php

$curl = curl_init();

curl_setopt_array($curl, [
  CURLOPT_URL => "https://api.mixpeek.com/v1/collections/{collection_identifier}/documents/bulk",
  CURLOPT_RETURNTRANSFER => true,
  CURLOPT_ENCODING => "",
  CURLOPT_MAXREDIRS => 10,
  CURLOPT_TIMEOUT => 30,
  CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  CURLOPT_CUSTOMREQUEST => "PATCH",
  CURLOPT_POSTFIELDS => json_encode([
    'update_data' => [
        
    ],
    'filters' => [
        'AND' => [
                [
                                'field' => 'metadata.status',
                                'operator' => 'eq',
                                'value' => 'pending'
                ]
        ]
    ]
  ]),
  CURLOPT_HTTPHEADER => [
    "Authorization: Bearer <token>",
    "Content-Type: application/json"
  ],
]);

$response = curl_exec($curl);
$err = curl_error($curl);

curl_close($curl);

if ($err) {
  echo "cURL Error #:" . $err;
} else {
  echo $response;
}

package main

import (
	"fmt"
	"strings"
	"net/http"
	"io"
)

func main() {

	url := "https://api.mixpeek.com/v1/collections/{collection_identifier}/documents/bulk"

	payload := strings.NewReader("{\n  \"update_data\": {},\n  \"filters\": {\n    \"AND\": [\n      {\n        \"field\": \"metadata.status\",\n        \"operator\": \"eq\",\n        \"value\": \"pending\"\n      }\n    ]\n  }\n}")

	req, _ := http.NewRequest("PATCH", url, payload)

	req.Header.Add("Authorization", "Bearer <token>")
	req.Header.Add("Content-Type", "application/json")

	res, _ := http.DefaultClient.Do(req)

	defer res.Body.Close()
	body, _ := io.ReadAll(res.Body)

	fmt.Println(string(body))

}

HttpResponse<String> response = Unirest.patch("https://api.mixpeek.com/v1/collections/{collection_identifier}/documents/bulk")
  .header("Authorization", "Bearer <token>")
  .header("Content-Type", "application/json")
  .body("{\n  \"update_data\": {},\n  \"filters\": {\n    \"AND\": [\n      {\n        \"field\": \"metadata.status\",\n        \"operator\": \"eq\",\n        \"value\": \"pending\"\n      }\n    ]\n  }\n}")
  .asString();

require 'uri'
require 'net/http'

url = URI("https://api.mixpeek.com/v1/collections/{collection_identifier}/documents/bulk")

http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true

request = Net::HTTP::Patch.new(url)
request["Authorization"] = 'Bearer <token>'
request["Content-Type"] = 'application/json'
request.body = "{\n  \"update_data\": {},\n  \"filters\": {\n    \"AND\": [\n      {\n        \"field\": \"metadata.status\",\n        \"operator\": \"eq\",\n        \"value\": \"pending\"\n      }\n    ]\n  }\n}"

response = http.request(request)
puts response.read_body

{
  "updated_count": 123,
  "message": "Documents updated successfully"
}

{
  "status": 123,
  "error": {
    "message": "<string>",
    "type": "<string>",
    "code": "<string>",
    "details": {}
  },
  "success": false
}

{
  "status": 123,
  "error": {
    "message": "<string>",
    "type": "<string>",
    "code": "<string>",
    "details": {}
  },
  "success": false
}

{
  "status": 123,
  "error": {
    "message": "<string>",
    "type": "<string>",
    "code": "<string>",
    "details": {}
  },
  "success": false
}

{
  "status": 123,
  "error": {
    "message": "<string>",
    "type": "<string>",
    "code": "<string>",
    "details": {}
  },
  "success": false
}

{
  "detail": [
    {
      "loc": [
        "<string>"
      ],
      "msg": "<string>",
      "type": "<string>",
      "input": "<unknown>",
      "ctx": {}
    }
  ]
}

{
  "status": 123,
  "error": {
    "message": "<string>",
    "type": "<string>",
    "code": "<string>",
    "details": {}
  },
  "success": false
}

PATCH

collections

{collection_identifier}

documents

bulk

Bulk Update Documents

curl --request PATCH \
  --url https://api.mixpeek.com/v1/collections/{collection_identifier}/documents/bulk \
  --header 'Authorization: Bearer <token>' \
  --header 'Content-Type: application/json' \
  --data '
{
  "update_data": {},
  "filters": {
    "AND": [
      {
        "field": "metadata.status",
        "operator": "eq",
        "value": "pending"
      }
    ]
  }
}
'

import requests

url = "https://api.mixpeek.com/v1/collections/{collection_identifier}/documents/bulk"

payload = {
    "update_data": {},
    "filters": { "AND": [
            {
                "field": "metadata.status",
                "operator": "eq",
                "value": "pending"
            }
        ] }
}
headers = {
    "Authorization": "Bearer <token>",
    "Content-Type": "application/json"
}

response = requests.patch(url, json=payload, headers=headers)

print(response.text)

const options = {
  method: 'PATCH',
  headers: {Authorization: 'Bearer <token>', 'Content-Type': 'application/json'},
  body: JSON.stringify({
    update_data: {},
    filters: {AND: [{field: 'metadata.status', operator: 'eq', value: 'pending'}]}
  })
};

fetch('https://api.mixpeek.com/v1/collections/{collection_identifier}/documents/bulk', options)
  .then(res => res.json())
  .then(res => console.log(res))
  .catch(err => console.error(err));

<?php

$curl = curl_init();

curl_setopt_array($curl, [
  CURLOPT_URL => "https://api.mixpeek.com/v1/collections/{collection_identifier}/documents/bulk",
  CURLOPT_RETURNTRANSFER => true,
  CURLOPT_ENCODING => "",
  CURLOPT_MAXREDIRS => 10,
  CURLOPT_TIMEOUT => 30,
  CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  CURLOPT_CUSTOMREQUEST => "PATCH",
  CURLOPT_POSTFIELDS => json_encode([
    'update_data' => [
        
    ],
    'filters' => [
        'AND' => [
                [
                                'field' => 'metadata.status',
                                'operator' => 'eq',
                                'value' => 'pending'
                ]
        ]
    ]
  ]),
  CURLOPT_HTTPHEADER => [
    "Authorization: Bearer <token>",
    "Content-Type: application/json"
  ],
]);

$response = curl_exec($curl);
$err = curl_error($curl);

curl_close($curl);

if ($err) {
  echo "cURL Error #:" . $err;
} else {
  echo $response;
}

package main

import (
	"fmt"
	"strings"
	"net/http"
	"io"
)

func main() {

	url := "https://api.mixpeek.com/v1/collections/{collection_identifier}/documents/bulk"

	payload := strings.NewReader("{\n  \"update_data\": {},\n  \"filters\": {\n    \"AND\": [\n      {\n        \"field\": \"metadata.status\",\n        \"operator\": \"eq\",\n        \"value\": \"pending\"\n      }\n    ]\n  }\n}")

	req, _ := http.NewRequest("PATCH", url, payload)

	req.Header.Add("Authorization", "Bearer <token>")
	req.Header.Add("Content-Type", "application/json")

	res, _ := http.DefaultClient.Do(req)

	defer res.Body.Close()
	body, _ := io.ReadAll(res.Body)

	fmt.Println(string(body))

}

HttpResponse<String> response = Unirest.patch("https://api.mixpeek.com/v1/collections/{collection_identifier}/documents/bulk")
  .header("Authorization", "Bearer <token>")
  .header("Content-Type", "application/json")
  .body("{\n  \"update_data\": {},\n  \"filters\": {\n    \"AND\": [\n      {\n        \"field\": \"metadata.status\",\n        \"operator\": \"eq\",\n        \"value\": \"pending\"\n      }\n    ]\n  }\n}")
  .asString();

require 'uri'
require 'net/http'

url = URI("https://api.mixpeek.com/v1/collections/{collection_identifier}/documents/bulk")

http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true

request = Net::HTTP::Patch.new(url)
request["Authorization"] = 'Bearer <token>'
request["Content-Type"] = 'application/json'
request.body = "{\n  \"update_data\": {},\n  \"filters\": {\n    \"AND\": [\n      {\n        \"field\": \"metadata.status\",\n        \"operator\": \"eq\",\n        \"value\": \"pending\"\n      }\n    ]\n  }\n}"

response = http.request(request)
puts response.read_body

{
  "updated_count": 123,
  "message": "Documents updated successfully"
}

{
  "status": 123,
  "error": {
    "message": "<string>",
    "type": "<string>",
    "code": "<string>",
    "details": {}
  },
  "success": false
}

{
  "status": 123,
  "error": {
    "message": "<string>",
    "type": "<string>",
    "code": "<string>",
    "details": {}
  },
  "success": false
}

{
  "status": 123,
  "error": {
    "message": "<string>",
    "type": "<string>",
    "code": "<string>",
    "details": {}
  },
  "success": false
}

{
  "status": 123,
  "error": {
    "message": "<string>",
    "type": "<string>",
    "code": "<string>",
    "details": {}
  },
  "success": false
}

{
  "detail": [
    {
      "loc": [
        "<string>"
      ],
      "msg": "<string>",
      "type": "<string>",
      "input": "<unknown>",
      "ctx": {}
    }
  ]
}

{
  "status": 123,
  "error": {
    "message": "<string>",
    "type": "<string>",
    "code": "<string>",
    "details": {}
  },
  "success": false
}

Authorizations

Authorization

string

header

required

Bearer authentication header of the form Bearer <token>, where <token> is your auth token.

Path Parameters

collection_identifier

string

required

The ID of the collection to update documents in.

Body

application/json

Request model for bulk updating documents by filters.

Updates ALL documents matching the provided filters with the SAME update_data. For updating specific documents by ID or different values per document, use BatchUpdateDocumentsRequest.

Use Cases: - Update all pending documents to processed - Update all documents from a specific date range - Apply uniform changes across filtered document sets

Requirements: - update_data: REQUIRED - fields to update on all matching documents - filters: OPTIONAL - if omitted, updates ALL documents in collection

update_data

Update Data · object

required

REQUIRED. Dictionary of field-value pairs to update on ALL matching documents. Can update any document field except vectors (metadata, source_blobs, etc.). All matched documents receive the SAME updates. Example: {'metadata.status': 'processed', 'metadata.reviewed': true}

Examples:

{
  "metadata": { "reviewed": true, "status": "processed" }
}

{ "metadata.processing_complete": true }

filters

LogicalOperator · object | null

OPTIONAL. Filter conditions to match documents for update. If not provided, updates ALL documents in the collection. Uses the logical AND/OR/NOT shape — a list of {field, operator, value} conditions (operators: eq, ne, in, nin, gt, gte, lt, lte, contains, exists, …). The MVS-native {'must': [{'key': ...}]} shape is NOT accepted here. Example: {'AND': [{'field': 'metadata.status', 'operator': 'eq', 'value': 'pending'}]}

Show child attributes

Example:

{
  "AND": [
    {
      "field": "metadata.status",
      "operator": "eq",
      "value": "pending"
    }
  ]
}

Response

Successful Response

Response model for bulk document update operation.

updated_count

integer

required

Number of documents that were updated.

message

string

default:Documents updated successfully

Return distinct values for a single field.Batch Update Documents

Organization

Namespaces

Buckets

Feature Extractors

Batch Queue

Collections

Documents

Retrievers

Taxonomies

Clusters

Triggers

Alerts

Webhooks

Apps

Agent Sessions

Annotations

Templates

Manifest

Discovery

Analytics

Notifications

Tasks

Inference

Resource Search

Pricing

Bulk Update Documents

Authorizations

Path Parameters

Body

Response