# Discover streams

Discover the available data streams for a configured source.

Returns the list of streams and their properties (sync modes, cursor fields, primary keys) for a given source.

#### Path Parameters

**`organization_id`** string required

The unique identifier of the organization (format: `org_*`).

#### Query Parameters

**`source_id`** string required

The source ID to discover streams for.

## Returns

A list of stream property objects, each containing `stream_name`, `sync_modes`, `default_cursor_field`, `source_defined_primary_key`, and `property_fields`.

Request

```bash cURL
curl "https://api.aitronos.com/v1/organizations/org_xyz789/knowledge/connectors/streams?source_id=src_abc123" \
  -H "Authorization: Bearer $ACCESS_TOKEN"
```


```python Python SDK
from aitronos import Aitronos

client = Aitronos(api_key="your-api-key")

streams = client.knowledge_connectors.discover_streams(
    organization_id="org_xyz789",
    source_id="src_abc123",
)
print(streams)
```


```python Python
import requests

org_id = "org_xyz789"
url = f"https://api.aitronos.com/v1/organizations/{org_id}/knowledge/connectors/streams"
headers = {"Authorization": "Bearer YOUR_ACCESS_TOKEN"}
params = {"source_id": "src_abc123"}

response = requests.get(url, headers=headers, params=params)
print(response.json())
```


```javascript JavaScript
const response = await fetch(
  "https://api.aitronos.com/v1/organizations/org_xyz789/knowledge/connectors/streams?source_id=src_abc123",
  {
    headers: { Authorization: "Bearer YOUR_ACCESS_TOKEN" },
  }
);
const data = await response.json();
console.log(data);
```

Response

```json 200 OK
{
  "data": [
    {
      "stream_name": "users",
      "sync_modes": ["full_refresh", "incremental"],
      "default_cursor_field": ["updated_at"],
      "source_defined_primary_key": [["id"]],
      "property_fields": [["id"], ["name"], ["email"], ["updated_at"]]
    },
    {
      "stream_name": "orders",
      "sync_modes": ["full_refresh"],
      "default_cursor_field": [],
      "source_defined_primary_key": [["order_id"]],
      "property_fields": [["order_id"], ["amount"], ["status"]]
    }
  ]
}
```


```json 4xx Error
{
  "success": false,
  "error": {
    "code": "CONNECTOR_SOURCE_NOT_FOUND",
    "message": "The requested source was not found.",
    "type": "client_error",
    "status": 404,
    "details": {},
    "trace_id": "abc-123-def",
    "timestamp": "2025-12-22T15:30:00Z"
  }
}
```

## Related Resources

- [Sources](/docs/api-reference/knowledge-connectors/sources)
- [Source Testing](/docs/api-reference/knowledge-connectors/source-testing)
- [Source Definitions](/docs/api-reference/knowledge-connectors/source-definitions)