Helper Functions

Helper functions and functional utilities to use within your Pipedream workflows

Integrate the Helper Functions API with the MongoDB API

Setup the Helper Functions API trigger to run a workflow which integrates with the MongoDB API. Pipedream's integration platform allows you to integrate Helper Functions and MongoDB remarkably fast. Free for developers.

Base64 Decode String with Helper Functions API on New Collection from MongoDB API
MongoDB + Helper Functions
 
Try it
Base64 Decode String with Helper Functions API on New Database from MongoDB API
MongoDB + Helper Functions
 
Try it
Base64 Decode String with Helper Functions API on New Document from MongoDB API
MongoDB + Helper Functions
 
Try it
Base64 Decode String with Helper Functions API on New Field in Document from MongoDB API
MongoDB + Helper Functions
 
Try it
Compare Arrays with Helper Functions API on New Collection from MongoDB API
MongoDB + Helper Functions
 
Try it
New Collection from the MongoDB API

Emit new an event when a new collection is added to a database

 
Try it
New Database from the MongoDB API

Emit new an event when a new database is added

 
Try it
New Document from the MongoDB API

Emit new an event when a new document is added to a collection

 
Try it
New Field in Document from the MongoDB API

Emit new an event when a new field is added to a document

 
Try it
Base64 Decode String with the Helper Functions API

Accepts a base64-encoded string, returns a decoded UTF-8 string

 
Try it
Create New Document with the MongoDB API

Create a new document in a collection of your choice. See the docs here

 
Try it
Compare Arrays with the Helper Functions API

Get the difference, intersection, union, or symetric difference of two arrays/sets.

 
Try it
Delete a Document with the MongoDB API

Delete a single document by ID. See the docs here

 
Try it
Convert Currency with the Helper Functions API

Convert an amount between currencies. See the documentation

 
Try it

Overview of Helper Functions

The Helper Functions app on Pipedream is a set of pre-built functions that streamline common tasks in your workflows. It acts like a Swiss Army knife for developers, providing essential tools such as format conversion, date manipulation, and text processing. By leveraging these functions, you can reduce the boilerplate code needed for routine operations, speeding up the development of intricate automations. The Helper Functions API can be a game changer when it comes to tasks like parsing dates in user-friendly formats, encoding and decoding data, or generating UUIDs, making them more efficient and less error-prone.

Overview of MongoDB

The MongoDB API provides powerful capabilities to interact with a MongoDB database, allowing you to perform CRUD (Create, Read, Update, Delete) operations, manage databases, and execute sophisticated queries. With Pipedream, you can harness these abilities to automate tasks, sync data across various apps, and react to events in real-time. It’s a combo that’s particularly potent for managing data workflows, syncing application states, or triggering actions based on changes to your data.

Connect MongoDB

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
import mongodb from 'mongodb'

export default defineComponent({
  props: {
    mongodb: {
      type: "app",
      app: "mongodb",
    },
    collection: {
      type: "string"
    },
    filter: {
      type: "object"
    }
  },
  async run({steps, $}) {
    const MongoClient = mongodb.MongoClient
    
    const {
      database,
      hostname,
      username,
      password,
    } = this.mongodb.$auth
    
    const url = `mongodb+srv://${username}:${password}@${hostname}/test?retryWrites=true&w=majority`
    const client = await MongoClient.connect(url, { 
      useNewUrlParser: true, 
      useUnifiedTopology: true 
    })
    
    const db = client.db(database)

    const results = await db.collection(this.collection).find(this.filter).toArray();
    $.export('results', results);
    
    await client.close()
  },
})