Desenvolvimento local com MongoDB Atlas CLI e Docker

1
npm init -y
2
npm install express mongodb

1
{
2
    "name": "mongodbexample",
3
    "version": "1.0.0",
4
    "description": "",
5
    "main": "main.js",
6
    "scripts": {
7
        "test": "echo \"Error: no test specified\" && exit 1",
8
        "start": "node main.js"
9
    },
10
    "keywords": [],
11
    "author": "",
12
    "license": "ISC",
13
    "dependencies": {
14
        "express": "^4.18.2",
15
        "mongodb": "^4.12.1"
16
    }
17
}

1
const { MongoClient } = require("mongodb");
2
const Express = require("express");
3
4
const app = Express();
5
6
const mongoClient = new MongoClient(process.env.MONGODB_ATLAS_URI);
7
let database, collection;
8
9
app.get("/data", async (request, response) => {
10
    try {
11
        const results = await collection.find({}).limit(5).toArray();
12
        response.send(results);
13
    } catch (error) {
14
        response.status(500).send({ "message": error.message });
15
    }
16
});
17
18
const server = app.listen(3000, async () => {
19
    try {
20
        await mongoClient.connect();
21
        database = mongoClient.db(process.env.MONGODB_DATABASE);
22
        collection = database.collection(`${process.env.MONGODB_COLLECTION}`);
23
        collection.insertOne({ "firstname": "Nic", "lastname": "Raboy" });
24
        console.log("Listening at :3000");
25
    } catch (error) {
26
        console.error(error);
27
    }
28
});
29
30
process.on("SIGTERM", async () => {
31
    if(process.env.CLEANUP_ONDESTROY == "true") {
32
        await database.dropDatabase();
33
    }
34
    mongoClient.close();
35
    server.close(() => {
36
        console.log("NODE APPLICATION TERMINATED!");
37
    });
38
});

1
const server = app.listen(3000, async () => {
2
    try {
3
        await mongoClient.connect();
4
        database = mongoClient.db(process.env.MONGODB_DATABASE);
5
        collection = database.collection(`${process.env.MONGODB_COLLECTION}`);
6
        collection.insertOne({ "firstname": "Nic", "lastname": "Raboy" });
7
        console.log("Listening at :3000");
8
    } catch (error) {
9
        console.error(error);
10
    }
11
});

1
app.get("/data", async (request, response) => {
2
    try {
3
        const results = await collection.find({}).limit(5).toArray();
4
        response.send(results);
5
    } catch (error) {
6
        response.status(500).send({ "message": error.message });
7
    }
8
});

1
process.on("SIGTERM", async () => {
2
    if(process.env.CLEANUP_ONDESTROY == "true") {
3
        await database.dropDatabase();
4
    }
5
    mongoClient.close();
6
    server.close(() => {
7
        console.log("NODE APPLICATION TERMINATED!");
8
    });
9
});

1
#!/usr/bin/env zx
2
3
$.verbose = true;
4
5
const runtimeTimestamp = Date.now();
6
7
process.env.MONGODB_CLUSTER_NAME = process.env.MONGODB_CLUSTER_NAME || "examples";
8
process.env.MONGODB_USERNAME = process.env.MONGODB_USERNAME || "demo";
9
process.env.MONGODB_PASSWORD = process.env.MONGODB_PASSWORD || "password1234";
10
process.env.MONGODB_DATABASE = process.env.MONGODB_DATABASE || "business_" + runtimeTimestamp;
11
process.env.MONGODB_COLLECTION = process.env.MONGODB_COLLECTION || "people_" + runtimeTimestamp;
12
process.env.CLEANUP_ONDESTROY = process.env.CLEANUP_ONDESTROY || false;
13
14
var app;
15
16
process.on("SIGTERM", () => { 
17
    app.kill("SIGTERM");
18
});
19
20
try {
21
    let createClusterResult = await $`atlas clusters create ${process.env.MONGODB_CLUSTER_NAME} --tier M0 --provider AWS --region US_EAST_1 --output json`;
22
    await $`atlas clusters watch ${process.env.MONGODB_CLUSTER_NAME}`
23
    let loadSampleDataResult = await $`atlas clusters loadSampleData ${process.env.MONGODB_CLUSTER_NAME} --output json`;
24
} catch (error) {
25
    console.log(error.stdout);
26
}
27
28
try {
29
    let createAccessListResult = await $`atlas accessLists create --currentIp --output json`;
30
    let createDatabaseUserResult = await $`atlas dbusers create --role readWriteAnyDatabase,dbAdminAnyDatabase --username ${process.env.MONGODB_USERNAME} --password ${process.env.MONGODB_PASSWORD} --output json`;
31
    await $`sleep 10`
32
} catch (error) {
33
    console.log(error.stdout);
34
}
35
36
try {
37
    let connectionString = await $`atlas clusters connectionStrings describe ${process.env.MONGODB_CLUSTER_NAME} --output json`;
38
    let parsedConnectionString = new URL(JSON.parse(connectionString.stdout).standardSrv);
39
    parsedConnectionString.username = encodeURIComponent(process.env.MONGODB_USERNAME);
40
    parsedConnectionString.password = encodeURIComponent(process.env.MONGODB_PASSWORD);
41
    parsedConnectionString.search = "retryWrites=true&w=majority";
42
    process.env.MONGODB_ATLAS_URI = parsedConnectionString.toString();
43
    app = $`node main.js`;
44
} catch (error) {
45
    console.log(error.stdout);
46
}

