Rest API

Run a statement

POSThttps://api.deltastream.io/run-statement

Body

multipart/form-data

orgIDstring

databaseNamestring

schemaNamestring

storeNamestring

statementstring

attachmentarray of string (binary)

Response

2004004015XX

Success

Body

application/jsonapplication/yaml

idstring

secretstring

dataarray of object

actionenum

unknowncreateupdatedropselect

targetenum

organizationstoredatabaseschemaqueryinteractive-queryrelationdescriptor-sourcetopicfunction-sourcefunctionsandboxapi-tokenschema-registryrolesprivilege-grantsrole-grantsorg-invitationsuser-invitationsconnector

Request

JavaScriptCurlPython

const response = await fetch('https://api.deltastream.io/run-statement', {
    method: 'POST',
    headers: {
      "Content-Type": "multipart/form-data"
    },
    body: JSON.stringify({}),
});
const data = await response.json();

Response

2004004015XX

[
  {
    "id": "text",
    "secret": "text",
    "data": [],
    "action": "unknown",
    "target": "organization"
  }
]

Copy a resource

GEThttps://api.deltastream.io/copy/{resource_type}/{org_id}/{resource_name}

Path parameters

resource_type*enum

function_sourcedescriptor_source

org_id*string

resource_name*string

Response

2004004015XX

Success

Body

application/octet-stream

string (bytes)

Request

JavaScriptCurlPython

const response = await fetch('https://api.deltastream.io/copy/{resource_type}/{org_id}/{resource_name}', {
    method: 'GET',
    headers: {},
});
const data = await response.json();

Response

2004004015XX

text

Returns the server version

GEThttps://api.deltastream.io/version

Response

2004015XX

server version

Body

application/jsonapplication/yaml

major*integer

minor*integer

patch*integer

Request

JavaScriptCurlPython

const response = await fetch('https://api.deltastream.io/version', {
    method: 'GET',
    headers: {},
});
const data = await response.json();

Response

2004015XX

{
  "major": 0,
  "minor": 0,
  "patch": 0
}