python - Python aiohttp电机引擎

Question

我正在尝试制作基本的注册 api，但我在使用motorengineand时遇到了一些问题aiohttp。

有人可以给我举例说明它是如何工作的吗？

这是我的代码：

from motorengine.connection import connect
from motorengine.document import Document
from motorengine.fields import StringField, DateTimeField

from aiohttp import web
import asyncio

import json


dbAdress = "mongodb+srv://test:[e-mail]/test?retryWrites=true&w=majority"
client = connect("test", dbAdress)

class Members(Document):
    __collection__ = "Members"

    name = StringField(required=True)
    password = StringField(required=True)
    register_date = DateTimeField(auto_now_on_insert=True)


async def index(request):
    response = {"status": "success"}
    return web.Response(text=json.dumps(response), status=200)


async def register(request):
    print(1)
    try:
        data = await request.json()

        print(data)
        username = data['username']
        password = data['password']

        print(username)

        if(username == "" or password == ""):
            raise KeyError
        
        print(Members.objects.filter(username=username))

        return web.Response(status=200)
    except KeyError:
        return web.Response(status=401)

app = web.Application()
app.add_routes([web.get("/", index),
                web.post("/register", register)])

web.run_app(app)

标签： pythonaiohttpmotorengine