import requests
url = "https://platform.reducto.ai/pipeline_async"
payload = {
"document_url": "<string>",
"pipeline_id": "<string>",
"settings": {},
"webhook": {
"mode": "disabled",
"channels": []
},
"priority": False
}
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({
document_url: '<string>',
pipeline_id: '<string>',
settings: {},
webhook: {mode: 'disabled', channels: []},
priority: false
})
};
fetch('https://platform.reducto.ai/pipeline_async', options)
.then(res => res.json())
.then(res => console.log(res))
.catch(err => console.error(err));package main
import (
"fmt"
"strings"
"net/http"
"io"
)
func main() {
url := "https://platform.reducto.ai/pipeline_async"
payload := strings.NewReader("{\n \"document_url\": \"<string>\",\n \"pipeline_id\": \"<string>\",\n \"settings\": {},\n \"webhook\": {\n \"mode\": \"disabled\",\n \"channels\": []\n },\n \"priority\": false\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))
}{
"job_id": "<string>"
}{
"detail": [
{
"loc": [
"<string>"
],
"msg": "<string>",
"type": "<string>",
"input": "<unknown>",
"ctx": {}
}
]
}Pipeline Async
import requests
url = "https://platform.reducto.ai/pipeline_async"
payload = {
"document_url": "<string>",
"pipeline_id": "<string>",
"settings": {},
"webhook": {
"mode": "disabled",
"channels": []
},
"priority": False
}
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({
document_url: '<string>',
pipeline_id: '<string>',
settings: {},
webhook: {mode: 'disabled', channels: []},
priority: false
})
};
fetch('https://platform.reducto.ai/pipeline_async', options)
.then(res => res.json())
.then(res => console.log(res))
.catch(err => console.error(err));package main
import (
"fmt"
"strings"
"net/http"
"io"
)
func main() {
url := "https://platform.reducto.ai/pipeline_async"
payload := strings.NewReader("{\n \"document_url\": \"<string>\",\n \"pipeline_id\": \"<string>\",\n \"settings\": {},\n \"webhook\": {\n \"mode\": \"disabled\",\n \"channels\": []\n },\n \"priority\": false\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))
}{
"job_id": "<string>"
}{
"detail": [
{
"loc": [
"<string>"
],
"msg": "<string>",
"type": "<string>",
"input": "<unknown>",
"ctx": {}
}
]
}Authorizations
Bearer authentication header of the form Bearer <token>, where <token> is your auth token.
Body
The URL of the document to be processed. You can provide one of the following: 1. A publicly available URL 2. A presigned S3 URL 3. A reducto:// prefixed URL obtained from the /upload endpoint after directly uploading a document 4. [API-131] A list of URLs (for multi-document pipelines, V3 API only)
The ID of the pipeline to use for the document.
Settings for pipeline execution that override pipeline defaults.
Show child attributes
Show child attributes
Show child attributes
Show child attributes
Workers poll the priority queue ahead of the standard queue, so priority jobs start sooner when there is queued work; sync jobs are prioritized above async jobs by default.
Response
Successful Response
Was this page helpful?