0
276
Views¿Cómo conectarse correctamente a MongoDB usando las funciones de la nube?
Me gustaría conectarme a mi clúster de Atlas solo una vez por instancia que ejecute Cloud Functions.
Aquí está mi código para una instancia:
const MongoClient = require("mongodb").MongoClient; const client = new MongoClient("myUrl", { useNewUrlParser: true, useUnifiedTopology: true, }); exports.myHttpMethod = functions.region("europe-west1").runWith({ memory: "128MB", timeoutSeconds: 20, }).https.onCall((data, context) => { console.log("Data is: ", data); client.connect(() => { const testCollection = client.db("myDB").collection("test"); testCollection.insertOne(data); }); }); Y me gustaría evitar client.connect() en cada llamada de función que parece ser demasiado.
Me gustaría hacer algo como esto:
const MongoClient = require("mongodb").MongoClient; const client = await MongoClient.connect("myUrl", { useNewUrlParser: true, useUnifiedTopology: true, }); const db = client.db("myDB"); exports.myHttpMethod = functions.region("europe-west1").runWith({ memory: "128MB", timeoutSeconds: 20, }).https.onCall((data, context) => { console.log("Data is: ", data); const testCollection = db.collection("test"); testCollection.insertOne(data); }); Pero no puedo await así.
En mis funciones AWS Lambda (que se ejecutan en python) no tengo este problema y solo puedo conectarme una vez por instancia, así que supongo que hay un equivalente pero no sé mucho JS / Node JS.
1 answers
Answer question0
Puede almacenar su cliente de base de datos como una variable global . De la documentación,
Cloud Functions a menudo recicla el entorno de ejecución de una invocación anterior. Si declara una variable en ámbito global, su valor se puede reutilizar en invocaciones posteriores sin tener que volver a calcular.
Intente refactorizar el código como se muestra a continuación:
import * as functions from "firebase-functions"; import { MongoClient } from "mongodb"; let client: MongoClient | null; const getClient = async () => { if (!client) { const mClient = new MongoClient("[MONGODB_URI]", {}); client = await mClient.connect(); functions.logger.log("Connected to MongoDB"); } else { functions.logger.log("Using existing MongoDB connection"); } functions.logger.log("Returning client"); return client; }; export const helloWorld = functions.https.onRequest( async (request, response) => { const db = (await getClient()).db("[DATABASE]"); const result = await db.collection("[COLLECTION]").findOne({}); response.send("Hello from Firebase!"); } );Esto debería reutilizar la conexión para esa instancia.
