Atlas レイテンシ削減に関するガイダンス

1// File: App.java2
3import java.util.Map;4import java.util.logging.Logger;5
6import org.bson.Document;7import org.json.JSONArray;8
9import com.mongodb.MongoException;10import com.mongodb.client.MongoClient;11import com.mongodb.client.MongoClients;12import com.mongodb.client.MongoCollection;13import com.mongodb.client.MongoDatabase;14
15import fi.iki.elonen.NanoHTTPD;16
17public class App extends NanoHTTPD {18    private static final Logger LOGGER = Logger.getLogger(App.class.getName());19
20    static int port = 3000;21    static MongoClient client = null;22
23    public App() throws Exception {24        super(port);25
26        // Replace the uri string with your MongoDB deployment's connection string27        String uri = "<atlas-connection-string>";28        client = MongoClients.create(uri);29
30        start(NanoHTTPD.SOCKET_READ_TIMEOUT, false);31        LOGGER.info("\nStarted the server: http://localhost:" + port + "/ \n");32    }33
34    public static void main(String[] args) {35        try {36            new App();37        } catch (Exception e) {38            LOGGER.severe("Couldn't start server:\n" + e);39        }40    }41
42    @Override43    public Response serve(IHTTPSession session) {44        StringBuilder msg = new StringBuilder();45        Map<String, String> params = session.getParms();46
47        Method reqMethod = session.getMethod();48        String uri = session.getUri();49
50        if (Method.GET == reqMethod) {51            if (uri.equals("/")) {52                msg.append("Welcome to my API!");53            } else if (uri.equals("/users")) {54                msg.append(listUsers(client));55            } else {56                msg.append("Unrecognized URI: ").append(uri);57            }58        } else if (Method.POST == reqMethod) {59            try {60                String name = params.get("name");61                if (name == null) {62                    throw new Exception("Unable to process POST request: 'name' parameter required");63                } else {64                    insertUser(client, name);65                    msg.append("User successfully added!");66                }67            } catch (Exception e) {68                msg.append(e);69            }70        }71
72        return newFixedLengthResponse(msg.toString());73    }74
75    static String listUsers(MongoClient client) {76        MongoDatabase database = client.getDatabase("test");77        MongoCollection<Document> collection = database.getCollection("users");78
79        final JSONArray jsonResults = new JSONArray();80        collection.find().forEach((result) -> jsonResults.put(result.toJson()));81
82        return jsonResults.toString();83    }84
85    static String insertUser(MongoClient client, String name) throws MongoException {86        MongoDatabase database = client.getDatabase("test");87        MongoCollection<Document> collection = database.getCollection("users");88
89        collection.insertOne(new Document().append("name", name));90        return "Successfully inserted user: " + name;91    }92}

1const express = require('express');2const bodyParser = require('body-parser');3
4// Use the latest client libraries by installing & importing them5const MongoClient = require('mongodb').MongoClient;6
7const app = express();8app.use(bodyParser.json());9app.use(bodyParser.urlencoded({ extended: true }));10
11const uri = "mongodb+srv://<db_username>:<db_password>@cluster0-111xx.mongodb.net/test?retryWrites=true&w=majority";12
13const client = new MongoClient(uri, {14    useNewUrlParser: true,15    useUnifiedTopology: true16});17
18// ----- API routes ----- //19app.get('/', (req, res) => res.send('Welcome to my API!'));20
21app.get('/users', (req, res) => {22    const collection = client.db("test").collection("users");23
24    collection25    .find({})26    .maxTimeMS(5000)27    .toArray((err, data) => {28        if (err) {29            res.send("The request has timed out. Please check your connection and try again.");30        }31        return res.json(data);32    });33});34
35app.post('/users', (req, res) => {36    const collection = client.db("test").collection("users");37    collection.insertOne({ name: req.body.name })38    .then(result => {39        res.send("User successfully added!");40    }, err => {41        res.send("An application error has occurred. Please try again.");42    })43});44// ----- End of API routes ----- //45
46app.listen(3000, () => {47    console.log(`Listening on port 3000.`);48    client.connect(err => {49        if (err) {50            console.log("Not connected: ", err);51            process.exit(0);52        }53        console.log('Connected.');54    });55});

1# File: main.py2
3from fastapi import FastAPI, Body, Request, Response, HTTPException, status4from fastapi.encoders import jsonable_encoder5
6from typing import List7from models import User8
9import pymongo10from pymongo import MongoClient11from pymongo import errors12
13# Replace the uri string with your |service| connection string14uri = "<atlas-connection-string>"15db = "test"16
17app = FastAPI()18
19@app.on_event("startup")20def startup_db_client():21    app.mongodb_client = MongoClient(uri)22    app.database = app.mongodb_client[db]23
24@app.on_event("shutdown")25def shutdown_db_client():26    app.mongodb_client.close()27
28##### API ROUTES #####29@app.get("/users", response_description="List all users", response_model=List[User])30def list_users(request: Request):31    try:32        users = list(request.app.database["users"].find().max_time_ms(5000))33        return users34    except pymongo.errors.ExecutionTimeout:35        raise HTTPException(status_code=status.HTTP_503_SERVICE_UNAVAILABLE, detail="The request has timed out. Please check your connection and try again.")36
37@app.post("/users", response_description="Create a new user", status_code=status.HTTP_201_CREATED)38def new_user(request: Request, user: User = Body(...)):39    user = jsonable_encoder(user)40    try:41        new_user = request.app.database["users"].insert_one(user)42        return {"message":"User successfully added!"}43    except pymongo.errors.DuplicateKeyError:44        raise HTTPException(status_code=status.HTTP_400_BAD_REQUEST, detail="Could not create user due to existing '_id' value in the collection. Try again with a different '_id' value.")