Data Catalog Entries

Get Data For Data Catalog Entry

Imports the data from a data catalog entry into MindBridge, asynchronously creating a new data table. The request can specify which columns to import, and can optionally provide a filter, a limit, an offset, and a set of sort properties to be applied when importing the data.

The data catalog entry’s source will be updated and validated before importing any data to ensure that the schema in the data catalog entry and the request are valid. If either the data catalog entry or the request are not valid, then the request will fail.

Unlike the Validate endpoint, for CONNECTION sources this endpoint does not need to call the Get Tables For Connection endpoint, as the underlying connection table will be refreshed directly before validation. Note that the data catalog entry’s own column definitions are not automatically updated from the connection — they reflect the schema at the time the entry was created.

Permissions

api.data-catalog-entries.read
api.data-tables.write

POST

data-catalog-entries

{dataCatalogEntryId}

get-data

Get Data For Data Catalog Entry

curl --request POST \
  --url https://{tenant}.mindbridge.ai/api/v1/data-catalog-entries/{dataCatalogEntryId}/get-data \
  --header 'Authorization: Bearer <token>' \
  --header 'Content-Type: application/json' \
  --data '
{
  "engagementId": "<string>",
  "columns": [
    "<string>"
  ],
  "filter": {},
  "limit": 1,
  "offset": 1,
  "sortProperties": [
    {
      "column": "<string>"
    }
  ]
}
'

import requests

url = "https://{tenant}.mindbridge.ai/api/v1/data-catalog-entries/{dataCatalogEntryId}/get-data"

payload = {
    "engagementId": "<string>",
    "columns": ["<string>"],
    "filter": {},
    "limit": 1,
    "offset": 1,
    "sortProperties": [{ "column": "<string>" }]
}
headers = {
    "Authorization": "Bearer <token>",
    "Content-Type": "application/json"
}

response = requests.post(url, json=payload, headers=headers)

print(response.text)

const options = {
  method: 'POST',
  headers: {Authorization: 'Bearer <token>', 'Content-Type': 'application/json'},
  body: JSON.stringify({
    engagementId: '<string>',
    columns: ['<string>'],
    filter: {},
    limit: 1,
    offset: 1,
    sortProperties: [{column: '<string>'}]
  })
};

fetch('https://{tenant}.mindbridge.ai/api/v1/data-catalog-entries/{dataCatalogEntryId}/get-data', 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://{tenant}.mindbridge.ai/api/v1/data-catalog-entries/{dataCatalogEntryId}/get-data",
  CURLOPT_RETURNTRANSFER => true,
  CURLOPT_ENCODING => "",
  CURLOPT_MAXREDIRS => 10,
  CURLOPT_TIMEOUT => 30,
  CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  CURLOPT_CUSTOMREQUEST => "POST",
  CURLOPT_POSTFIELDS => json_encode([
    'engagementId' => '<string>',
    'columns' => [
        '<string>'
    ],
    'filter' => [
        
    ],
    'limit' => 1,
    'offset' => 1,
    'sortProperties' => [
        [
                'column' => '<string>'
        ]
    ]
  ]),
  CURLOPT_HTTPHEADER => [
    "Authorization: Bearer <token>",
    "Content-Type: application/json"
  ],
]);

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

curl_close($curl);

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

package main

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

func main() {

	url := "https://{tenant}.mindbridge.ai/api/v1/data-catalog-entries/{dataCatalogEntryId}/get-data"

	payload := strings.NewReader("{\n  \"engagementId\": \"<string>\",\n  \"columns\": [\n    \"<string>\"\n  ],\n  \"filter\": {},\n  \"limit\": 1,\n  \"offset\": 1,\n  \"sortProperties\": [\n    {\n      \"column\": \"<string>\"\n    }\n  ]\n}")

	req, _ := http.NewRequest("POST", url, payload)

	req.Header.Add("Authorization", "Bearer <token>")
	req.Header.Add("Content-Type", "application/json")

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

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

	fmt.Println(string(body))

}

HttpResponse<String> response = Unirest.post("https://{tenant}.mindbridge.ai/api/v1/data-catalog-entries/{dataCatalogEntryId}/get-data")
  .header("Authorization", "Bearer <token>")
  .header("Content-Type", "application/json")
  .body("{\n  \"engagementId\": \"<string>\",\n  \"columns\": [\n    \"<string>\"\n  ],\n  \"filter\": {},\n  \"limit\": 1,\n  \"offset\": 1,\n  \"sortProperties\": [\n    {\n      \"column\": \"<string>\"\n    }\n  ]\n}")
  .asString();

