rethinkdb-python

1热度

1回答

比方说，我们有这样的文件： doc = {'foo': 1, 'bar': 2, id: 123} 我怎么做，这样我可以有，有foo和bar值对，ID并将它们分配给2个变量？我需要这个，以便我可以在复杂的查询中使用这些变量，而不必复制/粘贴多次相同的reql命令。这是我的尝试： ( r.expr(doc) # doc as input .do(lambda d: [

2热度

2回答

RethinkDB插入和冲突解决函数语法

我试图学习如何使用lambda函数解决冲突插入到表rethinkdb和python表中时，就像这个page上的最后一个示例。我想比较old_doc和new_doc之间的timestamp字段，并保留更新的文档。 r.table(import_table).insert(documents, conflict=lambda id, old_doc, new_doc: new_doc if new_d

-1热度

1回答

想使用setInsert更新reThinkDB中的文档Python

r.db('usersData').table('smsRaw').get("3413b71c-1628-47eb-83fa-6a3cccdb3e62").update({"MESSAGE": r.row('MESSAGE').setInsert({"DATE":"20160111","MESSAGE":[{"ADDR":"LONDON","date":"1468385398746"}]})})

1热度

2回答

使用Python lambda时处理丢失的字段

我有这个rethinkDB查询，它基本上返回以“CA：FA”开头的“basicConstraints”字段的文档。但是在我的一些文档中，“basicConstraints”字段不存在。 q = r.db('scanafi').table(active_table) \ .concat_map(lambda doc: doc["certificates"]\ .concat_map(lambd

0热度

1回答

Rethinkdb - 具有特定条件的原子检索/更新行

我有一堆需要从数据库获取单个记录（行）的芹菜工作者。它应该只会在“last_used”字段后经过60秒后返回，并且一旦返回，它应该用当前时间更新“last_used”（因此其他有0次延迟的无限重试的工人不会得到同一个）是否有可能在db级别执行所有这些操作？我不会有任何其他来源更新这个“last_used”字段。下面是单行的样子。 {"id": "..." "last_used": "2016

0热度

1回答

RethinkDB更新领域内嵌套的阵列 - > OBJ

这里是我行的样子： {"id": x , "data": [ { "someId": 1 , "url": https://twitter.com/HillaryClinton?ref_src=twsrc%5Egoogle%7Ctwcamp%5Eserp%7Ctwgr%5Eauthor, » } , { "someId": 2 ,

0热度

1回答

导入到RethinkDB时出错

我在尝试将Google json文件导入到Google Cloud Compute Instance中的RethinkDB时出错，我不知道该如何处理此错误。任何帮助表示赞赏。这是错误： [email protected]:~# rethinkdb import -f users_0.json --table test.users Traceback (most recent call last)

1热度

1回答

如何使用python将字符串转换为rethinkdb中的日期？

我的rethinkdb以以下格式存储数据。 data = [{ 'appName': "app1", 'startTime': "Mon, 14 Feb 2017 05:10:00 GMT", 'endTime': "Mon, 14 Feb 2017 05:15:00 GMT", 'status': "SUCCESS" }, {

0热度

1回答

选择回国最大，最小和平均

我在RethinkDB新的，需要通过“ID”分组返回最小值，最大值和“价值”的魅力，这是我的Json的例子： { "mycontent": [ { "id": "000000000011", "value": "300" }, { "id": "000000000012", "value": "500"

1热度

1回答

如何使用RethinkDB的复合索引的最小/最大函数

假设我有一个RethinkDB表，其中有type和timestamp字段。 type可以是"good"或"bad"。我想写一个RethinkDB查询，获取最近的"good"文档的timestamp，同时使用compound index和type和timestamp。这里是用一种溶液的示例脚本： import faker import rethinkdb as r import dateuti