New Records Returned by CloudWatch Logs Insights Query

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 deployed = await pd.triggers.deploy({
  id: "aws-new-records-returned-by-cloudwatch-logs-insights-query",
  externalUserId: "{external_user_id}", // any stable ID for this user in your system
  configuredProps: {
    aws: { authProvisionId: "apn_xxxxxxx" },
    region: "AWS Region",
    logGroupNames: ["CloudWatch Log Groups"],
  },
  webhookUrl: "https://example.com/webhooks/aws",
})

console.log(deployed.id)

curl -X POST https://api.pipedream.com/v1/connect/{project_id}/triggers/deploy \
  -H "Content-Type: application/json" \
  -H "X-PD-Environment: production" \
  -H "Authorization: Bearer {access_token}" \
  -d '{
    "external_user_id": "{external_user_id}",
    "id": "aws-new-records-returned-by-cloudwatch-logs-insights-query",
    "webhook_url": "https://example.com/webhooks/aws",
    "configured_props": {
      "aws": { "authProvisionId": "apn_xxxxxxx" },
      "region": "AWS Region",
      "logGroupNames": ["CloudWatch Log Groups"]
    }
  }'

MCP servers expose AWS actions as on-demand tools.

New Records Returned by CloudWatch Logs Insights Query is an event source, so your application deploys it
with the Connect SDK or API and then either receives each event at a
webhook URL or retrieves events on demand with the trigger events API.