Queue import
curl --request POST \
--url https://api.creditor.younegotiate.com/import-consumers \
--header 'Authorization: Bearer <token>' \
--header 'Content-Type: application/json' \
--data '
{
"upload_id": 123,
"header_id": 45,
"import_type": "add",
"update_fields": [
"email1",
"mobile1"
]
}
'import requests
url = "https://api.creditor.younegotiate.com/import-consumers"
payload = {
"upload_id": 123,
"header_id": 45,
"import_type": "add",
"update_fields": ["email1", "mobile1"]
}
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({
upload_id: 123,
header_id: 45,
import_type: 'add',
update_fields: ['email1', 'mobile1']
})
};
fetch('https://api.creditor.younegotiate.com/import-consumers', 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.creditor.younegotiate.com/import-consumers",
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([
'upload_id' => 123,
'header_id' => 45,
'import_type' => 'add',
'update_fields' => [
'email1',
'mobile1'
]
]),
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.creditor.younegotiate.com/import-consumers"
payload := strings.NewReader("{\n \"upload_id\": 123,\n \"header_id\": 45,\n \"import_type\": \"add\",\n \"update_fields\": [\n \"email1\",\n \"mobile1\"\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://api.creditor.younegotiate.com/import-consumers")
.header("Authorization", "Bearer <token>")
.header("Content-Type", "application/json")
.body("{\n \"upload_id\": 123,\n \"header_id\": 45,\n \"import_type\": \"add\",\n \"update_fields\": [\n \"email1\",\n \"mobile1\"\n ]\n}")
.asString();require 'uri'
require 'net/http'
url = URI("https://api.creditor.younegotiate.com/import-consumers")
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 \"upload_id\": 123,\n \"header_id\": 45,\n \"import_type\": \"add\",\n \"update_fields\": [\n \"email1\",\n \"mobile1\"\n ]\n}"
response = http.request(request)
puts response.read_body{
"message": "Import queued.",
"data": {
"id": 123,
"filename": "<string>",
"failed_filename": "<string>",
"file_size_bytes": 123,
"type_label": "<string>",
"type_short_label": "<string>",
"status_label": "<string>",
"update_fields": [
"<string>"
],
"total_records": 123,
"remaining_quota": 123,
"processed_count": 123,
"failed_count": 123,
"progress": {
"processed_count": 123,
"failed_count": 123,
"total_chunks": 123,
"completed_chunks": 123,
"failed_chunks": 123
},
"is_sftp_import": true,
"is_hidden": true,
"processing_started_at": "2023-11-07T05:31:56Z",
"processing_completed_at": "2023-11-07T05:31:56Z",
"processing_duration_seconds": 123,
"is_long_running": true,
"created_at": "2023-11-07T05:31:56Z",
"updated_at": "2023-11-07T05:31:56Z"
}
}{
"message": "<string>"
}{
"message": "An active membership is required."
}{
"message": "<string>"
}{
"message": "<string>"
}{
"message": "<string>",
"errors": {}
}Queue import
Finalize one unconsumed upload session after the frontend uploads the CSV to S3. The API verifies ownership, expiry, object existence, CSV extension, size, first row readability, and exact header match before queueing import jobs.
POST
/
import-consumers
Queue import
curl --request POST \
--url https://api.creditor.younegotiate.com/import-consumers \
--header 'Authorization: Bearer <token>' \
--header 'Content-Type: application/json' \
--data '
{
"upload_id": 123,
"header_id": 45,
"import_type": "add",
"update_fields": [
"email1",
"mobile1"
]
}
'import requests
url = "https://api.creditor.younegotiate.com/import-consumers"
payload = {
"upload_id": 123,
"header_id": 45,
"import_type": "add",
"update_fields": ["email1", "mobile1"]
}
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({
upload_id: 123,
header_id: 45,
import_type: 'add',
update_fields: ['email1', 'mobile1']
})
};
fetch('https://api.creditor.younegotiate.com/import-consumers', 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.creditor.younegotiate.com/import-consumers",
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([
'upload_id' => 123,
'header_id' => 45,
'import_type' => 'add',
'update_fields' => [
'email1',
'mobile1'
]
]),
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.creditor.younegotiate.com/import-consumers"
payload := strings.NewReader("{\n \"upload_id\": 123,\n \"header_id\": 45,\n \"import_type\": \"add\",\n \"update_fields\": [\n \"email1\",\n \"mobile1\"\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://api.creditor.younegotiate.com/import-consumers")
.header("Authorization", "Bearer <token>")
.header("Content-Type", "application/json")
.body("{\n \"upload_id\": 123,\n \"header_id\": 45,\n \"import_type\": \"add\",\n \"update_fields\": [\n \"email1\",\n \"mobile1\"\n ]\n}")
.asString();require 'uri'
require 'net/http'
url = URI("https://api.creditor.younegotiate.com/import-consumers")
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 \"upload_id\": 123,\n \"header_id\": 45,\n \"import_type\": \"add\",\n \"update_fields\": [\n \"email1\",\n \"mobile1\"\n ]\n}"
response = http.request(request)
puts response.read_body{
"message": "Import queued.",
"data": {
"id": 123,
"filename": "<string>",
"failed_filename": "<string>",
"file_size_bytes": 123,
"type_label": "<string>",
"type_short_label": "<string>",
"status_label": "<string>",
"update_fields": [
"<string>"
],
"total_records": 123,
"remaining_quota": 123,
"processed_count": 123,
"failed_count": 123,
"progress": {
"processed_count": 123,
"failed_count": 123,
"total_chunks": 123,
"completed_chunks": 123,
"failed_chunks": 123
},
"is_sftp_import": true,
"is_hidden": true,
"processing_started_at": "2023-11-07T05:31:56Z",
"processing_completed_at": "2023-11-07T05:31:56Z",
"processing_duration_seconds": 123,
"is_long_running": true,
"created_at": "2023-11-07T05:31:56Z",
"updated_at": "2023-11-07T05:31:56Z"
}
}{
"message": "<string>"
}{
"message": "An active membership is required."
}{
"message": "<string>"
}{
"message": "<string>"
}{
"message": "<string>",
"errors": {}
}Authorizations
Bearer authentication header of the form Bearer <token>, where <token> is your auth token.
Body
application/json
Available options:
add, add_account_with_create_cfpb, update, delete Required for update imports. pay_term_offers expands to all four individual pay-term columns.
Available options:
email1, mobile1, current_balance, expiry_date, pay_term_offers Last modified on July 20, 2026
Was this page helpful?
⌘I

