# AWS — Pipedream Connect

> Amazon Web Services (AWS) offers reliable, scalable, and inexpensive cloud computing services.

- API slug: `aws` (use in MCP headers and tool keys)
- Auth: API key (Pipedream-managed)
- Categories: Infrastructure & Cloud
- Website: https://aws.amazon.com/
- This page (HTML): https://pipedream.com/apps/aws
- Tools: 23 actions · 11 triggers

## Connect via MCP (recommended)

- Endpoint: `https://remote.mcp.pipedream.net/v3`
- Headers: `Authorization: Bearer <token>` · `x-pd-project-id` · `x-pd-environment` · `x-pd-external-user-id` · `x-pd-app-slug: aws`

```ts
import { Client } from "@modelcontextprotocol/sdk/client/index.js"
import { StreamableHTTPClientTransport } from "@modelcontextprotocol/sdk/client/streamableHttp.js"
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 accessToken = await pd.rawAccessToken

const transport = new StreamableHTTPClientTransport(
  new URL("https://remote.mcp.pipedream.net/v3"),
  {
    requestInit: {
      headers: {
        Authorization: `Bearer ${accessToken}`,
        "x-pd-project-id": process.env.PIPEDREAM_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": "aws",
      },
    },
  },
)

const mcp = new Client({ name: "my-agent", version: "1.0.0" })
await mcp.connect(transport)

const { tools } = await mcp.listTools()

// e.g. run CloudWatch Logs - Put Log Event:
const result = await mcp.callTool({
  name: "aws-cloudwatch-logs-put-log-event",
  arguments: {
    region: "AWS Region",
    logGroupName: "CloudWatch Log Groups",
  },
})
```

