Introdução ao MongoDB e Tornado

1
git clone git@github.com:mongodb-developer/mongodb-with-tornado.git

1
cd mongodb-with-tornado
2
pip install -r requirements.txt

1
export DB_URL="mongodb+srv://<username>:<password>@<url>/<db>?retryWrites=true&w=majority"

1
python app.py

1
curl -X "POST" "http://localhost:8000/" \
2
    -H 'Accept: application/json' \
3
    -H 'Content-Type: application/json; charset=utf-8' \
4
    -d $'{
5
        "name": "Jane Doe",
6
        "email": "jdoe@example.com",
7
        "gpa": "3.9"
8
    }'

1
client = motor.motor_tornado.MotorClient(os.environ["MONGODB_URL"])
2
db = client.college

1
class MainHandler(tornado.web.RequestHandler):
2
3
    async def get(self, **kwargs):
4
        pass
5
6
    async def post(self):
7
        pass
8
9
    async def put(self, **kwargs):
10
        pass
11
12
    async def delete(self, **kwargs):
13
        pass

1
async def post(self):
2
    student = tornado.escape.json_decode(self.request.body)
3
    student["_id"] = str(ObjectId())
4
5
    new_student = await self.settings["db"]["students"].insert_one(student)
6
    created_student = await self.settings["db"]["students"].find_one(
7
        {"_id": new_student.inserted_id}
8
    )
9
10
    self.set_status(201)
11
    return self.write(created_student)

1
app = tornado.web.Application(
2
    [
3
        (r"/", MainHandler),
4
        (r"/(?P<student_id>\w+)", MainHandler),
5
    ],
6
    db=db,
7
)

1
async def get(self, student_id=None):
2
    if student_id is not None:
3
        if (
4
            student := await self.settings["db"]["students"].find_one(
5
                {"_id": student_id}
6
            )
7
        ) is not None:
8
            return self.write(student)
9
        else:
10
            raise tornado.web.HTTPError(404)
11
    else:
12
        students = await self.settings["db"]["students"].find().to_list(1000)
13
        return self.write({"students": students})

1
async def put(self, student_id):
2
    student = tornado.escape.json_decode(self.request.body)
3
    await self.settings["db"]["students"].update_one(
4
        {"_id": student_id}, {"$set": student}
5
    )
6
7
    if (
8
        updated_student := await self.settings["db"]["students"].find_one(
9
            {"_id": student_id}
10
        )
11
    ) is not None:
12
        return self.write(updated_student)
13
14
    raise tornado.web.HTTPError(404)

1
async def delete(self, student_id):
2
    delete_result = await db["students"].delete_one({"_id": student_id})
3
4
    if delete_result.deleted_count == 1:
5
        self.set_status(204)
6
        return self.finish()
7
8
    raise tornado.web.HTTPError(404)