require 'uri'
require 'net/http'

url = URI("https://{tenant}.mindbridge.ai/api/v1/data-catalog-entries/{dataCatalogEntryId}/get-data")

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

request = Net::HTTP::Post.new(url)
request["Authorization"] = 'Bearer <token>'
request["Content-Type"] = 'application/json'
request.body = "{\n  \"engagementId\": \"<string>\",\n  \"columns\": [\n    \"<string>\"\n  ],\n  \"filter\": {},\n  \"limit\": 1,\n  \"offset\": 1,\n  \"sortProperties\": [\n    {\n      \"column\": \"<string>\"\n    }\n  ]\n}"

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

{
  "id": "<string>",
  "version": 123,
  "creationDate": "2023-11-07T05:31:56Z",
  "lastModifiedDate": "2023-11-07T05:31:56Z",
  "createdUserInfo": {
    "userId": "<string>",
    "userName": "<string>"
  },
  "lastModifiedUserInfo": {
    "userId": "<string>",
    "userName": "<string>"
  },
  "type": "ANALYSIS_RUN",
  "status": "IN_PROGRESS",
  "entityId": "<string>",
  "entityType": "ORGANIZATION",
  "error": "<string>",
  "errorMessage": "<string>"
}

Authorizations

Authorization

string

header

required

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

Path Parameters

dataCatalogEntryId

string

required

Body

application/json

engagementId

string

required

Identifies the engagement that the resulting Data Table will be associated with.

columns

string[]

required

The list of columns to retrieve from the data source.

Minimum array length: 1

filter

object

Optional filter to apply to the data retrieval. If not set, all rows are returned unfiltered.

Show child attributes

limit

integer<int64>

Maximum number of rows to return. If not set, all matching rows are returned.

Required range: x >= 0

offset

integer<int64>

Number of rows to skip before returning results. If not set, results start from the first row.

Required range: x >= 0

sortProperties

Sort Property · object[]

Optional sort specification ordered by precedence. Remotes that support server-side sorting will apply it; remotes that don't will ignore it.

Show child attributes

Response

202 - application/json

Accepted

string

The unique object identifier.

version

integer<int64>

Indicates the data integrity version to ensure data consistency.

creationDate

string<date-time>

The date that the object was originally created.

lastModifiedDate

string<date-time>

The date that the object was last updated or modified.

createdUserInfo

User Info · object

read-only

Details about the user who created the object.

Show child attributes

lastModifiedUserInfo

User Info · object

read-only

Details about the user who last modified or updated the object.

Show child attributes

type

enum<string>

Indicates the type of job being run.

Available options:

ANALYSIS_RUN,

ANALYSIS_SOURCE_INGESTION,

ADMIN_REPORT,

DATA_TABLE_EXPORT,

ANALYSIS_ROLL_FORWARD,

GDPDU_UNPACK_JOB,

ACCOUNT_GROUPING_EXPORT,

ACCOUNT_MAPPING_EXPORT,

DATA_TRANSFORMATION_JOB,

CONNECTION_TEST,

CONNECTION_TABLES,

DATA_TABLE,

DATA_SOURCE_IMPORT,

FILE_MANAGER_TO_DATA_TABLE

status

enum<string>

Indicates the current state of the job.

Available options:

IN_PROGRESS,

COMPLETE,

ERROR

entityId

string

Identifies the entity used in the job.

entityType

enum<string>

Identifies the entity type used in the job.

Available options:

ORGANIZATION,

ENGAGEMENT,

ANALYSIS,

ANALYSIS_RESULT,

ANALYSIS_SOURCE,

FILE_RESULT,

GDPDU_UNPACK_JOB,

ACCOUNT_GROUPING,

ENGAGEMENT_ACCOUNT_GROUPING,

FILE_MANAGER_FILE,

CONNECTION_TEST_RESULT,

CONNECTION_TABLES_RESULT,

DATA_TABLE,

DATA_SOURCE_IMPORT_TASK

error

string

The reason why the async job failed.

errorMessage

string

⌘I

Get Data For Data Catalog Entry

curl --request POST \
  --url https://{tenant}.mindbridge.ai/api/v1/data-catalog-entries/{dataCatalogEntryId}/get-data \
  --header 'Authorization: Bearer <token>' \
  --header 'Content-Type: application/json' \
  --data '
{
  "engagementId": "<string>",
  "columns": [
    "<string>"
  ],
  "filter": {},
  "limit": 1,
  "offset": 1,
  "sortProperties": [
    {
      "column": "<string>"
    }
  ]
}
'

import requests

