Integrate the Schedule API with the MongoDB API

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

Popular Ways to Connect Schedule with MongoDB#

Create New Document with MongoDB API on Custom Interval from Schedule API

Schedule + MongoDB

Try it

Create New Document with MongoDB API on Daily schedule from Schedule API

Schedule + MongoDB

Try it

Create New Document with MongoDB API on Monthly Schedule from Schedule API

Schedule + MongoDB

Try it

Create New Document with MongoDB API on Weekly schedule from Schedule API

Schedule + MongoDB

Try it

Delete a Document with MongoDB API on Custom Interval from Schedule API

Schedule + MongoDB

Try it

Popular Schedule and MongoDB Triggers#

Custom Interval from the Schedule API

Trigger your workflow every N hours, minutes or seconds.

Try it

Daily schedule from the Schedule API

Trigger your workflow every day.

Try it

Monthly Schedule from the Schedule API

Trigger your workflow on one or more days each month at a specific time (with timezone support).

Try it

Weekly schedule from the Schedule API

Trigger your workflow on one or more days each week at a specific time (with timezone support).

Try it

New Collection from the MongoDB API

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

Try it

Popular Schedule and MongoDB Actions#

Create New Document with the MongoDB API

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

Try it

Delete a Document with the MongoDB API

Delete a single document by ID. See the docs here

Try it

Find Document by Id with the MongoDB API

Retrieves a single document by ID. See the docs here

Try it

Search Documents with the MongoDB API

Search for specific documents or return all documents. See the docs here

Try it

Update a Document with the MongoDB API

Updates a single document by ID. See the docs here

Try it

Overview of Schedule#

With Schedule - A trigger provided by Pipedream - You can easily build
automated workflows that run on regular times or intervals. Some examples of
things that you can build using the Schedule API include:

Automated data retrieval from a third-party service, like pulling stats from
your Salesforce account on a set schedule.
Uploading new data sets to a database with a predetermined interval.
Automatic emails to customers or leads at a certain time of the day.
Automating data analysis based on a set schedule.
Automatically optimizing social media postings according to a specified
timeline.
Updating webpages at a certain interval with newly available content.
Re-running reports on a periodic basis.
Refreshing a cache of data at a given frequency.

Overview of MongoDB#

Assuming you want a few paragraph about the MongoDB API:

MongoDB offers a powerful API that allows developers to interact with their
databases in a variety of ways. The API provides methods for performing
standard CRUD (create, read, update, delete) operations, as well as more
specialized methods like bulk write operations and aggregate queries. MongoDB
also offers a rich set of indexing options that allow developers to optimize
their queries for maximum performance. With the MongoDB API, developers can
build a wide variety of applications, from simple data-driven apps to complex
event-driven systems.

Connect MongoDB#

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()
  },
})