Tuesday, March 14, 2023
HomeJavascriptIntegrating Cloudinary Notifications with Pipedream

Integrating Cloudinary Notifications with Pipedream

As I proceed my journey into studying the awesomeness of the Cloudinary platform, at this time I made a decision to check out their notifications assist. Cloudinary enables you to specify a webhook URL that can be hit on various kinds of occasions. I whipped up a fast instance of utilizing this with Pipedream, my favourite service for processing webhooks. Here is how I did it.

Setting Up the URL

With a purpose to use webhooks, you possibly can both specify a Cloudinary-wide URL or specify it when utilizing sure API strategies. For my check, I started at Pipedream, created a brand new HTTP-triggered workflow, copied the URL, after which pasted it into my Cloudinary account settings:

Webhook setting at Cloudinary

Testing Occasions

By default, Cloudinary will fireplace the webhook on:

  • Importing, renaming, and deleting an asset
  • Modifying metadata for an asset
  • Modifying tags for an asset
  • Modifying entry management for an asset
  • Making a brand new folder

Since I had my Pipedream workflow arrange, I rapidly examined utilizing Cloudinary’s Media Library. I made a brand new folder and simply began dropping just a few recordsdata in.

Media Library

After importing, I confirmed that I noticed an occasion on the Pipedream aspect and confirmed the physique matched what Cloudinary documented as a part of their payload.

Pipedream event record

Cool! Now let’s construct on it…

Verifying Occasions

The Cloudinary docs recommend that you simply validate the webhook to make sure it actually got here from them. This can be a combination of checking numerous headers and the physique and such, however actually, their SDK makes this straightforward… for probably the most half. So here is their easy Node.js instance:

cloudinary.utils.verifyNotificationSignature(physique, timestamp, signature, valid_for)

This made sense, however I wasn’t positive how one can deal with valid_for. I might completely inform what it meant, “If the webhook was despatched at time X, it is solely legitimate inside a time vary Y”, however I used to be not capable of finding documentation on this argument. I ended up going to the GitHub repo for the SDK and discovering it right here:


It is in seconds, and it defaults to 7200, so I need not trouble setting it. I added this to my workflow as a brand new code step with the next logic:

import { v2 as cloudinary } from 'cloudinary';

  cloud_name: course of.env.CLOUDINARY_CLOUD_NAME, 
  api_key: course of.env.CLOUDINARY_API_KEY, 
  api_secret: course of.env.CLOUDINARY_API_SECRET,
  safe: true

export default defineComponent({
  async run({ steps, $ }) {

    let verificationResult = cloudinary.utils.verifyNotificationSignature(
        JSON.stringify(steps.set off.occasion.physique), 
        steps.set off.occasion.headers['x-cld-timestamp'], 
        steps.set off.occasion.headers['x-cld-signature']);

    if(!verificationResult) return $.stream.exit("Cloudinary verification failed.");


Outdoors of being uncertain in regards to the time, two different issues tripped me. First, Pipedream lowercases HTTP headers. Discover within the pattern above I am utilizing the lowercase model of the headers Cloudinary sends. (FYI, you can get the uncooked headers in order for you.) Secondly, the tactic needs a JSON model of the physique. Pipedream mechanically parses it to knowledge which is definitely what I might need more often than not, however on this case, I needed to rework it again to JSON.

An Instance

A primary Pipedream workflow would want the HTTP set off and the verification step, outdoors of that you’d do… properly no matter is smart. I made a decision on a workflow that may:

  • examine to see if the occasion was an add
  • ship me an electronic mail with a duplicate of the image

Let’s sort out the primary one by utilizing a Filter step that continues if a situation is true. We wish to examine the notification_type worth of the physique despatched to the workflow and wish to proceed when it is set to add. Here is the Filter step I used:

Filtering on upload events

As a reminder, I might have achieved this in a code step. Heck, I might have achieved it within the verification step too. However I like my workflows to be descriptive, away from objective, and use the built-in stuff, like Filter, every time attainable.

You possibly can quote me on this – nice instruments adapt to your choice and do not pressure you to do issues just one manner.

Subsequent, I added a step to create my HTML string. This was barely complicated as I used the Cloudinary SDK once more to create a thumbnail of the picture that was simply uploaded. Here is the whole step:

import { v2 as cloudinary } from 'cloudinary';

  cloud_name: course of.env.CLOUDINARY_CLOUD_NAME, 
  api_key: course of.env.CLOUDINARY_API_KEY, 
  api_secret: course of.env.CLOUDINARY_API_SECRET,
  safe: true

// temp:
console.log('cloud identify', course of.env.CLOUDINARY_CLOUD_NAME);
export default defineComponent({
  async run({ steps, $ }) {
    let thumb = cloudinary.picture(steps.set off.occasion.physique.public_id, { 

    let physique = `
    <h1>New Picture Add</h1>
    A brand new picture has been uploaded to your Cloudinary library. You possibly can see the picture beneath:
    <a href="${steps.set off.occasion.physique.url}">${thumb}</a>

    return physique;


Lastly, I added the built-in Pipedream step that emails you. I say this each single time I weblog, however I used the identical worth for the textual content physique of the e-mail as HTML and you shouldn’t do this in manufacturing.

Send email to self configuration

And here is the ultimate outcome:

Email sample from workflow

Need to do that your self? You can also make a duplicate right here: https://pipedream.com/new?h=tch_3brfvn

Get pleasure from, and as all the time, let me know what you assume.

Photograph by Prateek Katyal on Unsplash



Please enter your comment!
Please enter your name here

Most Popular

Recent Comments