Schema Detection

Schema detection and drift tracking endpoints

List organization schema change events

GET

https://app.monad.com/api

/v3/{organization_id}/schema_detection/events

Authorization (header)

x-api-key (header)

List schema drift events (new field / type change) across every pipeline and edge in the organization, newest first, with offset pagination. Optionally bounded to events after from.

List organization schema change events › path Parameters

organization_id

string · required

Organization ID

List organization schema change events › query Parameters

limit

integer

Page size (default 10)

offset

integer

Row offset for pagination (default 0)

from

string

Only events strictly after this RFC3339 timestamp

List organization schema change events › Responses

One page of schema change events

models.SchemaHistoryList

github_com_monad-inc_core_pkg_types_models.Pagination

Pagination metadata.

models.SchemaHistory[]

GET/v3/{organization_id}/schema_detection/events

curl https://app.monad.com/api/v3/:organization_id/schema_detection/events \
  --header 'Authorization: <api-key>'

Example Responses

{
  "pagination": {
    "limit": 0,
    "offset": 0,
    "total": 0
  },
  "schema_history": [
    {
      "created_at": "created_at",
      "edge_id": "edge_id",
      "event_tags": [
        "string"
      ],
      "from_node_name": "from_node_name",
      "id": "id",
      "organization_id": "organization_id",
      "pipeline_id": "pipeline_id",
      "pipeline_name": "pipeline_name",
      "schema": {
        "key": {
          "types": {
            "key": {
              "count": 0,
              "first_seen": 0,
              "last_seen": 0
            }
          }
        }
      },
      "to_node_name": "to_node_name"
    }
  ]
}

json

application/json

List pipelines with tracked schema

GET

https://app.monad.com/api

/v3/{organization_id}/schema_detection/pipelines

Authorization (header)

x-api-key (header)

List the id and name of every pipeline in the organization that has any edge with a tracked schema state, for populating pipeline pickers.

List pipelines with tracked schema › path Parameters

organization_id

string · required

Organization ID

List pipelines with tracked schema › Responses

Pipelines with tracked schema

models.PipelineWithSchemaTracked[]

models.PipelineWithSchemaTracked

id

string

name

string

Schema tracking summary

GET

https://app.monad.com/api

/v3/{organization_id}/schema_detection/summary

Authorization (header)

x-api-key (header)

Counts of the organization's tracked edges by mode (learning / detection).

Schema tracking summary › path Parameters

organization_id

string · required

Organization ID

Schema tracking summary › Responses

Learning / detection counts

models.SchemaTrackingSummary

in_detection

integer

in_learning

integer

Conditions Alerts