Couchbase

import os

from unstructured_client import UnstructuredClient
from unstructured_client.models.operations import CreateSourceRequest
from unstructured_client.models.shared import CreateSourceConnector

with UnstructuredClient(api_key_auth=os.getenv("UNSTRUCTURED_API_KEY")) as client:
    response = client.sources.create_source(
        request=CreateSourceRequest(
            create_source_connector=CreateSourceConnector(
                name="<name>",
                type="couchbase",
                config={
                    "username": "<username>",
                    "bucket": "<bucket>",
                    "connection_string": "<connection-string>",
                    "scope": "<scope>",
                    "collection": "<collection>",
                    "password": "<password>",
                    "batch_size": <batch-size>,
                    "collection_id": "<collection-id>"
                }
            )
        )
    )

    print(response.source_connector_information)

curl --request 'POST' --location \
"$UNSTRUCTURED_API_URL/sources" \
--header 'accept: application/json' \
--header "unstructured-api-key: $UNSTRUCTURED_API_KEY" \
--header 'content-type: application/json' \
--data \
'{
    "name": "<name>",
    "type": "couchbase",
    "config": {
        "username": "<username>",
        "bucket": "<bucket>",
        "connection_string": "<connection-string>",
        "scope": "<scope>",
        "collection": "<collection>",
        "password": "<password>",
        "batch_size": <batch-size>,
        "collection_id": "<collection-id>"
    }
}'