Shopify

Automate online store management, products, orders, and customers.

Using the Shopify API with Trigger.dev

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

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

Example code using Shopify

Below is a working code example of how you can use Shopify 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 { shopifyApi, ApiVersion } from "@shopify/shopify-api";
3
import z from "zod";
4

5
// Make sure to include this import
6
// see: https://github.com/Shopify/shopify-api-js/blob/main/packages/shopify-api/docs/guides/runtimes.md
7
import "@shopify/shopify-api/adapters/node";
8
// Create a Shopify custom app: https://shopify.dev/tutorials/build-a-shopify-app-with-node-and-react
9
// Shopify SDK: https://github.com/Shopify/shopify-api-js
10
// https://admin.shopify.com/store/<STORE_ID>/settings/apps/development/<APP_ID>/api_credentials
11
// Initialize the Shopify API client
12
const shopify = shopifyApi({
13
  apiKey: process.env.SHOPIFY_API_KEY,
14
  apiSecretKey: process.env.SHOPIFY_API_SECRET!,
15
  scopes: ["write_products"], // Scopes can be found on the Shopify Admin Apps page
16
  hostName: process.env.SHOPIFY_HOSTNAME!, // Ex: <STORE_ID>.myshopify.com
17
  apiVersion: ApiVersion.October23,
18
  isEmbeddedApp: false,
19
});
20

21
// Define a job to update product variant prices
22
client.defineJob({
23
  id: "shopify-product-variant-price",
24
  name: "Shopify update product variant price",
25
  version: "1.0.0",
26
  trigger: eventTrigger({
27
    name: "shopify-product-variant-price",
28
    schema: z.object({
29
      // The product variant ID can be found in the Shopify Admin product variant URL
30
      // (e.g. https://admin.shopify.com/store/<STORE_NAME>/products/<PRODUCTS_ID>/variants/<VARIANT_ID>)
31
      productVariantId: z.number(),
32
      price: z.number(), // The new price of the product variant
33
    }),
34
  }),
35
  run: async (payload, io, ctx) => {
36
    const { productVariantId: id, price } = payload;
37

38
    // Use io.runTask to make the SDK call resumable and log-friendly
39
    await io.runTask(
40
      "Shopify update product variant price",
41
      async () => {
42
        // Initialize a Shopify session
43
        const session = shopify.session.customAppSession(
44
          process.env.SHOPIFY_HOSTNAME!
45
        );
46

47
        // The access token can be found in the Shopify Admin Apps page
48
        session.accessToken = process.env.SHOPIFY_ADMIN_ACCESS_TOKEN;
49

50
        // Initialize a Shopify REST client
51
        const client = new shopify.clients.Rest({ session });
52

53
        // Update the product variant price
54
        await client.put({
55
          path: `variants/${id}`,
56
          data: { variant: { id, price } },
57
        });
58
      },
59

60
      // Add metadata to improve how the task displays in the logs
61
      { name: "Shopify update product variant price", icon: "shopify" }
62
    );
63
  },
64
});