MongoDB is an open source NoSQL database management program.
Create a new document in a collection of your choice. See the docs here
Creates a new user in the LightSpeed VT system. See the documentation
Execute an aggregation pipeline on a MongoDB collection. See the documentation
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.
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()
},
})
LightSpeed VT is a learning management system (LMS) that provides a platform for delivering interactive training and e-learning experiences. Through the LightSpeed VT API, you can automate access to course catalogs, manage users, track progress and performance, and integrate this data with other systems. On Pipedream, you can leverage this API to create workflows that respond to events in real-time, synchronize training data with other platforms, and enhance the user learning experience with personalized automations.
import { axios } from "@pipedream/platform"
export default defineComponent({
props: {
lightspeed_vt: {
type: "app",
app: "lightspeed_vt",
}
},
async run({steps, $}) {
return await axios($, {
url: `https://webservices.lightspeedvt.net/REST/V1/users/`,
auth: {
username: `${this.lightspeed_vt.$auth.api_key}`,
password: `${this.lightspeed_vt.$auth.api_secret}`,
},
})
},
})