问题标签 [tornado-motor]

我想编写一个自定义错误日志类，它将向我显示代码返回的错误。
我不使用谷歌应用引擎，我使用 python tornado 框架。

所以任何人都可以指导我遵循的步骤。

实际上，我已经获得了从以下链接创建自定义记录器的步骤：

Python：跨所有模块的自定义日志记录

但是我如何实际将日志存储在数据库中并将其拉出并将其发布到我的前端。

实际上，我已经获得了从以下链接创建自定义记录器的步骤：

Python：跨所有模块的自定义日志记录

但是我如何实际将日志存储在 Mongodb 中并将其拉出并将其发布到我的前端。

我没有看到任何文档，我无法让它工作。

我正在执行与 pymongo 类似的操作：

所以从这里我没有得到任何结果，虽然我应该得到一个记录，因为数据库肯定是填充的：

为 A. Jesse Jiryu Davis 编辑答案

倒数第二行注释掉了“tornado.ioloop”。附加到最后一行

我正在使用的堆栈包括 tornado(async) 和 mongodb(motor) 我有一个用于处理请求数据的以下算法：

1. 来自传入请求的数据保存到特定于事件的集合中
2. 数据正在保存到统一的事件集合中

这是请求处理程序代码：

这是从请求处理程序调用的方法的代码

一切_save_%smth%都只是简单的电机 CRUD 操作，封装在函数调用中并包装在@engine装饰器中，如下所示：

因此请求数据在不同的集合中保存了两次： save_entity函数中的“特定的”和save_event函数中的“通用的” 。但实际上我看到，经常（大约 50% 的情况）被遗漏（数据未保存）并执行第二次保存。

所有数据处理和验证都是在之前进行的，因此假设抛出给 mongo 的数据是合适且有效的。

所以我想弄清楚，这种情况是如何发生的。我的猜测是 save_entity 函数设计不良，并且由于几个嵌入式函数，请求本身完成并且数据没有保存到数据库中。可以吗？

UPD添加了生产代码，所以现在情况会更清楚。我希望:) UPD 2添加了几个 CRUD 方法

我正在尝试使用龙卷风，我的用例是通过对象 ID 进行查询。

我已经看到了示例和参考，可以通过其他任何方式查询，但 ObjectID 除外。因为它是独一无二的，所以我想用它来查询。

任何建议如何使用 ObjectId 使用电机进行查询

所以我一直在研究如何编写异步代码，我想出了下面的代码：

我有以下两个问题：

1. 我们怎么能假设这段代码是异步的？我们只是依赖于使用 gen 模块使其异步的事实（当然我们需要为 gen 协程编写异步模块）
2. 为什么龙卷风会合并一个主线程？我们可以有一个主线程链接到另一个线程池的线程池吗？这个问题更倾向于我们用一个主线程实现什么？

我的 Tornado 应用程序中有 WebSocketHandler。我不确定这是使代码异步的正确方法。

我正在批量插入 mongodb 数据库。我知道插入的 99% 的记录会因为重复键错误而失败。我想在插入后打印有多少新记录插入到数据库中。所有这些都是通过 tornado motor mongodb 驱动程序在 python 中完成的，但这可能并不重要。

由于抛出异常，bulk_write_result为空。显然，我可以（除了并发问题）在插入之前和之后对完整集合进行计数，但我不喜欢仅在日志文件中的一行额外往返数据库。那么有什么方法可以发现实际插入了多少条记录？

我编写了以下简化版本的代码：

当我运行它时，我随机没有得到这两个错误或其中之一：

我正在使用 Python 3.4.3、Tornado 4.1、Pymongo 2.8、Motor 0.4.1 和 MongoDB 2.6.3。

tailable仅当和await_data选项True位于光标创建时才会出现此问题。

当我不关闭光标时，我也会收到 Pymongo 的错误。但我认为我应该明确关闭它，因为它是一个可尾游标。

我用谷歌搜索了它，但我没有运气。有什么建议么？

最新文档中的Motor教程展示了如何通过以下方式获取多个文档：tornado.gen.couroutine

然后它同步演示输出：

IOLoop.current().run_sync(do_find)

如何更改此函数，以便可以从异步中调用它handler并返回文档列表？