Create Ingestion Source

curl --request POST \
  --url https://statsigapi.net/console/v1/ingestion \
  --header 'Content-Type: application/json' \
  --header 'STATSIG-API-KEY: <api-key>' \
  --data '
{
  "dataset": "Metrics",
  "source_name": "<string>",
  "query": "<string>",
  "use_delta_sharing": true,
  "share": "<string>",
  "schema": "<string>",
  "table": "<string>",
  "enabled": true
}
'

import requests

url = "https://statsigapi.net/console/v1/ingestion"

payload = {
    "dataset": "Metrics",
    "source_name": "<string>",
    "query": "<string>",
    "use_delta_sharing": True,
    "share": "<string>",
    "schema": "<string>",
    "table": "<string>",
    "enabled": True
}
headers = {
    "STATSIG-API-KEY": "<api-key>",
    "Content-Type": "application/json"
}

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

print(response.text)

const options = {
  method: 'POST',
  headers: {'STATSIG-API-KEY': '<api-key>', 'Content-Type': 'application/json'},
  body: JSON.stringify({
    dataset: 'Metrics',
    source_name: '<string>',
    query: '<string>',
    use_delta_sharing: true,
    share: '<string>',
    schema: '<string>',
    table: '<string>',
    enabled: true
  })
};

fetch('https://statsigapi.net/console/v1/ingestion', 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://statsigapi.net/console/v1/ingestion",
  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([
    'dataset' => 'Metrics',
    'source_name' => '<string>',
    'query' => '<string>',
    'use_delta_sharing' => true,
    'share' => '<string>',
    'schema' => '<string>',
    'table' => '<string>',
    'enabled' => true
  ]),
  CURLOPT_HTTPHEADER => [
    "Content-Type: application/json",
    "STATSIG-API-KEY: <api-key>"
  ],
]);

$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://statsigapi.net/console/v1/ingestion"

	payload := strings.NewReader("{\n  \"dataset\": \"Metrics\",\n  \"source_name\": \"<string>\",\n  \"query\": \"<string>\",\n  \"use_delta_sharing\": true,\n  \"share\": \"<string>\",\n  \"schema\": \"<string>\",\n  \"table\": \"<string>\",\n  \"enabled\": true\n}")

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

	req.Header.Add("STATSIG-API-KEY", "<api-key>")
	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://statsigapi.net/console/v1/ingestion")
  .header("STATSIG-API-KEY", "<api-key>")
  .header("Content-Type", "application/json")
  .body("{\n  \"dataset\": \"Metrics\",\n  \"source_name\": \"<string>\",\n  \"query\": \"<string>\",\n  \"use_delta_sharing\": true,\n  \"share\": \"<string>\",\n  \"schema\": \"<string>\",\n  \"table\": \"<string>\",\n  \"enabled\": true\n}")
  .asString();

require 'uri'
require 'net/http'

url = URI("https://statsigapi.net/console/v1/ingestion")

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

request = Net::HTTP::Post.new(url)
request["STATSIG-API-KEY"] = '<api-key>'
request["Content-Type"] = 'application/json'
request.body = "{\n  \"dataset\": \"Metrics\",\n  \"source_name\": \"<string>\",\n  \"query\": \"<string>\",\n  \"use_delta_sharing\": true,\n  \"share\": \"<string>\",\n  \"schema\": \"<string>\",\n  \"table\": \"<string>\",\n  \"enabled\": true\n}"

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

{
  "type": "databricks",
  "dataset": "Metrics",
  "source_name": "ingestion-1",
  "query": "SELECT * FROM TABLE",
  "column_mapping": {
    "unit_id": "string",
    "id_type": "string",
    "dateid": "string",
    "metric_name": "string",
    "metric_value": "string",
    "numerator": "string",
    "denominator": "string"
  },
  "use_delta_sharing": false,
  "share": "string",
  "schema": "string",
  "table": "string",
  "enabled": false
}

POST

console

ingestion

Create Ingestion Source

curl --request POST \
  --url https://statsigapi.net/console/v1/ingestion \
  --header 'Content-Type: application/json' \
  --header 'STATSIG-API-KEY: <api-key>' \
  --data '
{
  "dataset": "Metrics",
  "source_name": "<string>",
  "query": "<string>",
  "use_delta_sharing": true,
  "share": "<string>",
  "schema": "<string>",
  "table": "<string>",
  "enabled": true
}
'

import requests

url = "https://statsigapi.net/console/v1/ingestion"

