Capture complete sources and comments with acknowledged IDs
curl --request POST \
--url https://agent.crowdlisten.com/agent/v1/ingest/content \
--header 'Content-Type: application/json' \
--data '
{
"entity_id": "<string>",
"sources": [
{
"content": "<string>",
"id": "<string>",
"title": "",
"url": "",
"author": "",
"published_at": "<string>",
"engagement": {
"likes": 1,
"comments": 1,
"views": 1,
"score": 1,
"shares": 1
},
"comments": [
{
"text": "<string>",
"id": "<string>",
"url": "<string>",
"published_at": "<string>",
"metadata": {},
"author": "unknown",
"likes": 1,
"replies": 1
}
],
"metadata": {}
}
],
"collection_run_id": "<string>",
"collection_scope": "<string>",
"coverage_state": "<string>"
}
'import requests
url = "https://agent.crowdlisten.com/agent/v1/ingest/content"
payload = {
"entity_id": "<string>",
"sources": [
{
"content": "<string>",
"id": "<string>",
"title": "",
"url": "",
"author": "",
"published_at": "<string>",
"engagement": {
"likes": 1,
"comments": 1,
"views": 1,
"score": 1,
"shares": 1
},
"comments": [
{
"text": "<string>",
"id": "<string>",
"url": "<string>",
"published_at": "<string>",
"metadata": {},
"author": "unknown",
"likes": 1,
"replies": 1
}
],
"metadata": {}
}
],
"collection_run_id": "<string>",
"collection_scope": "<string>",
"coverage_state": "<string>"
}
headers = {"Content-Type": "application/json"}
response = requests.post(url, json=payload, headers=headers)
print(response.text)const options = {
method: 'POST',
headers: {'Content-Type': 'application/json'},
body: JSON.stringify({
entity_id: '<string>',
sources: [
{
content: '<string>',
id: '<string>',
title: '',
url: '',
author: '',
published_at: '<string>',
engagement: {likes: 1, comments: 1, views: 1, score: 1, shares: 1},
comments: [
{
text: '<string>',
id: '<string>',
url: '<string>',
published_at: '<string>',
metadata: {},
author: 'unknown',
likes: 1,
replies: 1
}
],
metadata: {}
}
],
collection_run_id: '<string>',
collection_scope: '<string>',
coverage_state: '<string>'
})
};
fetch('https://agent.crowdlisten.com/agent/v1/ingest/content', 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://agent.crowdlisten.com/agent/v1/ingest/content",
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([
'entity_id' => '<string>',
'sources' => [
[
'content' => '<string>',
'id' => '<string>',
'title' => '',
'url' => '',
'author' => '',
'published_at' => '<string>',
'engagement' => [
'likes' => 1,
'comments' => 1,
'views' => 1,
'score' => 1,
'shares' => 1
],
'comments' => [
[
'text' => '<string>',
'id' => '<string>',
'url' => '<string>',
'published_at' => '<string>',
'metadata' => [
],
'author' => 'unknown',
'likes' => 1,
'replies' => 1
]
],
'metadata' => [
]
]
],
'collection_run_id' => '<string>',
'collection_scope' => '<string>',
'coverage_state' => '<string>'
]),
CURLOPT_HTTPHEADER => [
"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://agent.crowdlisten.com/agent/v1/ingest/content"
payload := strings.NewReader("{\n \"entity_id\": \"<string>\",\n \"sources\": [\n {\n \"content\": \"<string>\",\n \"id\": \"<string>\",\n \"title\": \"\",\n \"url\": \"\",\n \"author\": \"\",\n \"published_at\": \"<string>\",\n \"engagement\": {\n \"likes\": 1,\n \"comments\": 1,\n \"views\": 1,\n \"score\": 1,\n \"shares\": 1\n },\n \"comments\": [\n {\n \"text\": \"<string>\",\n \"id\": \"<string>\",\n \"url\": \"<string>\",\n \"published_at\": \"<string>\",\n \"metadata\": {},\n \"author\": \"unknown\",\n \"likes\": 1,\n \"replies\": 1\n }\n ],\n \"metadata\": {}\n }\n ],\n \"collection_run_id\": \"<string>\",\n \"collection_scope\": \"<string>\",\n \"coverage_state\": \"<string>\"\n}")
req, _ := http.NewRequest("POST", url, payload)
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://agent.crowdlisten.com/agent/v1/ingest/content")
.header("Content-Type", "application/json")
.body("{\n \"entity_id\": \"<string>\",\n \"sources\": [\n {\n \"content\": \"<string>\",\n \"id\": \"<string>\",\n \"title\": \"\",\n \"url\": \"\",\n \"author\": \"\",\n \"published_at\": \"<string>\",\n \"engagement\": {\n \"likes\": 1,\n \"comments\": 1,\n \"views\": 1,\n \"score\": 1,\n \"shares\": 1\n },\n \"comments\": [\n {\n \"text\": \"<string>\",\n \"id\": \"<string>\",\n \"url\": \"<string>\",\n \"published_at\": \"<string>\",\n \"metadata\": {},\n \"author\": \"unknown\",\n \"likes\": 1,\n \"replies\": 1\n }\n ],\n \"metadata\": {}\n }\n ],\n \"collection_run_id\": \"<string>\",\n \"collection_scope\": \"<string>\",\n \"coverage_state\": \"<string>\"\n}")
.asString();require 'uri'
require 'net/http'
url = URI("https://agent.crowdlisten.com/agent/v1/ingest/content")
http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true
request = Net::HTTP::Post.new(url)
request["Content-Type"] = 'application/json'
request.body = "{\n \"entity_id\": \"<string>\",\n \"sources\": [\n {\n \"content\": \"<string>\",\n \"id\": \"<string>\",\n \"title\": \"\",\n \"url\": \"\",\n \"author\": \"\",\n \"published_at\": \"<string>\",\n \"engagement\": {\n \"likes\": 1,\n \"comments\": 1,\n \"views\": 1,\n \"score\": 1,\n \"shares\": 1\n },\n \"comments\": [\n {\n \"text\": \"<string>\",\n \"id\": \"<string>\",\n \"url\": \"<string>\",\n \"published_at\": \"<string>\",\n \"metadata\": {},\n \"author\": \"unknown\",\n \"likes\": 1,\n \"replies\": 1\n }\n ],\n \"metadata\": {}\n }\n ],\n \"collection_run_id\": \"<string>\",\n \"collection_scope\": \"<string>\",\n \"coverage_state\": \"<string>\"\n}"
response = http.request(request)
puts response.read_body{
"inserted": 123,
"skipped_dedup": 123,
"total_received": 123,
"stored": 123,
"content_ids": [
"<string>"
],
"parent_content_ids": [
"<string>"
],
"comment_content_ids": [
"<string>"
],
"comments_received": 123,
"comments_inserted": 123,
"skipped_irrelevant": 0,
"complete": true,
"count_basis": "Acknowledged original records, including reused originals; not unique people"
}{
"detail": [
{
"loc": [
"<string>"
],
"msg": "<string>",
"type": "<string>"
}
]
}ingest
Capture complete sources and comments with acknowledged IDs
Capture all originals and parent links atomically; analysis is a separate step.
POST
/
agent
/
v1
/
ingest
/
content
Capture complete sources and comments with acknowledged IDs
curl --request POST \
--url https://agent.crowdlisten.com/agent/v1/ingest/content \
--header 'Content-Type: application/json' \
--data '
{
"entity_id": "<string>",
"sources": [
{
"content": "<string>",
"id": "<string>",
"title": "",
"url": "",
"author": "",
"published_at": "<string>",
"engagement": {
"likes": 1,
"comments": 1,
"views": 1,
"score": 1,
"shares": 1
},
"comments": [
{
"text": "<string>",
"id": "<string>",
"url": "<string>",
"published_at": "<string>",
"metadata": {},
"author": "unknown",
"likes": 1,
"replies": 1
}
],
"metadata": {}
}
],
"collection_run_id": "<string>",
"collection_scope": "<string>",
"coverage_state": "<string>"
}
'import requests
url = "https://agent.crowdlisten.com/agent/v1/ingest/content"
payload = {
"entity_id": "<string>",
"sources": [
{
"content": "<string>",
"id": "<string>",
"title": "",
"url": "",
"author": "",
"published_at": "<string>",
"engagement": {
"likes": 1,
"comments": 1,
"views": 1,
"score": 1,
"shares": 1
},
"comments": [
{
"text": "<string>",
"id": "<string>",
"url": "<string>",
"published_at": "<string>",
"metadata": {},
"author": "unknown",
"likes": 1,
"replies": 1
}
],
"metadata": {}
}
],
"collection_run_id": "<string>",
"collection_scope": "<string>",
"coverage_state": "<string>"
}
headers = {"Content-Type": "application/json"}
response = requests.post(url, json=payload, headers=headers)
print(response.text)const options = {
method: 'POST',
headers: {'Content-Type': 'application/json'},
body: JSON.stringify({
entity_id: '<string>',
sources: [
{
content: '<string>',
id: '<string>',
title: '',
url: '',
author: '',
published_at: '<string>',
engagement: {likes: 1, comments: 1, views: 1, score: 1, shares: 1},
comments: [
{
text: '<string>',
id: '<string>',
url: '<string>',
published_at: '<string>',
metadata: {},
author: 'unknown',
likes: 1,
replies: 1
}
],
metadata: {}
}
],
collection_run_id: '<string>',
collection_scope: '<string>',
coverage_state: '<string>'
})
};
fetch('https://agent.crowdlisten.com/agent/v1/ingest/content', 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://agent.crowdlisten.com/agent/v1/ingest/content",
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([
'entity_id' => '<string>',
'sources' => [
[
'content' => '<string>',
'id' => '<string>',
'title' => '',
'url' => '',
'author' => '',
'published_at' => '<string>',
'engagement' => [
'likes' => 1,
'comments' => 1,
'views' => 1,
'score' => 1,
'shares' => 1
],
'comments' => [
[
'text' => '<string>',
'id' => '<string>',
'url' => '<string>',
'published_at' => '<string>',
'metadata' => [
],
'author' => 'unknown',
'likes' => 1,
'replies' => 1
]
],
'metadata' => [
]
]
],
'collection_run_id' => '<string>',
'collection_scope' => '<string>',
'coverage_state' => '<string>'
]),
CURLOPT_HTTPHEADER => [
"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://agent.crowdlisten.com/agent/v1/ingest/content"
payload := strings.NewReader("{\n \"entity_id\": \"<string>\",\n \"sources\": [\n {\n \"content\": \"<string>\",\n \"id\": \"<string>\",\n \"title\": \"\",\n \"url\": \"\",\n \"author\": \"\",\n \"published_at\": \"<string>\",\n \"engagement\": {\n \"likes\": 1,\n \"comments\": 1,\n \"views\": 1,\n \"score\": 1,\n \"shares\": 1\n },\n \"comments\": [\n {\n \"text\": \"<string>\",\n \"id\": \"<string>\",\n \"url\": \"<string>\",\n \"published_at\": \"<string>\",\n \"metadata\": {},\n \"author\": \"unknown\",\n \"likes\": 1,\n \"replies\": 1\n }\n ],\n \"metadata\": {}\n }\n ],\n \"collection_run_id\": \"<string>\",\n \"collection_scope\": \"<string>\",\n \"coverage_state\": \"<string>\"\n}")
req, _ := http.NewRequest("POST", url, payload)
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://agent.crowdlisten.com/agent/v1/ingest/content")
.header("Content-Type", "application/json")
.body("{\n \"entity_id\": \"<string>\",\n \"sources\": [\n {\n \"content\": \"<string>\",\n \"id\": \"<string>\",\n \"title\": \"\",\n \"url\": \"\",\n \"author\": \"\",\n \"published_at\": \"<string>\",\n \"engagement\": {\n \"likes\": 1,\n \"comments\": 1,\n \"views\": 1,\n \"score\": 1,\n \"shares\": 1\n },\n \"comments\": [\n {\n \"text\": \"<string>\",\n \"id\": \"<string>\",\n \"url\": \"<string>\",\n \"published_at\": \"<string>\",\n \"metadata\": {},\n \"author\": \"unknown\",\n \"likes\": 1,\n \"replies\": 1\n }\n ],\n \"metadata\": {}\n }\n ],\n \"collection_run_id\": \"<string>\",\n \"collection_scope\": \"<string>\",\n \"coverage_state\": \"<string>\"\n}")
.asString();require 'uri'
require 'net/http'
url = URI("https://agent.crowdlisten.com/agent/v1/ingest/content")
http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true
request = Net::HTTP::Post.new(url)
request["Content-Type"] = 'application/json'
request.body = "{\n \"entity_id\": \"<string>\",\n \"sources\": [\n {\n \"content\": \"<string>\",\n \"id\": \"<string>\",\n \"title\": \"\",\n \"url\": \"\",\n \"author\": \"\",\n \"published_at\": \"<string>\",\n \"engagement\": {\n \"likes\": 1,\n \"comments\": 1,\n \"views\": 1,\n \"score\": 1,\n \"shares\": 1\n },\n \"comments\": [\n {\n \"text\": \"<string>\",\n \"id\": \"<string>\",\n \"url\": \"<string>\",\n \"published_at\": \"<string>\",\n \"metadata\": {},\n \"author\": \"unknown\",\n \"likes\": 1,\n \"replies\": 1\n }\n ],\n \"metadata\": {}\n }\n ],\n \"collection_run_id\": \"<string>\",\n \"collection_scope\": \"<string>\",\n \"coverage_state\": \"<string>\"\n}"
response = http.request(request)
puts response.read_body{
"inserted": 123,
"skipped_dedup": 123,
"total_received": 123,
"stored": 123,
"content_ids": [
"<string>"
],
"parent_content_ids": [
"<string>"
],
"comment_content_ids": [
"<string>"
],
"comments_received": 123,
"comments_inserted": 123,
"skipped_irrelevant": 0,
"complete": true,
"count_basis": "Acknowledged original records, including reused originals; not unique people"
}{
"detail": [
{
"loc": [
"<string>"
],
"msg": "<string>",
"type": "<string>"
}
]
}Body
application/json
Required string length:
1 - 100Required array length:
1 - 500 elementsShow child attributes
Show child attributes
Maximum string length:
200Maximum string length:
200Collector-level coverage state for this batch.
Pattern:
^(exhaustive|sampled|bounded|blocked|unknown)$Response
Successful Response
count_basis
string
default:Acknowledged original records, including reused originals; not unique people