Create a stream trigger

Creates a new stream trigger for data processing and routing. A stream trigger connects a data source to a target, enabling real-time data flow between components.

Usage Notes:

• The system automatically creates necessary import/export pairs
• Stream triggers define both source and target configurations
• The source configuration specifies where data originates
• The target configuration specifies where data should be delivered
• Response types can be Singleton (single response), Stream (continuous), or Chunked (paginated)
• Source and target types determine how data flows through the system
• The trigger is active immediately after creation
• Both synchronous and asynchronous data processing patterns are supported

POST /trigger/stream

Create a stream trigger

cURL

curl --request POST \
  --url https://api.quiva.ai/trigger/stream \
  --header 'Authorization: Bearer <token>' \
  --header 'Content-Type: application/json' \
  --data '
{
  "name": "my-stream-trigger",
  "collection": "my-collection",
  "description": "Stream data processing trigger",
  "trigger_type": "stream",
  "source": {
    "subject": "ms.data.source",
    "type": "stream",
    "response_type": "Stream"
  },
  "target": {
    "subject": "ms.data.target",
    "account": "account_identifier",
    "type": "stream"
  }
}
'

201

{
  "body": {
    "name": "my-stream-trigger",
    "collection": "my-collection",
    "description": "Stream data processing trigger",
    "source": {
      "subject": "ms.data.source",
      "type": "stream",
      "response_type": "Stream"
    },
    "target": {
      "subject": "ms.data.target",
      "account": "account_identifier",
      "type": "stream"
    },
    "stream": "quiva-trigger-config",
    "subject": "ms.trigger.stream.my-stream-trigger",
    "trigger_type": "stream",
    "type": "created"
  },
  "status_code": 201
}

Authorizations

Authorization · string · header · required

JWT token for authentication. Required for all API operations to verify identity and access permissions.

Body

application/json

name · string · required

Unique name identifier for the trigger. Used to construct the trigger's topic and subject.

Example:

"my-stream-trigger"

trigger_type · enum<string> · required

Must be 'stream' for this endpoint. Determines the trigger's behavior and available properties.

Available options: stream

Example:

"stream"

source · object · required

Show child attributes

target · object · required

Show child attributes

collection · string

Logical grouping the trigger belongs to. Used for organizing and filtering triggers.

Example:

"my-collection"

description · string

Human-readable description explaining the trigger's purpose and function.

Example:

"Stream data processing trigger"

Response

201

application/json

Stream trigger created successfully

body · object

Show child attributes

status_code · integer

HTTP status code indicating the result of the operation.

Example:

201