如何在 Rethinkdb 的 python lambda 表达式中应用大于等于

Question

我在 RethinkDB 中有以下 json 条记录 table。

[{
"pid": 12,
 "sk": [
       {
        "sid": 30,
        "et": 3
       },
       {
        "sid": 22,
        "et": 10
       },
       {
        "sid": 30,
        "et": 8
       }
      ],
"wc": [
      {
       "wid": 7,
       "et": 8
      },
      {
       "wid": 3,
       "et": 6
      },
      {
       "wid": 9,
       "et": 7
      }
    ]
}]

像这个一样，我在 table 中有数百万行。我想要实现的是根据 {sid,et}

的输入集过滤此 json

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

skObj=[{'sid': 1, 'et': 9},{'sid': 27, 'et': 6}]
cursor2=r.table('cube7').filter(lambda row: r.expr(skObj).set_difference(row['sk']).is_empty())['pid'].run(t)
cur_list2 = list(cursor2)

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

我希望看到的是每个输入集

skObj=[{'sid': 22, 'et': 10},{'sid': 30, 'et': 8}]

我想用这个条件过滤 table：

(sid=22 & et>=10) and (sid=30 & et>=8)

但目前它只等于

(sid=22 & et=10) and (sid=30 & et=8)

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

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

lambda x: (x['sid'] == 22) & (x['et'] >= 10)

Answer 1

所以您想获取 sk 数组包含至少一个与每个谓词匹配的文档的所有文档？

这是你想要的吗？

r.table('cube7').filter(
  lambda row: r.and_(r.args(r.expr(skObj).map(
    lambda x: row['sk'].contains(
      lambda y: (y['sid'] == x['sid']) & (y['et'] >= x['et'])
    )
  )))
)

如何在 Rethinkdb 的 python lambda 表达式中应用大于等于

How to apply Greater than equal in python lambda expression in Rethinkdb

python

lambda

rethinkdb

rethinkdb-python