Windmill Hub
Windmill's community hub
Share scripts, workflows and UIs
Create New Document
(
mongodb)
Verified
Created by armancemaripota 243 days ago Viewed 70 times 1 Point
No comments yet
Points:
0
Approved
submission
deno
import { Resource } from "https://deno.land/x/windmill@v1.55.0/mod.ts";
import { MongoClient } from "https://deno.land/x/atlas_sdk@v1.0.3/mod.ts";
/**
* @param data_source For example: `Cluster0`
*/
export async function main(
auth: Resource<"mongodb_rest">,
data_source: string,
database: string,
collection: string,
document: Record<string, any>
) {
const client = new MongoClient({
endpoint: auth.endpoint,
dataSource: data_source,
auth: { apiKey: auth.api_key },
});
const documents = client.database(database).collection(collection)
return await documents.insertOne(document)
}
No comments yet
- Points: 0deno
import * as wmill from "https://deno.land/x/windmill@v1.19.2/mod.ts"; import { Bson, MongoClient } from "https://deno.land/x/mongo@v0.30.1/mod.ts"; /* @param: {wmill.Resource} mongodb - Resource containing mongodb connection object example: await client.connect({ db: "<db_name>", tls: true, servers: [ { host: "<db_cluster_url>", port: 27017, }, ], credential: { username: "<username>", password: "<password>", db: "<db_name>", mechanism: "SCRAM-SHA-1", }, }); */ export async function main( mongodb_con: wmill.Resource<"mongodb">, new_document: object, db_name: string, collection_name: string, ) { const client = new MongoClient(); // Connecting to a Mongo Atlas Database const resp = await client.connect(mongodb_con); const db = client.database(db_name); const coll = db.collection(collection_name); const insertId = await coll.insertOne(new_document); return `Document inserted in MongoDB`; }Login to be able to commentNo comments yet