Windmill Hub
Windmill's community hub
Share scripts, workflows and UIs
Search Documents
(
mongodb)
Verified
Created by rossumblament 293 days ago Viewed 524 times 1 Point
No comments yet
Points:
0
Approved
submission
deno
import { Resource } from "https://deno.land/x/windmill@v1.70.1/mod.ts";
import { removeObjectEmptyFields } from "https://deno.land/x/windmill_helpers@v1.0.1/mod.ts";
import { MongoClient } from "https://deno.land/x/atlas_sdk@v1.0.3/mod.ts";
/**
* @param data_source For example: `Cluster0`
*
* @param filter For example: `{ "_id": "01234" }`
* Find out more at:
* https://www.mongodb.com/docs/manual/reference/method/db.collection.find/
*/
export async function main(
auth: Resource<"mongodb_rest">,
data_source: string,
database: string,
collection: string,
filter?: Record<string, any>,
projection?: Record<string, number>,
sort?: Record<string, number>,
limit?: number,
skip?: number,
) {
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.find(
filter,
removeObjectEmptyFields({ projection, sort, limit, skip }),
);
}
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", }, }); @param: {object} filter - Object to filter mongodb documents example: { username: { $ne: null } } */ export async function main( mongodb_con: wmill.Resource<"mongodb">, db_name: string, collection_name: string, filter: object ) { const client = new MongoClient(); // Connecting to a Mongo Atlas Database const resp = await client.connect(mongodb_con); const db = client.database(db_name); const collection = db.collection(collection_name); const all_collection = await collection.find(filter).toArray(); return (all_collection ? 'Documents Found in MongoDB' : 'Documents Not Found'); }Login to be able to commentNo comments yet