Update Bulk Sources

Update tags for multiple sources in bulk.

Supports two modes:

Explicit IDs: Pass a list of source IDs to update
Select all: Set select_all=true with optional filters

PUT/sources/bulk_update

Authorization

AuthorizationBearer token · headerrequired

Request body

requiredapplication/json

idsstring[] | null

List of entity IDs to update

Show properties

Any of:

string[]

Array of string

string

null

null

select_allboolean

If true, select all entities matching the filters

default: false

filtersBulkSelectionFilter | null

Optional filters when using select_all

Show properties

Any of:

BulkSelectionFilter

source_idstring | null

Filter by source ID (for pipelines/destinations)

Show properties

Any of:

string

string

null

null

destination_idstring | null

Filter by destination ID (for pipelines/destinations)

Show properties

Any of:

string

string

null

null

null

null

payloadBulkUpdatePayloadrequired

Payload for bulk tag updates across entity types.

Show properties

tagsstring[]required

Responses

200

Successful Response

any

422

Validation Error

detailValidationError[]

Show properties

Array of ValidationError

locstring | integer[]required

Show properties

Array of string | integer

Any of:

string

string

integer

integer

msgstringrequired

typestringrequired

inputany

ctxobject

Request

curl -X PUT 'https://api.streamkap.com/sources/bulk_update' \
  -H 'Authorization: Bearer YOUR_TOKEN' \
  -H 'Content-Type: application/json' \
  -d '{
  "ids": [
    "string"
  ],
  "select_all": false,
  "filters": {
    "source_id": "string",
    "destination_id": "string"
  },
  "payload": {
    "tags": [
      "string"
    ]
  }
}'

const response = await fetch("https://api.streamkap.com/sources/bulk_update", {
  method: "PUT",
  headers: {
    "Authorization": "Bearer YOUR_TOKEN",
    "Content-Type": "application/json"
  },
  body: "{\n  \"ids\": [\n    \"string\"\n  ],\n  \"select_all\": false,\n  \"filters\": {\n    \"source_id\": \"string\",\n    \"destination_id\": \"string\"\n  },\n  \"payload\": {\n    \"tags\": [\n      \"string\"\n    ]\n  }\n}"
});

import requests

response = requests.put(
    "https://api.streamkap.com/sources/bulk_update",
    headers={
        "Authorization": "Bearer YOUR_TOKEN",
        "Content-Type": "application/json"
    },
    data="{\n  \"ids\": [\n    \"string\"\n  ],\n  \"select_all\": false,\n  \"filters\": {\n    \"source_id\": \"string\",\n    \"destination_id\": \"string\"\n  },\n  \"payload\": {\n    \"tags\": [\n      \"string\"\n    ]\n  }\n}",
)

Response

Successful Response

{
  "detail": [
    {
      "loc": [
        "string"
      ],
      "msg": "string",
      "type": "string",
      "input": null,
      "ctx": {}
    }
  ]
}