Connectors
Start a DynamoDB export
Initiates a point-in-time export from Amazon DynamoDB for the specified connector. Use this to backfill your destination with existing DynamoDB table data.
POST
/
connectors
/
{uuid}
/
start-dynamodb-export
Start a DynamoDB export
curl --request POST \
--url https://api.artie.com/connectors/{uuid}/start-dynamodb-export \
--header 'Authorization: Bearer <token>' \
--header 'Content-Type: application/json' \
--data '
{
"s3Bucket": "<string>",
"s3Prefix": "<string>"
}
'import requests
url = "https://api.artie.com/connectors/{uuid}/start-dynamodb-export"
payload = {
"s3Bucket": "<string>",
"s3Prefix": "<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({s3Bucket: '<string>', s3Prefix: '<string>'})
};
fetch('https://api.artie.com/connectors/{uuid}/start-dynamodb-export', 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.artie.com/connectors/{uuid}/start-dynamodb-export",
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([
's3Bucket' => '<string>',
's3Prefix' => '<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://api.artie.com/connectors/{uuid}/start-dynamodb-export"
payload := strings.NewReader("{\n \"s3Bucket\": \"<string>\",\n \"s3Prefix\": \"<string>\"\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://api.artie.com/connectors/{uuid}/start-dynamodb-export")
.header("Authorization", "Bearer <token>")
.header("Content-Type", "application/json")
.body("{\n \"s3Bucket\": \"<string>\",\n \"s3Prefix\": \"<string>\"\n}")
.asString();require 'uri'
require 'net/http'
url = URI("https://api.artie.com/connectors/{uuid}/start-dynamodb-export")
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 \"s3Bucket\": \"<string>\",\n \"s3Prefix\": \"<string>\"\n}"
response = http.request(request)
puts response.read_body{
"exportARN": "<string>"
}Was this page helpful?
Previous
Fetch databases for an unsaved connectorLists available databases on the target using an unsaved connector configuration. Useful during connector setup to discover existing databases. Response metadata may include Iceberg S3 table bucket maintenance defaults.
Next
⌘I
Start a DynamoDB export
curl --request POST \
--url https://api.artie.com/connectors/{uuid}/start-dynamodb-export \
--header 'Authorization: Bearer <token>' \
--header 'Content-Type: application/json' \
--data '
{
"s3Bucket": "<string>",
"s3Prefix": "<string>"
}
'import requests
url = "https://api.artie.com/connectors/{uuid}/start-dynamodb-export"
payload = {
"s3Bucket": "<string>",
"s3Prefix": "<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({s3Bucket: '<string>', s3Prefix: '<string>'})
};
fetch('https://api.artie.com/connectors/{uuid}/start-dynamodb-export', 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.artie.com/connectors/{uuid}/start-dynamodb-export",
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([
's3Bucket' => '<string>',
's3Prefix' => '<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://api.artie.com/connectors/{uuid}/start-dynamodb-export"
payload := strings.NewReader("{\n \"s3Bucket\": \"<string>\",\n \"s3Prefix\": \"<string>\"\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://api.artie.com/connectors/{uuid}/start-dynamodb-export")
.header("Authorization", "Bearer <token>")
.header("Content-Type", "application/json")
.body("{\n \"s3Bucket\": \"<string>\",\n \"s3Prefix\": \"<string>\"\n}")
.asString();require 'uri'
require 'net/http'
url = URI("https://api.artie.com/connectors/{uuid}/start-dynamodb-export")
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 \"s3Bucket\": \"<string>\",\n \"s3Prefix\": \"<string>\"\n}"
response = http.request(request)
puts response.read_body{
"exportARN": "<string>"
}