payload = {
    "dataset": "Metrics",
    "source_name": "<string>",
    "query": "<string>",
    "use_delta_sharing": True,
    "share": "<string>",
    "schema": "<string>",
    "table": "<string>",
    "enabled": True
}
headers = {
    "STATSIG-API-KEY": "<api-key>",
    "Content-Type": "application/json"
}

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

print(response.text)

const options = {
  method: 'POST',
  headers: {'STATSIG-API-KEY': '<api-key>', 'Content-Type': 'application/json'},
  body: JSON.stringify({
    dataset: 'Metrics',
    source_name: '<string>',
    query: '<string>',
    use_delta_sharing: true,
    share: '<string>',
    schema: '<string>',
    table: '<string>',
    enabled: true
  })
};

fetch('https://statsigapi.net/console/v1/ingestion', 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://statsigapi.net/console/v1/ingestion",
  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([
    'dataset' => 'Metrics',
    'source_name' => '<string>',
    'query' => '<string>',
    'use_delta_sharing' => true,
    'share' => '<string>',
    'schema' => '<string>',
    'table' => '<string>',
    'enabled' => true
  ]),
  CURLOPT_HTTPHEADER => [
    "Content-Type: application/json",
    "STATSIG-API-KEY: <api-key>"
  ],
]);

$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://statsigapi.net/console/v1/ingestion"

	payload := strings.NewReader("{\n  \"dataset\": \"Metrics\",\n  \"source_name\": \"<string>\",\n  \"query\": \"<string>\",\n  \"use_delta_sharing\": true,\n  \"share\": \"<string>\",\n  \"schema\": \"<string>\",\n  \"table\": \"<string>\",\n  \"enabled\": true\n}")

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

	req.Header.Add("STATSIG-API-KEY", "<api-key>")
	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://statsigapi.net/console/v1/ingestion")
  .header("STATSIG-API-KEY", "<api-key>")
  .header("Content-Type", "application/json")
  .body("{\n  \"dataset\": \"Metrics\",\n  \"source_name\": \"<string>\",\n  \"query\": \"<string>\",\n  \"use_delta_sharing\": true,\n  \"share\": \"<string>\",\n  \"schema\": \"<string>\",\n  \"table\": \"<string>\",\n  \"enabled\": true\n}")
  .asString();

require 'uri'
require 'net/http'

url = URI("https://statsigapi.net/console/v1/ingestion")

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

request = Net::HTTP::Post.new(url)
request["STATSIG-API-KEY"] = '<api-key>'
request["Content-Type"] = 'application/json'
request.body = "{\n  \"dataset\": \"Metrics\",\n  \"source_name\": \"<string>\",\n  \"query\": \"<string>\",\n  \"use_delta_sharing\": true,\n  \"share\": \"<string>\",\n  \"schema\": \"<string>\",\n  \"table\": \"<string>\",\n  \"enabled\": true\n}"

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

{
  "type": "databricks",
  "dataset": "Metrics",
  "source_name": "ingestion-1",
  "query": "SELECT * FROM TABLE",
  "column_mapping": {
    "unit_id": "string",
    "id_type": "string",
    "dateid": "string",
    "metric_name": "string",
    "metric_value": "string",
    "numerator": "string",
    "denominator": "string"
  },
  "use_delta_sharing": false,
  "share": "string",
  "schema": "string",
  "table": "string",
  "enabled": false
}

Authorizations

STATSIG-API-KEY

string

header

required

Headers

x-respect-review-settings

string

Optional header to respect review settings for mutation endpoints.

Body

application/json

Option 1
Option 2
Option 3

dataset

enum<string>

required

Available options:

Metrics

type

enum<string>

required

Available options:

redshift,

bigquery-v2,

snowflake-v2,

databricks,

azure-synapse,

s3,

athena,

adls

source_name

string

required

column_mapping

object

Show child attributes

query

string

Available options:

true

schema

string

table

string

enabled

boolean

Response

200 - application/json

Create Ingestion Success

message

string

required

A simple string explaining the result of the operation.

data

object

required

A single result.

Show child attributes

⌘I

HTTP API

Console API

Alerts

Audit Logs

Autotunes

Company

Dynamic Configs

Events

Experiments

Experiments (Warehouse Native)

Configs

Gates

Holdouts

Ingestions

Keys

Layers

Metrics

Metrics (Warehouse Native)

Project

Usage

Reports

Segments

Tags

Target App

Users

Create Ingestion Source

Authorizations

Headers

Body

Response