url = "https://{tenant}.mindbridge.ai/api/v1/data-catalog-entries/{dataCatalogEntryId}/get-data"

payload = {
    "engagementId": "<string>",
    "columns": ["<string>"],
    "filter": {},
    "limit": 1,
    "offset": 1,
    "sortProperties": [{ "column": "<string>" }]
}
headers = {
    "Authorization": "Bearer <token>",
    "Content-Type": "application/json"
}

response = requests.post(url, json=payload, headers=headers)

print(response.text)

const options = {
  method: 'POST',
  headers: {Authorization: 'Bearer <token>', 'Content-Type': 'application/json'},
  body: JSON.stringify({
    engagementId: '<string>',
    columns: ['<string>'],
    filter: {},
    limit: 1,
    offset: 1,
    sortProperties: [{column: '<string>'}]
  })
};

fetch('https://{tenant}.mindbridge.ai/api/v1/data-catalog-entries/{dataCatalogEntryId}/get-data', 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://{tenant}.mindbridge.ai/api/v1/data-catalog-entries/{dataCatalogEntryId}/get-data",
  CURLOPT_RETURNTRANSFER => true,
  CURLOPT_ENCODING => "",
  CURLOPT_MAXREDIRS => 10,
  CURLOPT_TIMEOUT => 30,
  CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  CURLOPT_CUSTOMREQUEST => "POST",
  CURLOPT_POSTFIELDS => json_encode([
    'engagementId' => '<string>',
    'columns' => [
        '<string>'
    ],
    'filter' => [
        
    ],
    'limit' => 1,
    'offset' => 1,
    'sortProperties' => [
        [
                'column' => '<string>'
        ]
    ]
  ]),
  CURLOPT_HTTPHEADER => [
    "Authorization: Bearer <token>",
    "Content-Type: application/json"
  ],
]);

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

curl_close($curl);

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

package main

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

func main() {

	url := "https://{tenant}.mindbridge.ai/api/v1/data-catalog-entries/{dataCatalogEntryId}/get-data"

	payload := strings.NewReader("{\n  \"engagementId\": \"<string>\",\n  \"columns\": [\n    \"<string>\"\n  ],\n  \"filter\": {},\n  \"limit\": 1,\n  \"offset\": 1,\n  \"sortProperties\": [\n    {\n      \"column\": \"<string>\"\n    }\n  ]\n}")

	req, _ := http.NewRequest("POST", url, payload)

	req.Header.Add("Authorization", "Bearer <token>")
	req.Header.Add("Content-Type", "application/json")

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

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

	fmt.Println(string(body))

}

HttpResponse<String> response = Unirest.post("https://{tenant}.mindbridge.ai/api/v1/data-catalog-entries/{dataCatalogEntryId}/get-data")
  .header("Authorization", "Bearer <token>")
  .header("Content-Type", "application/json")
  .body("{\n  \"engagementId\": \"<string>\",\n  \"columns\": [\n    \"<string>\"\n  ],\n  \"filter\": {},\n  \"limit\": 1,\n  \"offset\": 1,\n  \"sortProperties\": [\n    {\n      \"column\": \"<string>\"\n    }\n  ]\n}")
  .asString();

require 'uri'
require 'net/http'

url = URI("https://{tenant}.mindbridge.ai/api/v1/data-catalog-entries/{dataCatalogEntryId}/get-data")

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

request = Net::HTTP::Post.new(url)
request["Authorization"] = 'Bearer <token>'
request["Content-Type"] = 'application/json'
request.body = "{\n  \"engagementId\": \"<string>\",\n  \"columns\": [\n    \"<string>\"\n  ],\n  \"filter\": {},\n  \"limit\": 1,\n  \"offset\": 1,\n  \"sortProperties\": [\n    {\n      \"column\": \"<string>\"\n    }\n  ]\n}"

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

{
  "id": "<string>",
  "version": 123,
  "creationDate": "2023-11-07T05:31:56Z",
  "lastModifiedDate": "2023-11-07T05:31:56Z",
  "createdUserInfo": {
    "userId": "<string>",
    "userName": "<string>"
  },
  "lastModifiedUserInfo": {
    "userId": "<string>",
    "userName": "<string>"
  },
  "type": "ANALYSIS_RUN",
  "status": "IN_PROGRESS",
  "entityId": "<string>",
  "entityType": "ORGANIZATION",
  "error": "<string>",
  "errorMessage": "<string>"
}

Overview

Details

Webhooks

API reference

Get Data For Data Catalog Entry

Permissions

Authorizations

Path Parameters

Body

Response