记录 MongoEngine 生成的原始查询

Question

我需要在我的 Django 应用中记录 MongoEngine 生成的所有查询。

我不能使用cursor._query()，因为我需要记录对所有 MongoEngine 文档的查询。

日志记录应该在应用程序级别而不是数据库级别完成，因此将 MongoDB 分析级别设置为 2 将无济于事。

我发现了这个gist，看起来很有帮助，但我没看懂。

有没有更简单的方法来编写中间件或任何其他可以记录所有查询的方法。

Answer 1

我在我的项目中使用了pymongo.monitoring。

import logging
from pymongo import monitoring

class CommandLogger(monitoring.CommandListener):

    def started(self, event):
        log.debug("Command {0.command}".format(event))
        logging.info("Command {0.command_name} with request id "
                 "{0.request_id} started on server "
                 "{0.connection_id}".format(event))

    def succeeded(self, event):
        logging.info("Command {0.command_name} with request id "
                 "{0.request_id} on server {0.connection_id} "
                 "succeeded in {0.duration_micros} "
                 "microseconds".format(event))

    def failed(self, event):
        logging.info("Command {0.command_name} with request id "
                 "{0.request_id} on server {0.connection_id} "
                 "failed in {0.duration_micros} "
                 "microseconds".format(event))

monitoring.register(CommandLogger())

更详细的见：

• pymongo documentation
• 关于profiler的信息