我如何做多个 eq_joins？

Question

我正在尝试执行多个 eq_joins。我得到的错误是：

ReqlQueryLogicError: Primary keys must be either a number, string, bool, pseudotype or array (got type OBJECT):
{
        "First name":   "John",
        "Last name":    "Urquhart",
        "employers":    [
                {
                        "date_hired":   "2-Mar-88",
                        "organization_id":      "2a5e2e3d-275a-426e-9ecd-0bd5601bff6b"
                }
        ],
        "id":   "e70d5350-c1e0-41ee-a1cc-6638c7136d89",
        "primary_photo":        "http://www.kingcounty.gov/~/media/safety/sheriff/Sheriff_Urquh in:
r.db('public').table(u'police_internal_affairs_allegations').filter(lambda var_24: var_24.coerce_to('string').match(u'(?i).*?Urquhart.*?')).eq_join(u'organization_id', r.db('public').table(u'organizations')).merge(lambda var_25: r.expr({'right': var_25['right'].coerce_to('array').map(lambda var_26: [(r.expr(u'organization_') + var_26[0]), var_26[1]]).coerce_to('object')})).zip().eq_join(u'person_id', r.db('public').table('people')).merge(lambda var_27: r.expr({'right': var_27['right'].coerce_to('array').map(lambda var_28: [(r.expr(u'person_') + var_28[0]), var_28[1]]).coerce_to('object')})).zip()

我的代码是：

ids_for_other_tables = [field for field in fields if field.endswith('_id')]
modified_joined_data = []
for field in ids_for_other_tables:

    special_names = {'person': 'people'}
    t = special_names[field[:-3]] if field[:-3] in special_names else field[:-3]+'s'
    dbobj = getattr(dbobj, 'eq_join')(field, r.db("public").table(t))

    dbobj = dbobj.merge(  lambda row: {'right': row['right'].coerce_to('array').map(
                  lambda pair: [r.expr(field[:-2]) + pair[0], pair[1]]
                ).coerce_to('object')})
    dbobj = dbobj.zip()

此代码的目的是自动连接表中以 _id 结尾的所有字段的信息

Answer 1

如果不查看 table 中的数据就很难说，但看起来问题在于您尝试 eq_join 的其中一个字段中有一个对象字段而不是 ID。我会运行在 eq_join 之前的查询部分，并确保它具有您期望的格式。

我如何做多个 eq_joins？

How I do multiple eq_joins?

python

rethinkdb