Retrieve a Stream execution

Import data into a DataSet in your Domo instance. This request will replace the data currently in the DataSet.

Known Limitation

The only supported content type is currently CSV format.

Best Practice

To upload data in CSV format, the Domo specification used for representing data grids in CSV format closely follows the RFC standard for CSV (RFC-4180). For more details on correct CSV formatting, click here.

GET /v1/streams/{STREAM_ID}/executions/{EXECUTION_ID}

Retrieve a Stream execution

cURL

curl --request GET \
  --url https://api.domo.com/v1/streams/{STREAM_ID}/executions/{EXECUTION_ID} \
  --header 'Authorization: Bearer <token>'

import requests

url = "https://api.domo.com/v1/streams/{STREAM_ID}/executions/{EXECUTION_ID}"

headers = {"Authorization": "Bearer <token>"}

response = requests.get(url, headers=headers)

print(response.text)

const options = {method: 'GET', headers: {Authorization: 'Bearer <token>'}};

fetch('https://api.domo.com/v1/streams/{STREAM_ID}/executions/{EXECUTION_ID}', options)
  .then(res => res.json())
  .then(res => console.log(res))
  .catch(err => console.error(err));

<?php

$curl = curl_init();

curl_setopt_array($curl, [
  CURLOPT_URL => "https://api.domo.com/v1/streams/{STREAM_ID}/executions/{EXECUTION_ID}",
  CURLOPT_RETURNTRANSFER => true,
  CURLOPT_ENCODING => "",
  CURLOPT_MAXREDIRS => 10,
  CURLOPT_TIMEOUT => 30,
  CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  CURLOPT_CUSTOMREQUEST => "GET",
  CURLOPT_HTTPHEADER => [
    "Authorization: Bearer <token>"
  ],
]);

$response = curl_exec($curl);
$err = curl_error($curl);

curl_close($curl);

if ($err) {
  echo "cURL Error #:" . $err;
} else {
  echo $response;
}

package main

import (
	"fmt"
	"net/http"
	"io"
)

func main() {

	url := "https://api.domo.com/v1/streams/{STREAM_ID}/executions/{EXECUTION_ID}"

	req, _ := http.NewRequest("GET", url, nil)

	req.Header.Add("Authorization", "Bearer <token>")

	res, _ := http.DefaultClient.Do(req)

	defer res.Body.Close()
	body, _ := io.ReadAll(res.Body)

	fmt.Println(string(body))

}

HttpResponse<String> response = Unirest.get("https://api.domo.com/v1/streams/{STREAM_ID}/executions/{EXECUTION_ID}")
  .header("Authorization", "Bearer <token>")
  .asString();

require 'uri'
require 'net/http'

url = URI("https://api.domo.com/v1/streams/{STREAM_ID}/executions/{EXECUTION_ID}")

http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true

request = Net::HTTP::Get.new(url)
request["Authorization"] = 'Bearer <token>'

response = http.request(request)
puts response.read_body

200

{
  "id": 1,
  "startedAt": "2016-05-26T22:20:21Z",
  "currentState": "ACTIVE",
  "createdAt": "2016-05-26T22:20:21Z",
  "modifiedAt": "2016-05-26T22:20:21Z"
}

Authorizations

Authorization · string · header · required

Bearer authentication header of the form Bearer <token>, where <token> is your auth token.

Path Parameters

STREAM_ID · number · required

The ID of the Stream of data being imported into a DataSet

EXECUTION_ID · number · required

The ID of the Stream execution within the Stream

Response

200 - application/json

Returns a subset fields of a Stream's object.

id · integer

startedAt · string

currentState · string

createdAt · string

modifiedAt · string