Airtable

Create, update or delete single or multiple records in your bases.

Using our official Airtable integration

Create any tasks possible with the Airtable API.

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

Example code using Airtable

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

Update Airtable when a new subscription is added to Stripe.Add a new record to Airtable when a Typeform response is submitted.Update Airtable database when there is a sale in Stripe.

1
import { TriggerClient } from "@trigger.dev/sdk";
2
import { Stripe } from "@trigger.dev/stripe";
3
import { Airtable } from "@trigger.dev/airtable";
4
const stripe = new Stripe({
5
  id: "stripe",
6
  apiKey: process.env.STRIPE_API_KEY!,
7
});
8

9
const airtable = new Airtable({
10
  id: "airtable",
11
  token: process.env.AIRTABLE_TOKEN!,
12
});
13

14
type Customers = {
15
  stripe_customer_id?: string;
16
  Sales?: string[];
17
};
18

19
type Sales = {
20
  payment_intent_id: string;
21
  amount: number;
22
  currency: string;
23
  Customers?: string[];
24
  "stripe_customer_id (from Customers)": string;
25
};
26

27
client.defineJob({
28
  id: "stripe-new-sale-update-airtable",
29
  name: "On new Stripe sale update Airtable",
30
  version: "1.0.0",
31
  integrations: {
32
    stripe,
33
    airtable,
34
  },
35
  trigger: stripe.onPaymentIntentSucceeded(),
36
  run: async (payload, io, ctx) => {
37
    const customersTable = io.airtable
38
      .base("<your base id>")
39
      .table<Customers>("<your table name>");
40

41
    const salesTable = io.airtable
42
      .base("<your base id>")
43
      .table<Sales>("<your table name>");
44

45
    const {
46
      id: payment_intent_id,
47
      customer: stripe_customer_id,
48
      amount,
49
      currency,
50
    } = payload;
51

52
    // Use the filter formula to find a customer record with the given stripe_customer_id
53
    const records = await customersTable.getRecords(
54
      "Filter records by stripe_customer_id",
55
      {
56
        filterByFormula: `{stripe_customer_id} = "${stripe_customer_id}"`,
57
        fields: ["stripe_customer_id"],
58
      }
59
    );
60

61
    let customerRecordId;
62
    if (records && records.length > 0) {
63
      // There is an existing customer
64
      customerRecordId = records[0].id;
65
    } else {
66
      const newCustomerRecord = await customersTable.createRecords(
67
        "create new customer record",
68
        [
69
          {
70
            fields: { stripe_customer_id: stripe_customer_id as string },
71
          },
72
        ]
73
      );
74
      customerRecordId = newCustomerRecord[0].id;
75
    }
76

77
    // Add sale to the Sales table
78
    const newSaleRecord = await salesTable.createRecords(
79
      "create new sale record",
80
      [
81
        {
82
          fields: {
83
            payment_intent_id,
84
            amount,
85
            currency,
86
            Customers: [customerRecordId], // Link to the customer record using its ID
87
          },
88
        },
89
      ]
90
    );
91
  },
92
});