Docs: [MCP guide](https://pipedream.com/docs/connect/mcp/developers.md)

## SDK

```ts
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 result = await pd.actions.run({
  id: "aws-cloudwatch-logs-put-log-event",
  externalUserId: "{external_user_id}", // any stable ID for this user in your system
  configuredProps: {
    aws: { authProvisionId: "apn_xxxxxxx" },
    region: "AWS Region",
    logGroupName: "CloudWatch Log Groups",
  },
})
```

Docs: [Managed auth guide](https://pipedream.com/docs/connect/managed-auth/quickstart.md) · [Tools guide](https://pipedream.com/docs/connect/components.md)

## Actions (23)

### `aws-cloudwatch-logs-put-log-event` — CloudWatch Logs - Put Log Event (Write)

Uploads a log event to the specified log stream. See docs

Full schema: https://pipedream.com/apps/aws/actions/cloudwatch-logs-put-log-event.md

### `aws-dynamodb-create-table` — DynamoDB - Create Table (Write)

Creates a new table to your account. See docs

Full schema: https://pipedream.com/apps/aws/actions/dynamodb-create-table.md

### `aws-dynamodb-execute-statement` — DynamoDB - Execute Statement (Write)

This operation allows you to perform transactional reads or writes on data stored in DynamoDB, using PartiQL. See docs

Full schema: https://pipedream.com/apps/aws/actions/dynamodb-execute-statement.md

### `aws-dynamodb-get-item` — DynamoDB - Get Item (Write)

The Get Item operation returns a set of attributes for the item with the given primary key. If there is no matching item, Get Item does not return any data and there will be no Item element in the response. See docs

Full schema: https://pipedream.com/apps/aws/actions/dynamodb-get-item.md

### `aws-dynamodb-put-item` — DynamoDB - Put Item (Write)

Creates a new item, or replaces an old item with a new item. If an item that has the same primary key as the new item already exists in the specified table, the new item completely replaces the existing item. See docs

Full schema: https://pipedream.com/apps/aws/actions/dynamodb-put-item.md

### `aws-dynamodb-query` — DynamoDB - Query (Read-only)

The query operation finds items based on primary key values. See docs

Full schema: https://pipedream.com/apps/aws/actions/dynamodb-query.md

### `aws-dynamodb-scan` — DynamoDB - Scan (Read-only)

The Scan operation returns one or more items and item attributes by accessing every item in a table. See docs

Full schema: https://pipedream.com/apps/aws/actions/dynamodb-scan.md

### `aws-dynamodb-update-item` — DynamoDB - Update Item (Write)

Updates an existing item's attributes, or adds a new item to the table if it does not already exist. See docs

Full schema: https://pipedream.com/apps/aws/actions/dynamodb-update-item.md

### `aws-dynamodb-update-table` — DynamoDB - Update Table (Write)

Modifies the settings for a given table. Only one type of modification is permitted per request. See docs

Full schema: https://pipedream.com/apps/aws/actions/dynamodb-update-table.md

### `aws-eventbridge-send-event` — EventBridge - Send Event to Event Bus (Write)

Sends an event to an EventBridge event bus. See documentation

Full schema: https://pipedream.com/apps/aws/actions/eventbridge-send-event.md

### `aws-lambda-create-function` — Lambda - Create Function (Write)

Create a Lambda function from source code. This action creates a zip file and deploys it to AWS Lambda. See the docs

Full schema: https://pipedream.com/apps/aws/actions/lambda-create-function.md

### `aws-lambda-invoke-function` — Lambda - Invoke Function (Write)

Invoke a Lambda function using the AWS API. See the docs

Full schema: https://pipedream.com/apps/aws/actions/lambda-invoke-function.md

### `aws-list-region-options` — List AWS Region Options (Read-only)

Retrieves available options for the AWS Region field.

Full schema: https://pipedream.com/apps/aws/actions/list-region-options.md

### `aws-redshift-create-rows` — Redshift - Create Rows (Write)

Insert rows into a table. See the documentation

Full schema: https://pipedream.com/apps/aws/actions/redshift-create-rows.md

### `aws-redshift-delete-rows` — Redshift - Delete Rows (Write)

Deletes row(s) in an existing table in Redshift. See the documentation

Full schema: https://pipedream.com/apps/aws/actions/redshift-delete-rows.md

### `aws-redshift-query-database` — Redshift - Query Database (Read-only)

Run a SELECT query on a database. See the documentation

Full schema: https://pipedream.com/apps/aws/actions/redshift-query-database.md

### `aws-redshift-update-rows` — Redshift - Update Rows (Write)

Update row(s) in an existing table in Redshift. See the documentation

Full schema: https://pipedream.com/apps/aws/actions/redshift-update-rows.md

### `aws-s3-download-file-to-tmp` — S3 - Download File to /tmp (Write)

Downloads a file from S3 to the /tmp directory. See the documentation

Full schema: https://pipedream.com/apps/aws/actions/s3-download-file-to-tmp.md

### `aws-s3-generate-presigned-url` — S3 - Generate Presigned URL (Write)

Creates a presigned URL to download from a bucket. See the documentation

Full schema: https://pipedream.com/apps/aws/actions/s3-generate-presigned-url.md

### `aws-s3-upload-base64-as-file` — S3 - Upload Base64 As File (Write)

Accepts a base64-encoded string and a filename, then uploads as a file to S3. See the documentation

Full schema: https://pipedream.com/apps/aws/actions/s3-upload-base64-as-file.md

### `aws-s3-upload-files` — S3 - Upload Files (Write)

Upload files to S3. Accepts either a file URL, a local file path, or a directory path. See the documentation

Full schema: https://pipedream.com/apps/aws/actions/s3-upload-files.md

### `aws-sns-send-message` — SNS - Send Message (Write)

Sends a message to a SNS Topic. See docs

Full schema: https://pipedream.com/apps/aws/actions/sns-send-message.md

### `aws-sqs-send-message` — SQS - Send Message (Write)

Sends a message to an SQS queue. See the docs

Full schema: https://pipedream.com/apps/aws/actions/sqs-send-message.md

## Triggers (11)

### `aws-new-sns-messages` — New SNS Messages (Instant)

Creates an SNS topic in your AWS account. Messages published to this topic are emitted from the Pipedream source.

Full schema: https://pipedream.com/apps/aws/triggers/new-sns-messages.md

### `aws-new-emails-sent-to-ses-catch-all-domain` — New Inbound SES Emails (Instant)

The source subscribes to all emails delivered to a specific domain configured in AWS SES. When an email is sent to any address at the domain, this event source emits that email as a formatted event. These events can trigger a Pipedream workflow and can be consumed via SSE or REST API.

Full schema: https://pipedream.com/apps/aws/triggers/new-emails-sent-to-ses-catch-all-domain.md

### `aws-s3-deleted-file` — New Deleted S3 File (Instant)

Emit new event when a file is deleted from a S3 bucket

Full schema: https://pipedream.com/apps/aws/triggers/s3-deleted-file.md

### `aws-new-dynamodb-stream-event` — New DynamoDB Stream Event (Polling)

Emit new event when a DynamoDB stream receives new events. See the docs here

Full schema: https://pipedream.com/apps/aws/triggers/new-dynamodb-stream-event.md

### `aws-new-records-returned-by-cloudwatch-logs-insights-query` — New Records Returned by CloudWatch Logs Insights Query (Polling)

Executes a CloudWatch Logs Insights query on a schedule, and emits the records as invidual events (default) or in batch

Full schema: https://pipedream.com/apps/aws/triggers/new-records-returned-by-cloudwatch-logs-insights-query.md

### `aws-s3-restored-file` — New Restored S3 File (Instant)

Emit new event when a file is restored into an S3 bucket

Full schema: https://pipedream.com/apps/aws/triggers/s3-restored-file.md

### `aws-s3-new-event` — New S3 Event (Instant)

Emit new S3 events for a given bucket

Full schema: https://pipedream.com/apps/aws/triggers/s3-new-event.md

### `aws-s3-new-file` — New S3 File (Instant)

Emit new event when a file is added to an S3 bucket

Full schema: https://pipedream.com/apps/aws/triggers/s3-new-file.md

### `aws-rds-new-event` — New Update to AWS RDS Database (Instant) (Instant)

Emit new event when there is an update to an AWS RDS Database.

Full schema: https://pipedream.com/apps/aws/triggers/rds-new-event.md

### `aws-redshift-new-row` — Redshift - New Row (Polling)

Emit new event when a new row is added to a table. See the documentation

Full schema: https://pipedream.com/apps/aws/triggers/redshift-new-row.md

### `aws-redshift-updated-row` — Redshift - Updated Row (Polling)

Emit new event when a row is updated, based on a selected timestamp column. See the documentation

Full schema: https://pipedream.com/apps/aws/triggers/redshift-updated-row.md

---

- All apps: https://pipedream.com/apps — index: https://pipedream.com/llms.txt
- Pipedream docs for agents: https://pipedream.com/docs/llms.txt