问题标签 [rethinkdb-python]

我在 rethinkdb 表中有以下 json 行。

我试图过滤那些 sid 的 et 值大于等于输入值的 sk 字段。

我试过下面的代码，它不起作用

请注意，sk 字段最多可包含 10 行

过滤后，我想再次对 ['wc'] 的结果数据集应用过滤器（对于 ge）

我错过了什么？

我想使用 rethinkdb .changes() 功能向用户推送一些消息。消息应该在没有来自用户的任何请求的情况下发送。

我正在将 rethinkdb 与 aiohttp 和 websockets 一起使用。这个怎么运作：

1. 用户发送消息
2. 服务器放入rethinkdb
3. 我需要什么：一个额外的循环使用 rethinkdb.changes函数向连接的用户发送更新

这就是我启动应用程序的方式：

在wshandler我有一个循环，它处理传入的消息：

如何创建第二个循环将消息发送到同一个打开的连接池？如何使其线程安全？

我在 RethinkDB 表中有以下 json 记录。

像这个一样，我的表中有数百万行。我想要实现的是根据 {sid,et} 的输入集过滤这个 json

我在 python 中使用下面的代码（skObj 是输入）::

上面的查询根据 sk 的输入集正确过滤了我在 RethinkDB 中的 cube7 表。skObj 最多可以包含 10 个集合。

我想看到的是每个输入集

我想用这个条件过滤表：

但目前它只做等于

如何在我的 lambda 表达式中为每组 (sid,et) 的 et 值使用大于？

如何从下面创建通用表达式 - 这适用于原始数据

假设我有一张包含以下文件的表格：

是否可以将所有文档分组为最终的 json 结构，例如：

如果是的话，最好和最有效的方法是什么？我有超过一百万个这样的文档，在 4 个带有强大服务器的分片上（每个 22 Gb 缓存）

我已经尝试过了（目前在数据资源管理器中，在 JS 中）：

接着

但是数据浏览器似乎挂起，如您所见，仍在处理它......

我从 rethinkdb 集群中获取的行包括带有时区的日期对象。这是一个例子：

我正在尝试将它们字符串化为某种格式：

它导致

我该如何克服呢？

当我收到来自客户端的消息时，我想并行运行多个 RethinkDB 查询并立即将结果发送给客户端。

阻塞方式如下。计数可能需要几分钟。我希望其他可以更快返回的查询不会被计数查询所阻碍。

我怀疑我需要https://rethinkdb.com/blog/async-drivers/和http://www.tornadoweb.org/en/stable/guide/async.html的组合

我在想也许答案是让这两行类似于：

我的运行查询将是：

我正在编写一个大致遵循此示例的应用程序。

当我提交一个 POST 请求时：

curl http://localhost:5000/todos -d "data=Remember the milk" -X POST

我从 RethinkDB 收到以下错误：

rethinkdb/ast.py", line 118, in run return c._start(self, **global_optargs) AttributeError: 'function' object has no attribute '_start'

有没有人遇到过这种事情？我将 RethinkDB 2.2.2 与 Python 3.5.0 和 Flask 0.10.1 一起使用。

谢谢，

爱洛

让我们假设这样的表格内容，对于相同的 product_id，我们在 status==1（已发布）和最后 status==0（未发布）期间的更新行数与更新数一样多，然后变为==2（已删除）

现在，我正在尝试寻找一种方法，可能使用二级复合索引，例如，给定一个日期，例如 col1（使用 r.time）

这里的困难在于，只要它的 last_updated 日期小于或等于提供的日期，product_id 文档仍将被视为最新状态。

我尝试按 product_id 分组，然后取 max('last_updated')，然后仅在 status==1 时保留每个缩减唯一文档

我想为每个状态/给定日期都有一个索引

或另一种解决方案，将在另一个表中插入聚合的结果，该聚合结果将仅存储每个日期的唯一文档，包含匹配相同条件的所有初始文档 ID，等等......然后稍后使用这些执行连接中间记录以在给定日期/状态获取每个 product_id 的值。

就像是：

请指教

编辑1：

这是我尝试运行以分析我的数据的查询示例，例如，这里是获取具有超过 1 个文档的每个组的状态的概述：

假设我需要在可以关联多个文档的表上维护一个索引，执行相同的 item_id（当然不是主键）。

一个二级复合索引是否可以基于任何 item_id 根据条件返回最新文档的函数的结果，在插入新文档时自行更新？

这张表在短短 25 天内已经保存了 120 万份文档，因此它是一个大数据案例，因为它会不断增长，并且必须始终保留旧记录，以构建多年来所需的任何数据中心。

我使用pyinstaller -F ./parser.spec.
然后我运行程序./dist/parser并得到这个错误：

我试图创建一个挂钩文件，但说实话，我真的觉得我不知道自己在做什么。

rethinkdb在hiddenimports但pyparser不会向我抛出任何错误，表明可能有什么问题。