AWS

Manage your AWS databases, storage, and compute resources.

Using the AWS API with Trigger.dev

You can use Trigger.dev with any existing Node SDK or even just using fetch. Using io.runTask makes your AWS background job resumable and appear in our dashboard.

Use io.runTask() and the official SDK or fetch.

Example code using AWS

Below is a working code example of how you can use AWS with Trigger.dev. These samples are open source and maintained by the community, you can copy and paste them into your own projects.

1
import { TriggerClient, eventTrigger } from "@trigger.dev/sdk";
2
import { InvokeCommand, LambdaClient, LogType } from "@aws-sdk/client-lambda";
3
import { fromEnv } from "@aws-sdk/credential-providers";
4
import z from "zod";
5

6
// Create a TriggerClient for managing trigger jobs// AWS Lambda setup assumed. For more information on AWS Lambda:
7
// https://docs.aws.amazon.com/lambda/latest/dg/getting-started.html
8

9
// Create an AWS Lambda client using AWS SDK for JavaScript (v3)
10
// For AWS SDK Lambda documentation:
11
// https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/lambda/
12
// https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/Package/-aws-sdk-client-lambda/Interface/LambdaClientConfig/
13
// AWS SDK Credential Providers:
14
// https://github.com/aws/aws-sdk-js-v3/tree/main/packages/credential-providers
15
const lambdaClient = new LambdaClient({
16
  region: process.env.AWS_REGION,
17
  credentials: fromEnv(),
18
});
19

20
// Define a Trigger job to invoke the AWS Lambda function
21
client.defineJob({
22
  // Job metadata
23
  id: "invoke-aws-lambda-function",
24
  name: "Invoke AWS Lambda function",
25
  version: "1.0.0",
26

27
  // Set up a trigger for this job, in this case, an event trigger
28
  trigger: eventTrigger({
29
    name: "aws",
30

31
    // Define the schema for the payload. In this case, it expects a function name and a payload object with length and width.
32
    schema: z.object({
33
      functionName: z.string(),
34
      payloadObject: z.object({ length: z.number(), width: z.number() }),
35
    }),
36
  }),
37

38
  // Define the code to run when the job is triggered
39
  run: async (payload, io, ctx) => {
40
    // Wrap an SDK call in io.runTask to make it resumable and display it in logs
41
    const result = await io.runTask(
42
      "Invoke Lambda",
43
      async () => {
44
        // Create an AWS Lambda invocation command
45
        const command = new InvokeCommand({
46
          FunctionName: payload.functionName,
47
          Payload: JSON.stringify(payload.payloadObject),
48
          LogType: LogType.Tail,
49
        });
50

51
        // Send the command to AWS Lambda
52
        const { Payload, LogResult } = await lambdaClient.send(command);
53

54
        // Process the Lambda response and logs
55
        const result = Buffer.from(Payload).toString();
56
        const logs = Buffer.from(LogResult, "base64").toString();
57

58
        // Return the computed area and associated logs as task output
59
        return { result, logs };
60
      },
61
      // Add metadata to the task to improve its display in the logs
62
      { name: "Invoke Lambda", icon: "aws" }
63
    );
64
  },
65
});