const options = {
method: 'POST',
headers: {'content-type': 'application/json', authorization: 'Bearer <TOKEN>'},
body: JSON.stringify({
pipes: [
{
pipe_id: 'people:match:amplemarket@1',
connector: {
strategy: 'first',
connections: [{type: 'vault', connection: 'amplemarket_123'}]
}
}
],
input: [{id: '1', profile_url: 'https://linkedin.com/li/johndoe'}]
})
};
fetch('https://api.pipe0.com/v1/pipes/run', options)
.then(res => res.json())
.then(res => console.log(res))
.catch(err => console.error(err));
import requests
url = "https://api.pipe0.com/v1/pipes/run"
payload = {
"pipes": [
{
"pipe_id": "people:match:amplemarket@1",
"connector": {
"strategy": "first",
"connections": [
{
"type": "vault",
"connection": "amplemarket_123"
}
]
}
}
],
"input": [
{
"id": "1",
"profile_url": "https://linkedin.com/li/johndoe"
}
]
}
headers = {
"content-type": "application/json",
"authorization": "Bearer <TOKEN>"
}
response = requests.post(url, json=payload, headers=headers)
print(response.text)
curl --request POST \
--url https://api.pipe0.com/v1/pipes/run \
--header 'authorization: Bearer <TOKEN>' \
--header 'content-type: application/json' \
--data '
{
"pipes": [
{
"pipe_id": "people:match:amplemarket@1",
"connector": {
"strategy": "first",
"connections": [
{
"type": "vault",
"connection": "amplemarket_123"
}
]
}
}
],
"input": [
{
"id": "1",
"profile_url": "https://linkedin.com/li/johndoe"
}
]
}
'
package main
import (
"fmt"
"strings"
"net/http"
"io"
)
func main() {
url := "https://api.pipe0.com/v1/pipes/run"
payload := strings.NewReader("{\"pipes\":[{\"pipe_id\":\"people:match:amplemarket@1\",\"connector\":{\"strategy\":\"first\",\"connections\":[{\"type\":\"vault\",\"connection\":\"amplemarket_123\"}]}}],\"input\":[{\"id\":\"1\",\"profile_url\":\"https://linkedin.com/li/johndoe\"}]}")
req, _ := http.NewRequest("POST", url, payload)
req.Header.Add("content-type", "application/json")
req.Header.Add("authorization", "Bearer <TOKEN>")
res, _ := http.DefaultClient.Do(req)
defer res.Body.Close()
body, _ := io.ReadAll(res.Body)
fmt.Println(string(body))
}
<?php
require_once('vendor/autoload.php');
$client = new \GuzzleHttp\Client();
$response = $client->request('POST', 'https://api.pipe0.com/v1/pipes/run', [
'body' => '{"pipes":[{"pipe_id":"people:match:amplemarket@1","connector":{"strategy":"first","connections":[{"type":"vault","connection":"amplemarket_123"}]}}],"input":[{"id":"1","profile_url":"https://linkedin.com/li/johndoe"}]}',
'headers' => [
'authorization' => 'Bearer <TOKEN>',
'content-type' => 'application/json',
],
]);
echo $response->getBody();
POST /v1/pipes/run HTTP/1.1
Content-Type: application/json
Authorization: Bearer <TOKEN>
Host: api.pipe0.com
Content-Length: 218
{"pipes":[{"pipe_id":"people:match:amplemarket@1","connector":{"strategy":"first","connections":[{"type":"vault","connection":"amplemarket_123"}]}}],"input":[{"id":"1","profile_url":"https://linkedin.com/li/johndoe"}]}