cURL
curl --request GET \
--url https://api.pipedream.com/v1/connect/{project_id}/deployed-triggers/{trigger_id}/events \
--header 'Authorization: Bearer <token>' \
--header 'x-pd-environment: <x-pd-environment>'import { PipedreamClient } from "@pipedream/sdk";
const client = new PipedreamClient({
clientId: "YOUR_CLIENT_ID",
clientSecret: "YOUR_CLIENT_SECRET",
projectEnvironment: "YOUR_PROJECT_ENVIRONMENT",
projectId: "YOUR_PROJECT_ID"
});
await client.deployedTriggers.listEvents("trigger_id", {
externalUserId: "external_user_id",
n: 1
});
from pipedream import Pipedream
client = Pipedream(
project_id="YOUR_PROJECT_ID",
client_id="YOUR_CLIENT_ID",
client_secret="YOUR_CLIENT_SECRET",
)
client.deployed_triggers.list_events(
trigger_id="trigger_id",
external_user_id="external_user_id",
n=1,
)
package com.example.usage;
import com.pipedream.api.BaseClient;
import com.pipedream.api.resources.deployedtriggers.requests.DeployedTriggersListEventsRequest;
public class Example {
public static void main(String[] args) {
BaseClient client = BaseClient.withCredentials("<clientId>", "<clientSecret>")
.projectId("YOUR_PROJECT_ID")
.build()
;
client.deployedTriggers().listEvents(
"trigger_id",
DeployedTriggersListEventsRequest
.builder()
.externalUserId("external_user_id")
.n(1)
.build()
);
}
}
package main
import (
"fmt"
"net/http"
"io"
)
func main() {
url := "https://api.pipedream.com/v1/connect/{project_id}/deployed-triggers/{trigger_id}/events"
req, _ := http.NewRequest("GET", url, nil)
req.Header.Add("x-pd-environment", "<x-pd-environment>")
req.Header.Add("Authorization", "Bearer <token>")
res, _ := http.DefaultClient.Do(req)
defer res.Body.Close()
body, _ := io.ReadAll(res.Body)
fmt.Println(string(body))
}{
"data": [
{
"e": {},
"k": "<string>",
"ts": 123,
"id": "<string>",
"sum": "<string>"
}
]
}{
"error": "Throttled"
}List trigger events
Retrieve recent events emitted by a deployed trigger
GET
/
v1
/
connect
/
{project_id}
/
deployed-triggers
/
{trigger_id}
/
events
cURL
curl --request GET \
--url https://api.pipedream.com/v1/connect/{project_id}/deployed-triggers/{trigger_id}/events \
--header 'Authorization: Bearer <token>' \
--header 'x-pd-environment: <x-pd-environment>'import { PipedreamClient } from "@pipedream/sdk";
const client = new PipedreamClient({
clientId: "YOUR_CLIENT_ID",
clientSecret: "YOUR_CLIENT_SECRET",
projectEnvironment: "YOUR_PROJECT_ENVIRONMENT",
projectId: "YOUR_PROJECT_ID"
});
await client.deployedTriggers.listEvents("trigger_id", {
externalUserId: "external_user_id",
n: 1
});
from pipedream import Pipedream
client = Pipedream(
project_id="YOUR_PROJECT_ID",
client_id="YOUR_CLIENT_ID",
client_secret="YOUR_CLIENT_SECRET",
)
client.deployed_triggers.list_events(
trigger_id="trigger_id",
external_user_id="external_user_id",
n=1,
)
package com.example.usage;
import com.pipedream.api.BaseClient;
import com.pipedream.api.resources.deployedtriggers.requests.DeployedTriggersListEventsRequest;
public class Example {
public static void main(String[] args) {
BaseClient client = BaseClient.withCredentials("<clientId>", "<clientSecret>")
.projectId("YOUR_PROJECT_ID")
.build()
;
client.deployedTriggers().listEvents(
"trigger_id",
DeployedTriggersListEventsRequest
.builder()
.externalUserId("external_user_id")
.n(1)
.build()
);
}
}
package main
import (
"fmt"
"net/http"
"io"
)
func main() {
url := "https://api.pipedream.com/v1/connect/{project_id}/deployed-triggers/{trigger_id}/events"
req, _ := http.NewRequest("GET", url, nil)
req.Header.Add("x-pd-environment", "<x-pd-environment>")
req.Header.Add("Authorization", "Bearer <token>")
res, _ := http.DefaultClient.Do(req)
defer res.Body.Close()
body, _ := io.ReadAll(res.Body)
fmt.Println(string(body))
}{
"data": [
{
"e": {},
"k": "<string>",
"ts": 123,
"id": "<string>",
"sum": "<string>"
}
]
}{
"error": "Throttled"
}The limit on the number of events returned is 100.
Authorizations
ConnectTokenOAuth2
A short-lived Connect token for client-side requests on behalf of an end user. Generate one via the Create Connect token endpoint.
Headers
The environment in which the server client is running
Available options:
development, production Path Parameters
The project ID, which starts with proj_.
Pattern:
^proj_[a-zA-Z0-9]+$Query Parameters
Your end user ID, for whom you deployed the trigger
The number of events to retrieve (defaults to 20 if not provided)
Response
trigger events retrieved
Response received when retrieving trigger events
Show child attributes
Show child attributes
Was this page helpful?