Make an HTTP Request

In Flow Action Extensions, open HTTP Requests.

Click Create request.

Give the request a clear name such as Create Airtable product record. This is the name you will look for later inside Shopify Flow.

Select the HTTP method that Airtable expects for creating records. In most Airtable create-record setups, this is POST.

Enter your Airtable endpoint URL in the URL field.

api.airtable.com/v0/{{ secrets.airTableProductsBaseId }}/Products

In the following image, you can see how the Airtable endpoint URL maps with the base and you can adjust your url accordingly.

Add the headers required by Airtable. A common setup looks like this:

Authorization: Bearer {{ secrets.airtableAccessToken }}
Content-Type: application/json

In the request body, enter the JSON payload that Airtable should receive. Map in the product values you plan to pass from Shopify Flow.

{
  "records": {{ variables.records }}
}

the data looks like this to create the entry:

"records": [
      {
        "fields": {
          "Title": "Classic White T-Shirt",
          "Handle": "classic-white-tshirt",
          "Product ID": 1001
        }
      },
      {
        "fields": {
          "Title": "Eco-Friendly Water Bottle",
          "Handle": "eco-water-bottle",
          "Product ID": 1002
        }
      }
    ]

But in our case, we have used the records as variable and we will pass the variable as a stringified JSON array containing fields to create. We will see it next step while creating the flow.

Our final request looks like this:

Save the request. It is now available to select in the HTTP Request action in Shopify Flow.

Open Shopify Flow and create a new workflow.

Choose a schedule-based trigger and set it to run day at a certain time, I am running this every 10 minutes for DEMO purpose.

This gives you a recurring workflow that checks for products regularly.

Fech the products that are not yet available in Airtable. The products that are added to Airtable get the tag added-to-airtable in the last step of this flow. In this step we are fetch products that are not tagged with added-to-airtable you can learn more about the query params from this link

Now we will format the data to pass in the HTTP request, you can see in the step 5 of HTTP request creation, in the body we were using the variable records and in this step we will format the fetched product data to pass as variable to the HTTP request. Select Run code action from the Flow.



Then configure the step like this:

query {
  getProductData {
    id
    handle
    title
  }
}

export default function main(input) {
  const records = input.getProductData.map((data) => {
    const numericId = parseInt(data.id.replace("gid://shopify/Product/", ""));
    return {
      fields: {
        "Product ID": numericId,
        "Title": data.title,
        "Handle": data.handle
      }
    };
  });

  return {
    records: JSON.stringify(records)
  };
}

"The output of Run Code"
type Output {
  "The message returned by the script"
  records: String
}

This gives you code that you can preview in right side

Add the HTTP Request action provided by Flow Action Extensions.

When prompted to choose a request, select the request you created earlier, such as Create Airtable product record.


Then select the request, hit save and go back to flow.

In the HTTP Request Variables input, we will pass the records that we formatted in the previous step.

{
  "records": "{{runCode.records}}"
}

These records will be pushed to the HTTP request body.

Now Iterate through all the products that were fetched in the earlier step and tag them added-to-airtable so that these products are not fetched next time the flow runs.

Save and activate the workflow.