AsyncMongo技术文档

1. 安装指南

AsyncMongo 是一个构建在 tornado ioloop 上的异步 MongoDB 访问库。安装过程非常简单，只需使用 pip 命令即可：

pip install asyncmongo

确保在安装前已经安装了 pymongo（版本 1.9 或以上）和 tornado 这两个依赖库。

2. 项目使用说明

AsyncMongo 的语法尽量与 pymongo 保持一致，以便用户能够更容易地进行迁移。下面是一个简单的使用示例：

首先，你需要导入 asyncmongo 和 tornado.web：

import asyncmongo
import tornado.web

然后，创建一个继承自 tornado.web.RequestHandler 的处理器，并在其中使用 asyncmongo.Client 来连接数据库：

class Handler(tornado.web.RequestHandler):
    @property
    def db(self):
        if not hasattr(self, '_db'):
            self._db = asyncmongo.Client(
                pool_id='mydb',
                host='127.0.0.1',
                port=27017,
                maxcached=10,
                maxconnections=50,
                dbname='test'
            )
        return self._db

在处理器的 get 方法中，你可以使用 find 方法来查询数据，并将查询结果通过回调函数 _on_response 返回：

class Handler(tornado.web.RequestHandler):
    # ...（之前的代码）

    @tornado.web.asynchronous
    def get(self):
        self.db.users.find(
            {'username': self.current_user},
            limit=1,
            callback=self._on_response
        )

最后，实现 _on_response 方法来处理查询结果：

class Handler(tornado.web.RequestHandler):
    # ...（之前的代码）

    def _on_response(self, response, error):
        if error:
            raise tornado.web.HTTPError(500)
        self.render('template', full_name=response['full_name'])

3. 项目API使用文档

AsyncMongo 的 API 设计与 pymongo 类似，下面是一些基本的使用方法：

• 创建客户端：

client = asyncmongo.Client(pool_id='mydb', host='127.0.0.1', port=27017, maxcached=10, maxconnections=50, dbname='test')

• 连接到特定的集合：

conn = client.connection(collectionname="your_collection", dbname="your_dbname")

• 查询数据：

conn.find(query, callback=your_callback)

• 插入数据：

conn.insert(document, callback=your_callback)

更多 API 使用方法，请参考 pymongo 的文档。

4. 项目安装方式

AsyncMongo 可以通过 pip 进行安装：

pip install asyncmongo

在安装之前，请确保你的系统中已经安装了 pymongo（版本 1.9 或以上）和 tornado 这两个库。