1
process.env.MONGODB_CLUSTER_NAME = process.env.MONGODB_CLUSTER_NAME || "examples";
2
process.env.MONGODB_USERNAME = process.env.MONGODB_USERNAME || "demo";
3
process.env.MONGODB_PASSWORD = process.env.MONGODB_PASSWORD || "password1234";
4
process.env.MONGODB_DATABASE = process.env.MONGODB_DATABASE || "business_" + runtimeTimestamp;
5
process.env.MONGODB_COLLECTION = process.env.MONGODB_COLLECTION || "people_" + runtimeTimestamp;
6
process.env.CLEANUP_ONDESTROY = process.env.CLEANUP_ONDESTROY || false;

1
process.on("SIGTERM", () => { 
2
    app.kill("SIGTERM");
3
});

1
try {
2
    let createClusterResult = await $`atlas clusters create ${process.env.MONGODB_CLUSTER_NAME} --tier M0 --provider AWS --region US_EAST_1 --output json`;
3
    await $`atlas clusters watch ${process.env.MONGODB_CLUSTER_NAME}`
4
    let loadSampleDataResult = await $`atlas clusters loadSampleData ${process.env.MONGODB_CLUSTER_NAME} --output json`;
5
} catch (error) {
6
    console.log(error.stdout);
7
}

1
try {
2
    let createAccessListResult = await $`atlas accessLists create --currentIp --output json`;
3
    let createDatabaseUserResult = await $`atlas dbusers create --role readWriteAnyDatabase,dbAdminAnyDatabase --username ${process.env.MONGODB_USERNAME} --password ${process.env.MONGODB_PASSWORD} --output json`;
4
    await $`sleep 10`
5
} catch (error) {
6
    console.log(error.stdout);
7
}

1
try {
2
    let connectionString = await $`atlas clusters connectionStrings describe ${process.env.MONGODB_CLUSTER_NAME} --output json`;
3
    let parsedConnectionString = new URL(JSON.parse(connectionString.stdout).standardSrv);
4
    parsedConnectionString.username = encodeURIComponent(process.env.MONGODB_USERNAME);
5
    parsedConnectionString.password = encodeURIComponent(process.env.MONGODB_PASSWORD);
6
    parsedConnectionString.search = "retryWrites=true&w=majority";
7
    process.env.MONGODB_ATLAS_URI = parsedConnectionString.toString();
8
    app = $`node main.js`;
9
} catch (error) {
10
    console.log(error.stdout);
11
}

1
FROM node:18
2
3
WORKDIR /usr/src/app
4
5
COPY ./app/* ./
6
COPY ./docker_run_script.mjs ./
7
8
RUN curl https://fastdl.mongodb.org/mongocli/mongodb-atlas-cli_1.3.0_linux_x86_64.tar.gz --output mongodb-atlas-cli_1.3.0_linux_x86_64.tar.gz
9
RUN tar -xvf mongodb-atlas-cli_1.3.0_linux_x86_64.tar.gz && mv mongodb-atlas-cli_1.3.0_linux_x86_64 atlas_cli
10
RUN chmod +x atlas_cli/bin/atlas
11
RUN mv atlas_cli/bin/atlas /usr/bin/
12
13
RUN npm install -g zx
14
RUN npm install
15
16
EXPOSE 3000
17
18
CMD ["./docker_run_script.mjs"]

1
version: "3.9"
2
services:
3
    web:
4
        build:
5
            context: .
6
            dockerfile: Dockerfile
7
        ports:
8
            - "3000:3000"
9
        environment:
10
            MONGODB_ATLAS_PUBLIC_API_KEY: YOUR_PUBLIC_KEY_HERE
11
            MONGODB_ATLAS_PRIVATE_API_KEY: YOUR_PRIVATE_KEY_HERE
12
            MONGODB_ATLAS_ORG_ID: YOUR_ORG_ID_HERE
13
            MONGODB_ATLAS_PROJECT_ID: YOUR_PROJECT_ID_HERE
14
            MONGODB_CLUSTER_NAME: examples
15
            MONGODB_USERNAME: demo
16
            MONGODB_PASSWORD: password1234
17
            # MONGODB_DATABASE: sample_mflix
18
            # MONGODB_COLLECTION: movies
19
            CLEANUP_ONDESTROY: true

1
docker-compose up