[新手开源] 使用 Tornado 搭建 RESTful 接口服务

[nekocode]

作为一个「人生苦短，我用 Python 」的程序员，最近毅然决然地决定使用 Tornado 搭建一个社交应用的服务后端。现在在开发途中积累了很多不错的东西，打算分享给有这方面需求的人。

我在开发该社交应用（图片问答社区）中，使用了以下一些工具：
Tornado ， MongoDB ， Redis ， Qiniu ， MQTT

说实话， MongoDB 真的挺适合储存社交数据的，不过 Tornado 下真的缺乏一款好用的 MongoDB 的 ORM 框架， Motor Engine 还缺乏很多功能。不知道有没有大牛能够推荐一下。

另外就是目前在实现用户 Feeds 时有些停顿，目前仍在研究如何处理会好一些，也希望有经验的大牛能提供下好的意见。

去掉大部分的业务逻辑的壳，需要的拿去，也欢迎 Star ， PR ：
TornaREST . Github

[dai269619118]

支持一下 有空了下载过来看下

[nekocode]

@dai269619118 谢谢支持~

[tonghuashuai]

MongoDB 的 ORM 我们用的 pymongo ，然后做了一点修改，使用起来完全无痛，非常顺手

[nekocode]

做的修改是让 pymongo 支持异步？

这里有一篇文章，是针对 tornado 下的 ORM 框架的对比测试，你可以看看：
http://www.cnblogs.com/restran/p/4937673.html

[nekocode]

@tonghuashuai

[withrock]

刚好派上用场，请收下我的膝盖！

[withrock]

就是对你起的这个项目名称不太满意
tornado + rest = tornaRST ???

[tonghuashuai]

@nekocode
也没什么大修改，就是根据 model 名字自动设置 __collection__ 以及加了个迭代查询的方法

[nekocode]

@withrock
tornado 和 REST 是不同概念的东西，无法相提并论，所以我用的是 & 操作符，而不是 +。至于名称的话，不用太在意，随便起的而已 ✪ε✪

[mapleray]

弱弱问下，`user = yield User.objects.get(user_id)` 和 `schools = yield School.objects.find_all()` 这里用`yield` 的好处？没怎么看懂...

[ethego]

用 gevent 另外包一个线程或者开一个线程池代理 pymongo ， tornado 的数据库请求全往这里发，应该可以解决阻塞的问题。

[phithon]

并没有用 orm ，好像没见过有异步的 orm ？求推荐， mysql/mongo

[ethego]

@phithon 没必要，异步也是在 orm 外部做， orm 不是干这个的。

[strahe]

一直用 pymongo ， mongodb 原生的操作更爽，你只是需要稍微适应一下

[cloudzhou]

我想问一下 mqtt 用在哪里？

[nekocode]

@mapleray
这是利用 yield 关键字来实现异步操作，具体实现要看 tornado 的 gen 装饰器。


@phithon
@strahe
我之前在使用 MySQL 的时候，一直用的是 torndb ，也并非 ORM 库。


@cloudzhou
MQTT 用在实现消息推送上， MQTT 比起其他协议（例如 XMPP ）简单高效多了。

[ericls]

motor 在 aiohttp 下还是很不错哒感觉

[nekocode]

@ericls 异步实现上，好像也就 motor 靠谱些了

[latyas]

ThreadPool + pymongo 保证没坑
用 motor 的话还是悠着点好

[phithon]

@ethego
我知道 orm 不是干这个的，但具体怎么实现『在外部做』，求指导？
有封装了的可以直接用的么？

[zhuf]

mongoengine 啊

[nekocode]

@latyas 实现起来太麻烦了。

@phithon https://motor.readthedocs.org/en/latest/index.html

@zhuf mongoengine 不是非阻塞的。 motorengine 是 mongoengine 针对 tornado 的 port 版本。

[neoblackcap]

@phithon 要不就是多线程 /多进程池，要不就是消息队列。再来就是 microservice ，然后用 AsyncHttpClient 调用。

PS ：毕竟数据库操作都是 IO 密集型，因此用多线程也是可以的。

[fhefh]

学习了 mark

[SaberSalv]

为什么都喜欢绑定? 比如我不想用 MongoDB 怎么办?

[nekocode]

@SaberSalv 很抱歉，我并没有把它做成可拆卸的，想使用 MySQL 的话必须自己修改代码（推荐使用 torndb ）。我写它的出发点在于创建一个提供社交接口的高性能的后端，所以在栈选择上比较极端。

[phithon]

@nekocode
这个并不是 orm 呀。。。我写的一个项目就是用的 motor https://github.com/phith0n/Minos

[nekocode]

@phithon
需要 ORM 的话可以看看这个： https://github.com/heynemann/motorengine
我在代码里面就是使用它的，具体可以查阅我的 Github Repo

[phithon]

@nekocode 已关注~

[anson008]

https://github.com/PyMySQL/Tornado-MySQL
我目前一个 websocket 项目中用的 tornado+异步 mysql db 读写
希望和大家多多交流

[latyas]

@nekocode 不麻烦

from concurrent.futures import ThreadPoolExecutor

tpool = ThreadPoolExecutor()

asyncio 的话 await asyncio.wrap_future(tpool.submit(target, *args, **kwargs)) 即可，
tornado 也有用 concurrent 库的接口。

[withrock]

@gen.coroutine
13 def get_all_gallerys():
14 gallery_path = "/mnt/F/Picture"
15 gallerys = []
16 for item in os.listdir(gallery_path):
17 if not os.path.isdir(item):
18 continue
19 gallery = dict(
20 name = item,
21 path = os.path.join(gallery_path, item)
22 )
23 gallerys.append(gallery)
24 raise gen.Return(gallerys)
25
26 class GalleryHandler(BaseHandler):
27 def data_received(self, chunk):
28 pass
29
30 @tornado.web.asynchronous
31 @gen.coroutine
32 def get(self):
33 ret = yield get_all_gallerys()
34 print ret
35 self.write_json(ret)


@nekocode
请问这样调用，想在这个 handle 里返回一个目录下的所有文件夹，但是返回的消息却是
{"msg": "success.", "code": 200, "data": []}
后台没有打印报错信息
只是： 304 GET /api/photo/gallerys (::1)
请问这样该怎么办呢？