Get Records
curl --request POST \
--url https://app.superleap.com/api/v1/appflow/objects/{object_slug}/records \
--header 'Authorization: <authorization>' \
--header 'Content-Type: <content-type>' \
--data '
{
"query": {
"fields": [
"<string>"
],
"filter": {
"and": [
{
"field": "<string>",
"operator": "<string>",
"value": "<any>"
}
]
}
},
"next_token": "<string>"
}
'import requests
url = "https://app.superleap.com/api/v1/appflow/objects/{object_slug}/records"
payload = {
"query": {
"fields": ["<string>"],
"filter": { "and": [
{
"field": "<string>",
"operator": "<string>",
"value": "<any>"
}
] }
},
"next_token": "<string>"
}
headers = {
"Authorization": "<authorization>",
"Content-Type": "<content-type>"
}
response = requests.post(url, json=payload, headers=headers)
print(response.text)const options = {
method: 'POST',
headers: {Authorization: '<authorization>', 'Content-Type': '<content-type>'},
body: JSON.stringify({
query: {
fields: ['<string>'],
filter: {and: [{field: '<string>', operator: '<string>', value: '<any>'}]}
},
next_token: '<string>'
})
};
fetch('https://app.superleap.com/api/v1/appflow/objects/{object_slug}/records', 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://app.superleap.com/api/v1/appflow/objects/{object_slug}/records",
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([
'query' => [
'fields' => [
'<string>'
],
'filter' => [
'and' => [
[
'field' => '<string>',
'operator' => '<string>',
'value' => '<any>'
]
]
]
],
'next_token' => '<string>'
]),
CURLOPT_HTTPHEADER => [
"Authorization: <authorization>",
"Content-Type: <content-type>"
],
]);
$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://app.superleap.com/api/v1/appflow/objects/{object_slug}/records"
payload := strings.NewReader("{\n \"query\": {\n \"fields\": [\n \"<string>\"\n ],\n \"filter\": {\n \"and\": [\n {\n \"field\": \"<string>\",\n \"operator\": \"<string>\",\n \"value\": \"<any>\"\n }\n ]\n }\n },\n \"next_token\": \"<string>\"\n}")
req, _ := http.NewRequest("POST", url, payload)
req.Header.Add("Authorization", "<authorization>")
req.Header.Add("Content-Type", "<content-type>")
res, _ := http.DefaultClient.Do(req)
defer res.Body.Close()
body, _ := io.ReadAll(res.Body)
fmt.Println(string(body))
}HttpResponse<String> response = Unirest.post("https://app.superleap.com/api/v1/appflow/objects/{object_slug}/records")
.header("Authorization", "<authorization>")
.header("Content-Type", "<content-type>")
.body("{\n \"query\": {\n \"fields\": [\n \"<string>\"\n ],\n \"filter\": {\n \"and\": [\n {\n \"field\": \"<string>\",\n \"operator\": \"<string>\",\n \"value\": \"<any>\"\n }\n ]\n }\n },\n \"next_token\": \"<string>\"\n}")
.asString();require 'uri'
require 'net/http'
url = URI("https://app.superleap.com/api/v1/appflow/objects/{object_slug}/records")
http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true
request = Net::HTTP::Post.new(url)
request["Authorization"] = '<authorization>'
request["Content-Type"] = '<content-type>'
request.body = "{\n \"query\": {\n \"fields\": [\n \"<string>\"\n ],\n \"filter\": {\n \"and\": [\n {\n \"field\": \"<string>\",\n \"operator\": \"<string>\",\n \"value\": \"<any>\"\n }\n ]\n }\n },\n \"next_token\": \"<string>\"\n}"
response = http.request(request)
puts response.read_bodyAppflow APIs
Get Records
POST
/
api
/
v1
/
appflow
/
objects
/
{object_slug}
/
records
Get Records
curl --request POST \
--url https://app.superleap.com/api/v1/appflow/objects/{object_slug}/records \
--header 'Authorization: <authorization>' \
--header 'Content-Type: <content-type>' \
--data '
{
"query": {
"fields": [
"<string>"
],
"filter": {
"and": [
{
"field": "<string>",
"operator": "<string>",
"value": "<any>"
}
]
}
},
"next_token": "<string>"
}
'import requests
url = "https://app.superleap.com/api/v1/appflow/objects/{object_slug}/records"
payload = {
"query": {
"fields": ["<string>"],
"filter": { "and": [
{
"field": "<string>",
"operator": "<string>",
"value": "<any>"
}
] }
},
"next_token": "<string>"
}
headers = {
"Authorization": "<authorization>",
"Content-Type": "<content-type>"
}
response = requests.post(url, json=payload, headers=headers)
print(response.text)const options = {
method: 'POST',
headers: {Authorization: '<authorization>', 'Content-Type': '<content-type>'},
body: JSON.stringify({
query: {
fields: ['<string>'],
filter: {and: [{field: '<string>', operator: '<string>', value: '<any>'}]}
},
next_token: '<string>'
})
};
fetch('https://app.superleap.com/api/v1/appflow/objects/{object_slug}/records', 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://app.superleap.com/api/v1/appflow/objects/{object_slug}/records",
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([
'query' => [
'fields' => [
'<string>'
],
'filter' => [
'and' => [
[
'field' => '<string>',
'operator' => '<string>',
'value' => '<any>'
]
]
]
],
'next_token' => '<string>'
]),
CURLOPT_HTTPHEADER => [
"Authorization: <authorization>",
"Content-Type: <content-type>"
],
]);
$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://app.superleap.com/api/v1/appflow/objects/{object_slug}/records"
payload := strings.NewReader("{\n \"query\": {\n \"fields\": [\n \"<string>\"\n ],\n \"filter\": {\n \"and\": [\n {\n \"field\": \"<string>\",\n \"operator\": \"<string>\",\n \"value\": \"<any>\"\n }\n ]\n }\n },\n \"next_token\": \"<string>\"\n}")
req, _ := http.NewRequest("POST", url, payload)
req.Header.Add("Authorization", "<authorization>")
req.Header.Add("Content-Type", "<content-type>")
res, _ := http.DefaultClient.Do(req)
defer res.Body.Close()
body, _ := io.ReadAll(res.Body)
fmt.Println(string(body))
}HttpResponse<String> response = Unirest.post("https://app.superleap.com/api/v1/appflow/objects/{object_slug}/records")
.header("Authorization", "<authorization>")
.header("Content-Type", "<content-type>")
.body("{\n \"query\": {\n \"fields\": [\n \"<string>\"\n ],\n \"filter\": {\n \"and\": [\n {\n \"field\": \"<string>\",\n \"operator\": \"<string>\",\n \"value\": \"<any>\"\n }\n ]\n }\n },\n \"next_token\": \"<string>\"\n}")
.asString();require 'uri'
require 'net/http'
url = URI("https://app.superleap.com/api/v1/appflow/objects/{object_slug}/records")
http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true
request = Net::HTTP::Post.new(url)
request["Authorization"] = '<authorization>'
request["Content-Type"] = '<content-type>'
request.body = "{\n \"query\": {\n \"fields\": [\n \"<string>\"\n ],\n \"filter\": {\n \"and\": [\n {\n \"field\": \"<string>\",\n \"operator\": \"<string>\",\n \"value\": \"<any>\"\n }\n ]\n }\n },\n \"next_token\": \"<string>\"\n}"
response = http.request(request)
puts response.read_bodyFetch records for a specific entity with optional filtering and token-based pagination. This endpoint is used by the AppFlow connector to pull data from Superleap during flow execution.
Headers
string
required
Bearer token for authentication, click here to generate one
string
default:"application/json"
required
application/json
Path Parameters
string
required
The entity identifier for the object (e.g., “lead”, “user”, “opportunity”). Use the List Objects endpoint to discover available identifiers.
Body
object
required
Query object containing field selection and filter parameters
Show Properties
Show Properties
string[]
required
List of field names to include in the response. Use the Get Object endpoint to discover available fields.
Show Example
Show Example
["name", "email", "phone", "created_at"]
string
Pagination token returned from a previous response. Pass
null for the first request. When the response includes a next_token, pass it in the next request to retrieve the following page of results.Example Request
curl --location --request POST 'https://app.superleap.com/api/v1/appflow/objects/lead/records' \
--header 'Content-Type: application/json' \
--header 'Authorization: Bearer SUPERSECRETREDACTEDKEY' \
--data '{
"query": {
"fields": [
"name",
"email"
],
"filter": {
"and": [
{
"field": "updated_at",
"operator": "gte",
"value": 1757134404000
}
]
}
},
"next_token": null
}'
Example Response
{
"success": true,
"data": {
"records": [
{
"email": null,
"id": "xk40vL_CrqDIiR6",
"name": "Fakiyat",
"updated_at": "2025-11-05T18:45:22.372Z"
},
{
"email": null,
"id": "xk40vL_lFM1am8Z",
"name": "Fakiyat",
"updated_at": "2025-11-05T18:45:22.372Z"
},
{
"email": "asdf@gmail.com",
"id": "xk40vL_myqHgKhu",
"name": "Eric Collins",
"updated_at": "2025-11-06T10:12:45.001Z"
}
],
"next_token": "eyJpZCI6InhrNDB2TF9xeUNuS1V6bCIsIm51bWJlcl9vZl9yZWNvcmRzIjozMDAwLCJ1cGRhdGVkX2F0IjoxNzcxNzA3MTU1NjgyfQ=="
}
}
Response Fields
| Field | Type | Description |
|---|---|---|
success | boolean | Whether the request was successful |
data.records | array | List of record objects with the requested fields |
data.next_token | string | null | Pagination token for the next page. null when there are no more results. |
Pagination
Records are returned in pages. When the response includes a non-nullnext_token:
- Pass the
next_tokenvalue in your next request to retrieve the following page - Continue paginating until
next_tokenisnull - Each page may contain up to 3000 records
Incremental Sync
For incremental data syncs, filter by a timestamp field (e.g.,updated_at) using the gte operator with a Unix timestamp in milliseconds. This allows you to fetch only records that have been modified since your last sync.
{
"query": {
"fields": ["name", "email"],
"filter": {
"and": [
{
"field": "updated_at",
"operator": "gte",
"value": 1757134404000
}
]
}
},
"next_token": null
}
⌘I