MULTI-APP TOOLKIT
Build with Amplitude + Google Drive
- Multi-app
- One MCP session
- 61 actions
- 17 triggers
- Managed auth
MCP
One MCP session, both toolsets
One session gives your product or agent every Amplitude and Google Drive tool at once — connect once, list tools, and call them like any single-app session.
// accessToken: mint a short-lived token with the Connect SDK — see the MCP guide
const transport = new StreamableHTTPClientTransport(
new URL("https://remote.mcp.pipedream.net/v3"),
{
requestInit: {
headers: {
Authorization: `Bearer ${accessToken}`,
"x-pd-project-id": "{project_id}",
"x-pd-environment": "production",
"x-pd-external-user-id": "{external_user_id}", // any stable ID for this user in your system
"x-pd-app-slug": "amplitude,google_drive",
},
},
},
)
const mcp = new Client({ name: "my-agent", version: "1.0.0" })
await mcp.connect(transport)
const { tools } = await mcp.listTools()
// One list, both toolsets: Amplitude and Google Drive tools arrive
// together, each keyed by its own app's slug.
// e.g. run Create Cohort:
const result = await mcp.callTool({
name: "amplitude-create-cohort",
arguments: {
cohortName: "Name",
appId: 10,
},
})import { PipedreamClient } from "@pipedream/sdk"
const pd = new PipedreamClient({
projectId: process.env.PIPEDREAM_PROJECT_ID!,
clientId: process.env.PIPEDREAM_CLIENT_ID!,
clientSecret: process.env.PIPEDREAM_CLIENT_SECRET!,
projectEnvironment: "production",
})
const externalUserId = "{external_user_id}" // any stable ID for this user in your system
const [amplitudeTools, googleDriveTools] =
await Promise.all([
pd.components.list({ app: "amplitude" }),
pd.components.list({ app: "google_drive" }),
])
// One external user owns both connected accounts, so either app's tools
// run on their behalf with the same externalUserId.curl "https://api.pipedream.com/v1/connect/{project_id}/components?app=amplitude" \
-H "X-PD-Environment: production" \
-H "Authorization: Bearer {access_token}"
curl "https://api.pipedream.com/v1/connect/{project_id}/components?app=google_drive" \
-H "X-PD-Environment: production" \
-H "Authorization: Bearer {access_token}"
# Connect both accounts to the same external_user_id, then
# configure and invoke either app's tools on that user's behalf.ARCHITECTURE
One user, two connected accounts
Your user connects each account once, under whatever ID they already have in your product. The two stay independent — either can be revoked on its own — and your code reaches both through that one user.
Your product
external_user_id
{external_user_id}Pipedream Connect
Managed identity
Auth · tools · routing
Amplitude
Connected account
Google Drive
Connected account
TOOLS
Amplitude tools
The Amplitude tools this pairing puts in reach, each one running on your user's own connected account.
Actions top 8 of 11
-
Create Cohort
actionCreate a static cohort in Amplitude from an explicit list of user or Amplitude IDs viaPOST /api/3/cohorts/upload(the only REST-documented cohort creation endpoint; behavioral/dynamic cohorts cannot be created via REST). Use List Cohorts to find an existing cohort ID if updating. Example: call withcohortName="Power Users Q3",appId=849238,idType="BY_USER_ID",ids=["user@example.com"],owner="admin@example.com"-> returns{cohortId: "abc123"}. See the documentation.Writev0.0.2 -
Download Cohort File
actionDownload a completed cohort export's member list (step 3 of 3: request -> status -> download). Call Request Cohort Download then Get Cohort Download Status first, and only call this once status isJOB COMPLETED— calling it earlier will fail. Returns one record per member (amplitude_id/user_id, plus any requested user properties) — not the cohort's own metadata (name, size, definition); use List Cohorts for that. Example: call withrequestId="req_456"-> returns{requestId: "req_456", memberCount: 4200, returnedCount: 4200, truncated: false, members: [{amplitude_id: "123456789", user_id: "user@example.com"}, ...]}. See the documentation.Read-onlyv0.0.2 -
Get Cohort Download Status
actionCheck whether a cohort download job has finished (step 2 of 3: request -> status -> download). Call Request Cohort Download first to get arequestId. This action polls internally for up to ~35 seconds before returning, since Amplitude's export jobs commonly take 30-60+ seconds regardless of cohort size. If the returnedasync_statusis stillJOB INPROGRESS, call this action again with the same request ID (it may take a few calls) — do not call Download Cohort File untilasync_statusisJOB COMPLETED. Example: call withrequestId="req_456"-> returns{request_id: "req_456", cohort_id: "abc123", async_status: "JOB COMPLETED"}. See the documentation.Read-onlyv0.0.2 -
Get Event Segmentation
actionQuery event segmentation data (counts, uniques, and other metrics) for one or more events over a date range from the Amplitude Dashboard REST API. Use this to analyze how an event trends over time, optionally broken down by user properties. Example: call withevent={"event_type":"Purchase"},startDate="20240706",endDate="20240805",metric="uniques"-> returns{data: {xValues: ["2024-07-06", ...], series: [[42, 51, ...]]}}(one value per day per requested series). See the documentation.Read-onlyv0.0.2 -
Get Funnel Analysis
actionCompute conversion rates across an ordered (or unordered/sequential) set of funnel steps over a date range from the Amplitude Dashboard REST API. Provide one event definition per funnel step. Example: call withevents=["{\"event_type\":\"Sign Up\"}","{\"event_type\":\"Purchase\"}"],startDate="20240706",endDate="20240805"-> returns{data: [{stepByStep: [...], cumulative: [...], eventCount: 4200}, ...]}(one entry per step). See the documentation.Read-onlyv0.0.2 -
Get Retention Analysis
actionCompute retention (return rate) between a start event and a return event over a date range from the Amplitude Dashboard REST API. Example: call withstartEvent={"event_type":"_new"},returnEvent={"event_type":"_active"},startDate="20240706",endDate="20240805"-> returns{data: {series: [[...retention counts per interval...]], seriesLabels: [...]}}. See the documentation.Read-onlyv0.0.2 -
Get User Activity
actionFetch the event stream for a single user by their numeric Amplitude ID from the Amplitude Dashboard REST API. Each returned event defaults to just event_type and event_time; passfieldsto also get e.g.event_properties,user_properties,uuid,session_id,amplitude_id,device_id(event objects can carry many properties, so these stay opt-in). Amplitude's API caps each request at 1000 events with no cursor; this tool pagesoffsetforward automatically to collect up tolimitevents (set it above 1000, up to 5000, to fetch more than one page). Use Search Users first to resolve the Amplitude ID. Example: call withuser=12345678,limit=50-> returns{events: [{event_type: "Purchase", event_time: "2024-08-05 14:22:10"}, ...], userData: {...}, truncated: false}(truncated: truemeans more events likely exist beyond what was returned — raiselimit/offsetto fetch further). See the documentation.Read-onlyv0.0.2 -
List Cohorts
actionList all behavioral cohorts in the Amplitude project. Returns acohortsarray; each entry defaults to id, name, size, lastMod, appId. Passfieldsto get more, e.g.description,published,archived, or the largedefinition(the cohort's filter logic) /owners/viewers(email arrays). Use this to discover valid cohort IDs for Request Cohort Download (step 1 of 3, followed by Get Cohort Download Status and Download Cohort File, to fetch a cohort's member list). Example: call with no parameters -> returns{cohorts: [{id: "abc123", name: "Power Users Q3", size: 4200, lastMod: 1722873600000, appId: 849238}, ...]}. See the documentation.Read-onlyv0.0.2
Triggers
No Amplitude triggers are available yet.
TOOLS
Google Drive tools
The Google Drive tools this pairing puts in reach, each one running on your user's own connected account.
Actions top 8 of 50
-
Add Comment
actionAdd an unanchored comment to a Google Doc (general feedback, no text highlighting). See the documentationWritev0.1.10 -
Copy File
actionCreate a copy of the specified file. See the documentation for more informationWritev0.1.25 -
Create Folder
actionCreate a new empty folder. See the documentation for more informationWritev0.1.26 -
Create New File From Template
actionCreate a new Google Docs file from a template. Optionally include placeholders in the template document that will get replaced from this action. See documentationWritev0.1.28 -
Create New File From Text
actionCreate a new file from plain text. See the documentation for more informationWritev0.2.18 -
Create Shared Drive
actionCreate a new shared drive. See the documentation for more informationWritev0.1.26 -
Create Text File
actionCreate a new Google Doc from text content in Google Drive. The file is created as a Google Docs document, which can be viewed and edited in the browser. Use this when the user asks to create a document, write a file, or save text to Drive. To place the file in a specific folder, pass theparentId— use Search Files withmimeType = 'application/vnd.google-apps.folder'to find the folder ID first. Supported content formats: plain text, Markdown, HTML, Rich Text, CSV. See the documentationWritev0.0.4 -
Delete Comment
actionDelete a specific comment (Requires ownership or permissions). See the documentationWritev0.0.14
Triggers top 4 of 17
-
Changes to Files in Drive
triggerEmit new event when a change is made to one of the specified files. See the documentationv0.0.13 -
Changes to Specific Files
triggerWatches for changes to specific files, emitting an event when a change is made to one of those files. To watch for changes to shared drive files, use the Changes to Specific Files (Shared Drive) source instead.v0.3.11 -
Changes to Specific Files (Shared Drive)
triggerWatches for changes to specific files in a shared drive, emitting an event when a change is made to one of those filesv0.3.13 -
New Access Proposal
triggerEmit new event when a new access proposal is requested in Google Drivev0.0.16
MULTI-APP
Works with more apps
The combinations customers connect alongside these two — nothing here is limited to a pair.
REFERENCE
Toolkit details
- x-pd-app-slug
- amplitude,google_drive
- Primary app
- Amplitude (amplitude)
- Second app
- Google Drive (google_drive)
- Authentication
- API key + OAuth
- Available actions
- 61
- Available triggers
- 17